2017-09-25 3 views
0

ドルイドのコンソールを開いたときに、http://localhost:8090/console.htmlを使用して私はすべての私のスーパーバイザのリストをカフカの話題に関連付けることができます。その後、私はJSONレスポンス以下、スーパーバイザのいずれかの状態をクリックすると"remainingSeconds"の意味:XXXX、 "type": "ACTIVE"はドルイドのスーパーバイザのステータスオブジェクトにありますか?

{ "ID": "テストkafka7"、 "generationTime": "2017-09-25T12:53:44.003Z"、」 1 "、" durationSeconds ":3600、" activeTasks ":[{" id( "id")} "、"ペイロード ":"データソース ":"テストカフカ7 "、"トピック ":"テストカフカ2 "、"パーティション " ":" index_kafka_test-kafka7_4b18d459ca23552_dpdodphp "、" startingOffsets ":{" 0 ":0}、" startTime ":" 2017-09-25T12:44:34.572Z "、" remainingSeconds ":3050、" type ":" ACTIVE " 、 "currentOffsets":{"0":0}、 "ラグ":{"0":0}}、 "publishingTasks":[]、 "latestOffsets":{"0":0}、 "minimumLag" { "0":0}、 "aggregateLag":0、 "offsetsLastUpdated": "2017-09-25T12:53:31.617Z"}}

Iはを参照して何度も、"type":"ACTIVE"のステータスです。しかし、私はこのタイプの意味を理解していない:アクティブ秒と残りの秒、何秒の残りの秒ですか?時にはこれらの2つのキーが表示されないこともあるので、時々表示されるのはなぜ混乱しすぎて、別の時に表示されないのか、これらの用語の意味さえ分かりません。誰が私にこれらのキーの意味が何であるか教えてください。そして、なぜ彼らは時々出現し、他の時に現れないのですか?

答えて

1

スーパーバイザのステータスは、監視しているすべてのタスクの現在のステータスを表示しています。 "type"フィールドと "remainingSeconds"フィールドは、特定のタスクを記述しています。

タイプACTIVEは、タスクが現在カフカからデータを消費していることを意味します。もう1つの可能なタイプはPUBLISHINGです。これは、タスクがKafkaからデータを消費し、Druidの共有ディープストレージにパブリッシュを開始したことを意味します。

これは、ACTIVEタスクがPUBLISHINGに移行するまでに残っている秒数である「remainingSeconds」をもたらします。各タスクのライフサイクルはACTIVEから始まり、次にPUBLISHINGになり、終了します。

+0

ありがとう、回答のための@Gian。ステータスオブジェクトのキーに関するドキュメントを入手できるリンクを教えてください。そして、なぜいくつかのタスクがアクティブなステータスを取得しないのはなぜかという疑問がもうありましたか?私が気付いたことは何度もありますが、3つのタスクを作成すると、2つがアクティブになり、そのうちの1つが永久にアクティブな状態にならず、自分のデータを消費せず、公開ステータスにもなりません。 –

+1

特定のフィールドの意味は文書化されていません。ドキュメントを追加する際に問題を提出してもかまいません(また、PRで自分自身を起動することもできます)。 ステータスを持たない(ACTIVEでもPUBLISHINGでもない)タスクは、まだ起動されていない可能性があります。すべてを実行するのに十分なタスク容量がない可能性がありますか? –

+0

はい、私は間違いなくオブジェクトの適切なドキュメントを要求する問題を提出します。でも私はPLを押したいですが、各キーの理解が正しいかどうかは分かりません。ジアン、あなたは私が十分な容量を持っていないかもしれないと言ったように?私はあなたが正しいと思うし、ここではあなたが労働者の能力について話していると仮定しています。これらの労働者の能力を増やす方法を理解できるリンクやサイトに私を案内してください。 –

関連する問題