我正在尝试实现hadoop流文档中解释的状态更新:
如何更新流应用程序中的状态?
流处理可以使用stderr发出状态信息。要设置状态, reporter:status:<message>
应发送到 stderr
.
是这个吗 reporter:status
保存在任何地方的信息,还是仅仅是一条心跳消息来显示流处理正在进行?
如果我打电话 sys.stderr.write("test message")
,我可以去尝试>日志>色调中的stderr并查看此消息。
但是,如果我把它改成 sys.stderr.write("reporter:status:test message")
,我哪儿也找不到。
暂无答案!
目前还没有任何答案,快来回答吧!