2017-04-13 23 views
1

sparkランチャーでsparkアプリケーションを送信します。私はアプリケーションが完了するまで待たずにアプリケーションを終了させる必要があります。Spark - javaのアプリIDでspakrアプリハンドルを取得する方法

SparkAppHandle spark = new SparkLauncher() 
      .setAppResource("/usr/local/myapp.jar") 
      .setMainClass("com.myapp.app") 
      .setMaster("yarn") 
      .setDeployMode("cluster") 
      .startApplication(this); 

とget app id。

String id = spark.getAppId(); // how to wait untill not UNKONWN? 
SparkAppHandle curApp = ???.getHandleByID(id); // how to get? 

にはどうすればいいのApp IDでSparkAppHnadleを得ることができますので、私はDestoryは()メソッドを呼び出すことができます。

答えて

0

その他の情報でSparkAppHandleを取得する方法はありません。私は、appIDまたは一意の文字列をキーとするハッシュマップと、値としてのSparkAppHandleを作成して解決しました。これは基本的な解決策ではありませんが、それはこれまでの唯一の解決策です。

関連する問題