如果kafka topic收到与kafka connector sql字段不符的记录，导致flink
如果kafka topic收到与kafka connector sql字段不符的记录，导致flink sql作业反序列化报错，该怎么办呢？
写个sql，两个datastream都是kafka生成的，然后join，结果写入mysq
写个sql，两个datastream都是kafka生成的，然后join，结果写入mysql。那这两个datastream会丢失吗？
Flink 我在sql cli执行连接kafka建表sql（该kafka接收csv数据），然后有一条
Flink 我在sql cli执行连接kafka建表sql（该kafka接收csv数据），然后有一条数据造的不符合字段格式，导致报错，然后该flink作业就无法继续running了，请问该如何处理呢？
问下哈，我现在场景是从kafka接数据源一份到hive一份测流到mq。但是hive sql提交得ta
问下哈，我现在场景是从kafka接数据源一份到hive一份测流到mq。但是hive sql提交得tableapi和stream提交只能运行一个，如何能同时提交两条流
Flink SQL读取Kafka数据并写入 Kafka另外一个主题，为何总是持续重启？
Flink SQL读取Kafka数据并写入 Kafka另外一个主题，为何总是持续重启？
各位, 请问: flink cdc, 用 flink sql 的方式 sink 到 kafka 可以
各位, 请问: flink cdc, 用 flink sql 的方式 sink 到 kafka 可以指定输出 schema 信息嘛? 看到好像只有 api 中可以指定 .deserializer(new JsonDebeziumDeserializationSchema(true)). flink ...
各位kafka里多张表的数据 flink sql如何 分别映射不同的表呢？
各位kafka里多张表的数据 flink sql如何 分别映射不同的表呢？
请问下，我要用sql方式写入Kafka，用哪个connector呢？
请问下，我要用sql方式写入Kafka，用哪个connector呢？
大家知道 flink sql 消费kafka如何感知动态添加topic吗？ topic-patt
大家知道 flink sql 消费kafka如何感知动态添加topic吗？ topic-pattern目前用这种方式感知到了但是没有写进去数据
各位大佬，idea中测试使用FlinkCDC SQL 读取Mysql 数据写入Kafka中，代码中创
各位大佬，idea中测试使用FlinkCDC SQL 读取Mysql 数据写入Kafka中，代码中创建了checkpoint，发现每次重启Idea中FlinkCDC的代码都会全量读取Mysql数据并写入Kafka，请教一下如何以增量的方式读取Mysql数据写入Kafka呢？是不是每次重启程序都会全量...
更新时间 2023-09-07 03:56:15
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
社区圈子
