读取kafka直接写入starrocks,flinksql提交，有参数把算子分开吗？-[阿里云_云淘科技]

匿名 • 2023年12月10日下午5:35 • 阿里云

读取kafka直接写入starrocks,flinksql提交，算子合并了看不到读取写入数量计数器的值，有参数把算子分开吗？

以下为热心网友提供的参考意见

env.disableOperatorChaining(); ，此回答整理自钉群“【③群】Apache Flink China社区”

以下为热心网友提供的参考意见

在Flink SQL中，可以使用UNION ALL来将多个算子分开。例如，如果你有两个算子分别用于读取Kafka和写入StarRocks，可以将它们分开并使用UNION ALL连接起来。这样，每个算子的计数器值将会单独显示。

以下是一个示例：

SELECT * FROM kafka_source;
UNION ALL
SELECT * FROM starrocks_sink;

在这个示例中，kafka_source和starrocks_sink分别是用于读取Kafka和写入StarRocks的算子。通过使用UNION ALL，你可以将它们分开并查看各自的计数器值。

本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：https://www.cnzhanzhang.com/13650.html