apache-kafka - KSQL WARN警告: window end time was truncated to Long. MAX是什么意思？

Question

我在 ksql-server.stdout 中收到 ksql WARN 警告:窗口结束时间被截断为 Long.MAX。

我想知道在什么情况下会触发此警告以及重要程度，因为生成此警告的查询也提供了从功能角度来看的预期结果。

查看 ksql 源代码 - 试图理解已处理警告的预期含义及其重要程度

查询工作正常 - 只是有这个警告 WARN Warning: window end time was truncated to Long.MAX in ksql-server.stdout.

Answer 1

如果窗口的计算结束时间超出范围，则输出此警告日志行反序列化翻滚或跳跃窗口键。

只有在使用 PRINT topic 命令时才会看到此警告。参见 https://github.com/confluentinc/ksql/issues/5458了解详情。

如果您在正常处理数据期间看到此警告，即当不使用 PRINT 命令时，则可能是您导入了带有窗口​​键的流，即使用 WINDOW_TYPE='hopping' 或 WINDOW_TYPE='tumbling' 窗口大小 WINDOW_SIZE 错误，或者基础源主题没有时间窗口键。