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

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

「点点赞赏，手留余香」

还没有人赞赏，快来当第一个赞赏的人吧！

=====这是一个广告位，招租中，联系qq 78315851====

1 条回复 A 作者 M 管理员

xin在这AM 2023-12-21 8:08:57 1

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

已喜欢已反对
小周sirAM 2023-12-21 8:08:57 2
在Flink SQL中，可以使用UNION ALL来将多个算子分开。例如，如果你有两个算子分别用于读取Kafka和写入StarRocks，可以将它们分开并使用UNION ALL连接起来。这样，每个算子的计数器值将会单独显示。

以下是一个示例：

SELECT * FROM kafka_source;UNION ALLSELECT * FROM starrocks_sink;

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

读取kafka直接写入starrocks,flinksql提交，有参数把算子分开吗？[阿里云] 暂停朗读为您朗读