我怎样才能完成德鲁伊任务？
How can I complete a Druid Task?
我在 Druid 数据源上导入了一些数据。为此，我使用 Nifi 和 Tranquility 以微小的粒度进行流式注入（用于我的测试）。
我用 Ambari 来检查我的所有任务及其状态。
我的所有数据都正确导入到我的数据源中，我可以使用 Hive 查询请求它们。
当我在 Ambari 上查看我的任务时，它们都是 运行，它们从来都不是 "Complete"。如果我想完成其中一个，我必须杀死它，但我丢失了我的数据和状态任务是 "FAILED"。
我想了解如何才能成功完成我的任务。
谢谢。
我发现了问题。
在我的宁静会议中，我为 "WindowPeriod" 声明了一个很大的值。
事实上，任务在"WindowPeriod"结束时自动结束。
例如"WindowPeriod":"PT10M"表示任务将在10分钟后结束。
很高兴你明白了！只是想提醒所有阅读本文的人，Tranquility 已被弃用。应该为开始新部署的任何人提供 https://druid.apache.org/docs/latest/development/extensions-core/kafka-ingestion 等流媒体摄取服务。
我在 Druid 数据源上导入了一些数据。为此，我使用 Nifi 和 Tranquility 以微小的粒度进行流式注入（用于我的测试）。
我用 Ambari 来检查我的所有任务及其状态。
我的所有数据都正确导入到我的数据源中，我可以使用 Hive 查询请求它们。 当我在 Ambari 上查看我的任务时，它们都是 运行，它们从来都不是 "Complete"。如果我想完成其中一个，我必须杀死它，但我丢失了我的数据和状态任务是 "FAILED"。
我想了解如何才能成功完成我的任务。 谢谢。
我发现了问题。
在我的宁静会议中，我为 "WindowPeriod" 声明了一个很大的值。
事实上，任务在"WindowPeriod"结束时自动结束。
例如"WindowPeriod":"PT10M"表示任务将在10分钟后结束。
很高兴你明白了！只是想提醒所有阅读本文的人，Tranquility 已被弃用。应该为开始新部署的任何人提供 https://druid.apache.org/docs/latest/development/extensions-core/kafka-ingestion 等流媒体摄取服务。