2016-05-21 10 views

答えて

1

はStreamingApplication

ストリングAPPID = dag.getValue(DAGContext.APPLICATION_ID)に渡されるCONFオブジェクトを使用し、オペレータは

ストリングAPPID = Context.OperatorContext.getValue(Context.DAGContext APPLICATION_ID。)を使用します。

注: populateDAG機能内では実行できません。 APPLICATION_IDは、起動後にアプリケーションに割り当てられます。 populateDag()フェーズでは、論理プランが作成されていますが、実際のYARNアプリケーションは作成されません。 APPLICATION_IDはまだ作成されていないため、それはnullです。

関連する問題