quel est le sens de "remainingSeconds": XXXX, "type": "ACTIVE" dans l'objet d'état du superviseur de druide?

Question

Après avoir démarré druid quand j'ouvre la console de druid en utilisant http://localhost:8090/console.html je peux voir la liste de tous mes superviseurs liés aux sujets de Kafka. Puis, quand je clique sur l'état de l'un des superviseur je reçois la réponse suivante JSON

{ "id": "test-kafka7", "generationTime": "2017-09-25T12: 53: 44.003Z", » charge utile ": {" dataSource ":" test-kafka7 "," sujet ":" test-kafka2 "," partitions ": 1," réplicas ": 1," durationSeconds ": 3600," activeTasks ": [{" id ":" index_kafka_test-kafka7_4b18d459ca23552_dpdodphp "," startingOffsets ": {" 0 ": 0}," startTime ":" 2017-09-25T12: 44: 34.572Z "," remainingSeconds ": 3050," type ":" ACTIVE " "currentOffsets": {"0": 0}, "lag": {"0": 0}}], "publishingTasks": [], "latestOffsets": {"0": 0}, "minimumLag": { "0": 0}, "aggregateLag": 0, "offsetsLastUpdated": "2017-09-25T12: 53: 31.617Z"}}

Plusieurs fois, je vois "remainingSeconds": NNN, "type":"ACTIVE" dans le statut. Mais je ne comprends pas ce que signifie ce type: secondes actives et restantes, secondes restantes pour quoi? Et parfois ces deux clés n'apparaissent même pas, alors je suis trop confus pourquoi apparaissent-ils parfois et pourquoi n'apparaissent-ils pas d'autres fois, je ne comprends même pas le sens de ces termes. Quelqu'un peut-il me dire quelle est la signification de ces clés et pourquoi apparaissent-elles parfois et n'apparaissent pas d'autres fois?

Answer 1

L'état du superviseur vous montre l'état actuel de toutes les tâches qu'il supervise. Les champs "type" et "remainingSeconds" décrivent une tâche particulière. Type ACTIVE signifie qu'une tâche utilise actuellement des données de Kafka. Un autre type possible est PUBLISHING qui signifie que la tâche est consommée en consommant des données de Kafka, et a commencé à le publier dans le stockage profond partagé par Druid.

Cela nous amène à "remainingSeconds", qui est le nombre de secondes restantes avant qu'une tâche ACTIVE ne passe à la publication. Chaque tâche a un cycle de vie où elle commence ACTIVE, puis devient PUBLICATION, puis se termine.