apache-flink - Flink Table API 不会处理所有记录
问题描述
我们使用 Flink Table API 来处理从 mysql（使用 maxwell）推送到 kafka 的流记录。我们将流注册为表并基于 3 个主题执行连接查询。当我们尝试从 maxwell 引导数据时，第一次运行引导时 flink 应用程序只处理很少的记录。当我再次运行引导程序时，它会处理所有记录。任何人都可以让我知道您是否遇到过类似的问题以及如何解决它，这样当我引导时，所有记录都会在第一次运行时自行处理。在使用 Flink 中的 Table API 处理基于多个流的连接时，我需要指定任何配置吗？非常感谢任何指针。
解决方案
推荐阅读
- c# - 除非必要，否则如何不评估三元运算符的第三部分
- python - 调用 pandas.get_dummies() 后的疑惑结果
- java - Wildfly 中奇怪的请求/响应机构？
- c# - c#服务器套接字数据没有正确接收
- angularjs - 如果 Angular Js 中的控制器相同，如何将数据从 1 个视图传递到另一个视图？
- python - Python Kivy 更新 KV 文件中子部件的文本
- python - Firefox 不会多次更新视图。（姜戈）
- aframe - 标记处于垂直位置时如何配置ar.js
- vaadin - 如何在 Vaadin 10 组合框中添加语言标志
- java - 使用 Spring Data JPA 在 postgresql 中创建表空间