Как я могу выполнить задание друида?

Question

Я импортирую некоторые данные из моего источника данных Druid. Для этого я использую Nifi и Tranquility для потоковой инъекции с мелкой детализацией (для моих тестов).

У меня есть Ambari для проверки всех моих задач и их статуса.

Все мои данные импортированына мой источник данных правильно, и я могу запросить их с помощью запроса Hive. Когда я смотрю свои задачи на Ambari, все они выполняются, они никогда не выполняются. Если я хочу выполнить один из них, мне нужно его убить, но я теряю свои данные, и задача статуса «СБОЙ».

Я хотел бы понять, что я могу сделать для успешного выполнения своих задач. Спасибо.

Answer 1

Рад, что ты это понял! Просто хочу призвать тех, кто читает это, что Спокойствие устарело. Сервисы потоковой передачи, такие как https://druid.apache.org/docs/latest/development/extensions-core/kafka-ingestion, должны предлагаться всем, кто начинает новое развертывание.

Answer 2

Я обнаружил проблему.

В моем conf спокойствия я объявил большое значение для "WindowPeriod".

Фактически, задача автоматически заканчивается, когда заканчивается "WindowPeriod".

Например, "WindowPeriod":"PT10M" означает, что задача завершится через 10 минут.