问答 2022-02-15 来自:开发者社区

mq 的消息 过来需要 join 业务方的数据(mysql table) ,是不是将 #Flink

mq 的消息 过来需要 join 业务方的数据(mysql table) ,是不是将 mq 的消息作为一个streaming ,过来了一条数据就去 jdbc 查询 mysql 的数据,还是 他会将 mq 作为 一个流,mysql 的数据也作为一个流,进行双流 进行join,这种应该是tempolar join ,blink 的temporal join 使用lookup 方式,这种会不有性能影响....

问答 2022-02-15 来自:开发者社区

使用Flink Table对接Kafka 当使用startFromLatest且开启对 #FLink

使用Flink Table对接Kafka 当使用startFromLatest且开启对应的checkpoint时 当手工重启作业时如何从上一次停止的kafka offset进行继续消费? #Flink

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注