2017-09-25 39 views
0

當我開始德魯伊時,當我打開德魯伊的控制檯使用http://localhost:8090/console.html我可以看到所有我的監督連接與卡夫卡主題列表。後來,當我對任何主管的狀態單擊我獲得以下JSON響應druid的主管狀態對象中「remainingSeconds」的含義是什麼:XXXX,「type」:「ACTIVE」?

{ 「ID」: 「測試kafka7」, 「generationTime」: 「2017-09-25T12:53:44.003Z」,」有效載荷 「:{」 數據源 「:」 測試kafka7" , 「主題」: 「測試kafka2」, 「分區」:1, 「副本」:1, 「durationSeconds」:3600, 「activeTasks」:[{「編碼「:」 index_kafka_test-kafka7_4b18d459ca23552_dpdodphp」, 「startingOffsets」:{ 「0」:0}, 「開始時間」: 「2017-09-25T12:44:34.572Z」, 「remainingSeconds」:3050, 「類型」: 「ACTIVE」 「currentOffsets」:{ 「0」:0}, 「滯後」:{ 「0」:0}}], 「publishingTasks」:[], 「latestOffsets」:{ 「0」:0}, 「minimumLag」: { 「0」:0}, 「aggregateLag」:0, 「offsetsLastUpdated」: 「2017-09-25T12:53:31.617Z」}}

很多次,我看到"remainingSeconds": NNN"type":"ACTIVE"處於狀態。但我不明白這種類型的含義:活動和剩餘秒數,剩餘秒數是什麼?有時候這兩個鍵甚至不會出現,所以我對它們爲什麼偶爾出現以及爲什麼不出現其他時間太困惑了,我甚至都不理解這些術語的含義。任何人都可以告訴我這些鑰匙是什麼意思,爲什麼他們有時會出現,而不會出現其他時間?

回答

1

主管狀態向您顯示所監督的所有任務的當前狀態。 「type」和「remainingSeconds」字段描述了一個特定的任務。

類型ACTIVE意味着任務當前正在使用來自Kafka的數據。另一種可能的類型是PUBLISHING,這意味着該任務完成了Kafka的數據消耗,並已開始將其發佈到Druid的共享深存儲。

這將我們帶到「remainingSeconds」,這是ACTIVE任務轉換到PUBLISHING之前剩餘的秒數。每個任務都有一個生命週期,它從ACTIVE開始,然後變成PUBLISHING,然後結束。

+0

非常感謝,@Gian的答案。你可以給我任何鏈接,我可以得到狀態對象的鍵的文檔。而且我還有一個疑問,那就是爲什麼某些任務不能獲得ACTIVE狀態?就像我注意到的很多次一樣,如果我創造3個任務,其中2個任務可能會激活,其中一個任務永遠不會處於活動狀態,也不會將我的數據用於德魯伊,也不具有發佈狀態。 –

+1

特定領域的含義沒有記錄,雖然它應該是;隨時提交添加文檔的問題(甚至可以在PR中自行啓動!)。 沒有任何狀態(ACTIVE或PUBLISHING)的任務可能尚未啓動。你可能沒有足夠的任務容量來運行它們? –

+0

是的,我肯定會提出問題,要求他們爲對象提供適當的文檔。即使我想推PL,但我不確定我對每個鍵的理解是否正確。吉安,你說過我可能沒有足夠的能力吧?我想你可能是對的,我在這裏假設你在談論工人的能力。你能否指引我到任何可以瞭解如何提高這些工人能力的環節或地點? –

相關問題