是否可以使用 HepPlanner 进行逻辑计划优化，因为 HepPlanner 比 VolcanoPlanner 更快。
我的 Flink 程序有问题（背景：Java 代码库，Flink 版本 1.12.1 - 该版本是业务需求，但如果这是此版本的已
我们正在尝试从 DB-cdc 连接器（upsert 行为）表加入。
使用 'kafka' 事件源，通过现有的 cdc 数据按键丰富
我的数据来自两个不同的 Kafka 主题，由不同的代理提供服务，每个主题具有不同数量的分区。一个流包
我不确定如何在 sql-client.sh 中使用保存点我尝试使用以下步骤进行测试。它没有成功。
你能帮我理
我们正在努力根据帐户上的活动得出帐户的状态。我们根据帐户上的用户活动计算并保留到期日期（即
我可以在 Apache Flink 中检查点并将动态表存储到 RocksDB 作为持久后端吗？
如果是这样，我可以在这里拥
非常需要任何帮助，所以像这样在 AWS Kinesis Analytics Studio Flink SQL 上运行 =>
<pre><code>%flink.ssql
drop table
我需要延迟处理某些事件。
例如。我有三个事件（在 Kafka 上发布）：
<ul>
<li>A (id: 1, retryAt: now)<
我试图理解为什么在我的工作中使用 <code>upsert-kafka</code> 源时，我看到的记录基本上是重复的。
假
