apacheflink连接

Apache Flink - 启用连接排序

我注意到Apache Flink没有优化表连接的顺序。目前，它保留了用户指定的连接顺序（基本上，它按字面顺序进行查询）。我想Apache Calcite可以优化连接的顺序，但由于某些原因，这些规则在Apache Flink中没有使用。例如，如果我们有两个表' R '和' S ' private val tableEnv: BatchTableEnvironment = TableEnviron...

如果缺少一些事件，如何使用apache flink稳健地计算连接？

我有一连串的jsons通过kafka和iam尝试使用apache flink加入密钥。其中5个具有相同的键，所以我想使用全局窗口并提供触发器为5.但问题是如果只有四个jsons到达而第五个从未到来的话。如何处理这种情况。我需要处理的所有故障情况。有人请提供输入作为我刚接触流处理的输入，我想用flink探索。