2017-12-06 5 views
0

Javaアクションにスケジューラー時間を渡す必要があります。oozie、コーディネーターにスケジューラー時間を渡してください。

たとえば、1分のスケジューラ時間を設定します。現在の時間は15:45ですが、遅延やエラーが発生したため、現在実行されているJavaアクション時間は15:40(5分遅れ)になり、Javaアクションで実行時間を記録する必要があります。 Javaコード(jar)を引数として使用します。

どうすればこの問題を解決できますか?

おかげ

+0

'COORDフォーマットする方法の例を検索:nominalTime()'と行動にワークフローにコーディネーターからそれを渡します。分だけ正確です。 –

答えて

0

あなたはタイムスタンプを取得し、引数としてJavaコードに渡すEL function「文字列のタイムスタンプ()」で構築oozieを使用することができます。 例えば

<action name='actionJava'> 
     <java> 
      <job-tracker>${jobTracker}</job-tracker> 
      <name-node>${nameNode}</name-node> 
      <name>JavaAction</name> 
      <main-class>com.oozie.JTestMain</main-class> 
      <arg>${timestamp()}</arg> 
     </java> 
     <ok to="end" /> 
     <error to="killJob" /> 
</action> 
関連する問題