flink sql。kafka 接受double为0的数据群,最后变为了0.0 有办法解决吗?
flink sql。kafka 接受double为0的数据群,最后变为了0.0 有办法解决吗?
Flink CDC 如果用sql方式的话中间是不是必须要经历kafka来转换一下呢?
Flink CDC mysql到hive,如果用sql方式的话中间是不是必须要经历kafka来转换一下呢?
flink cdc sql方式将mysql同步到kafka时报发下错误,有遇到的吗?
flink cdc sql方式将mysql同步到kafka时报发下错误,kafka是集群模式,有遇到的吗?
flink sql读取kafka数据
kafka数据源中的数据格式是数组格式:[{"a":1,"b":2},{"a":3,"b":1}],flink sql应该如何定义对应的schema去读取数据?
flink sql 写数据到kafka,我应该怎么组织数据 写入kafka呢?
flink sql 写数据到kafka,kafka的数据格式json是嵌套的 我应该怎么组织数据 写入kafka呢?
Flink CDC我自定义了一个flink SQL的Kafka分区器,有遇到这个问题的吗?
Flink CDC我自定义了一个flink SQL的Kafka分区器,在写入的时候会报类型转换异常,有遇到这个问题的吗?
请问有flink sql 1.15 从kafka读取数据然后写入clickhouse的示例代码吗
环境说明:flink sql 1.15 on yarn 模式 现在需要去读取kafka的数据,然后写入clickhouse。 请问有示例代码,包括pom.xml文件中需要添加哪些信息吗? 主要是想问下sink表怎么建,pom文件怎么引入依赖
这个flink问题怎么解决? sql 消费kafka,开启了checkpoint。
这个flink问题怎么解决? sql 消费kafka,开启了checkpoint。topic每个分区都是有数据,现在监控发现,flink作业在提交offset的时候,消费一段时间后,有1个partition的数据offset不提交了,但是这个partition一直有数据。
请教大家一个flink sql 消费kafka,开启了checkpoint。topic每个分区都是有
请教大家一个flink sql 消费kafka,开启了checkpoint。topic每个分区都是有数据,现在监控发现,flink作业在提交offset的时候,消费一段时间后,有1个partition的数据offset不提交了,但是这个partition一直有数据
一个Flink SQl的job中,消费同一个kafka,使用滚动窗口计算每小时的统计,使用渐进式窗?
一个Flink SQl的job中,消费同一个kafka,使用滚动窗口计算每小时的统计,使用渐进式窗口计算零点到当前的统计;现在遇到一个问题:滚动窗口计算 需要设置 table.exec.emit.early-fire.enabled = true; table.exec.emit.early-fir...
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。