【发布时间】:2014-01-09 06:06:40
【问题描述】:
我使用下面的 Rscript 作为 hadoop 流的映射器。我想在 tasktracker 的控制台或 oozie 所做的任何其他日志位置上查看日志信息\警告等,但它没有任何原因。我的 oozie 工作已成功完成
脚本
#! /usr/bin/env Rscript
library(methods)
library(utils)
library(devtools)
library(corpcor)
library(getopt)
library(logging)
library(HadoopStreaming)
main <- function() {
paste("A", 1:50, sep = "")
input <- file("stdin", open = "r")
loginfo("CUSTOM ERROR")
targets <- read.table(file="meta_reference1.csv", sep=";")
print("############################################")
print(target)
close(input)
}
为测试目的更新了 Rscript
#! /usr/bin/env Rscript
library(methods)
library(utils)
library(devtools)
library(corpcor)
library(getopt)
library(logging)
library(HadoopStreaming)
main <- function() {
write("prints to stderr", stderr())
write("prints to stdout", stdout())
}
没有出现日志..请建议
【问题讨论】:
-
糟糕,这是我的错误……我没有调用 main 函数,所以它不起作用。我刚刚打电话给 main() 并且它起作用了
标签: hadoop hadoop-streaming oozie rscript