mesos-rxjavaライブラリでMesosタスクを終了させたり、フレームワークをシャットダウンする方法を探しています。 subscribe()の後、メゾスからのイベントに応じて、メゾスにコールを送信する唯一の機会があります。私は、Fenzoを別のスケジューリング・ループに統合することができました。これは、PromiseからObservableを使用してオファー・リースに応答し、Fenzoループの約束を保存することで可能です。その仕事を打ち負かすことを約束してください。しかし、まだ開始していないタスクを取り消すことはできませんし、フレームワークをシャットダウンするために解決しません。または、単に非反応的な方法でHTTPリクエストを送信するためにライブラリの認証を使用する方法がありますか?私が紛失しているクリーナーソリューションはありますか?mesos-rxjava - タスクとシャットダウンスケジューラを終了する
0
A
答えて
1
私はここでTEARDOWN Call [1]を呼び出しています。このコールがスケジューラからmesosに送信されると、クラスタ全体でフレームワークが完全にシャットダウンされます。
mesos-rxjavaクライアントに提供するObservable(Observablesを下のリンク2にまとめて織り成す例があります)にSubjectを織り込むことで、自分自身にハンドルを提供して、イベントへの直接的な反応。下のリンク3はこれをもう少し説明するGithubの問題へのリンクです。
[1] https://github.com/apache/mesos/blob/master/docs/scheduler-http-api.md#teardown
[2] https://github.com/mesosphere/mesos-rxjava/blob/master/mesos-rxjava-example/mesos-rxjava-example-framework/src/main/java/com/mesosphere/mesos/rx/java/example/framework/sleepy/Sleepy.java#L140
[3] https://github.com/mesosphere/mesos-rxjava/pull/63#issuecomment-235043568
関連する問題
- 1. タスクが終了するとタスクを終了する
- 2. タスク。タスクが完了する前にすべて終了する
- 3. タスク内でセロリタスクを終了する
- 4. 1回のスパーク・タスクを終了する
- 5. sbtタスクを終了するには?
- 6. メインスレッドが終了すると非同期タスクが終了しますか?
- 7. タスクが終了したらUIAlertViewを終了します
- 8. Laravelキューのタスクが終了する
- 9. バックグラウンドでJavaExecタスクを実行し、ビルドが完了すると終了する
- 10. タスク開始時間とタスク終了時間をBaseXに記録する方法
- 11. C#終了タスクが終了しないプロセス
- 12. タスクがプロセス終了前に終了していない
- 13. タスクが終了コードnullで終了しました
- 14. android - タスクが終了するとProgressDialogが遅すぎる
- 15. 終了しますスケジュールされたタスク
- 16. JavaFX - タスクを完全に終了または終了できますか?
- 17. Javaマルチスレッド - タスクがそのジョブを終了するたびにタスクをスケジュールする
- 18. タスクをキャンセルするか、タスクの実行を即座に終了するには?
- 19. forループからタスクを開始し、ループが終了すると終了します
- 20. を終了一気-タスクによってロードされたタスクが
- 21. タスクが終了した後のAlarmManager
- 22. タスクが終了し、[C#UWP]使用
- 23. Backgroundrbスケジュールされたタスクの終了
- 24. Gulp Watchタスクの早期終了
- 25. ASyncタスクが終了した後にアンドロイドサービスを終了する方法完了しましたか?
- 26. タスクをキャンセルして終了するまで待ちます
- 27. タスクのすべてのアクティビティを終了する
- 28. SLURM別のタスクが終了したらタスクをqsubする方法は?
- 29. mpirunプロセスを終了すると、bashループが終了する
- 30. サブプロセスを終了するとPythonプログラムが終了する