flink sql。kafka 接受double为0的数据群,最后变为了0.0 有办法解决吗?

flink sql。kafka 接受double为0的数据群,最后变为了0.0 有办法解决吗?

Flink CDC 如果用sql方式的话中间是不是必须要经历kafka来转换一下呢?

Flink CDC mysql到hive,如果用sql方式的话中间是不是必须要经历kafka来转换一下呢?

如何在 PolarDB-X 中优化慢 SQL

2 课时 |
113 人已学 |
免费

SQL完全自学手册

61 课时 |
3601 人已学 |
免费

SQL Server on Linux入门教程

14 课时 |
4329 人已学 |
免费
开发者课程背景图

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...

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

产品推荐

社区圈子

数据库
数据库
分享数据库前沿,解构实战干货,推动数据库技术变革
253179+人已加入
加入
相关电子书
更多
用SQL做数据分析
阿里云流计算 Flink SQL 核心功能解密
SQL智能诊断优化产品SQLess蚂蚁最佳实践
立即下载 立即下载 立即下载