Flink CDC里如果源端 MySQL 主键是bigint unsigned 类型, 怎么转换?

Flink CDC里如果源端 MySQL 主键是bigint unsigned 类型, 转换成 cdc 类型为 decimal , 然后写到 starrocks 对应的类型为 decimal128 , StarRocks 不支持 decimal 作为主键的类型, 我也尝试过改 cdc 源码将 big...

Flink CDC里bigint类型的id 20位,同步到starrocks 最后几位会失真为啥?

Flink CDC里bigint类型的id 20位,同步到starrocks 最后几位会失真是怎么个情况cdc 3.0 整库同步模式,flink cdc sh,

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

Flink CDC数据表中的字段是bigint,接收到字段类型是Decimal,这是因为字符集的?

Flink CDC数据表中的字段是bigint,接收到字段类型是Decimal,这是因为字符集的原因么?

flink 2.4.1 主键id读取好像有点问题 数据库是bigint 读取过来是字符串?

flink 2.4.1主键id读取好像有点问题 数据库是bigint 读取过来是字符串?

字段是long类型(毫秒级的时间戳)对应flink是bigint类型,怎么转成flink#Flink

字段是long类型(毫秒级的时间戳)对应flink是bigint类型,怎么转成flinksql支持的timestamp作为watermark,flinksql建表的时候用 #Flink

FLINK SQL 1.10 如何直接将bigint类型时间数据转换为Timestamp类型数据而不

我是Flink新手,正在学习flink sql相关开发,参考的阿里云开发文档进行学习 https://www.alibabacloud.com/help/zh/faq-detail/64813.htm?spm=a2c63.q38357.a3.3.368d1352JdVsRU 我现在有一些13位的bi...

Flink SQL中的DATE_FORMAT()函数中,如何将bigint转换为timestamp类型?

Flink SQL中的DATE_FORMAT()函数中,如何将bigint转换为timestamp类型?用cast转换失败,有大佬遇见这种问题么?

相当于Flink-SQL中的“from_unixtime(bigint unixtime)”

我正在寻找相当于函数from_unixtime(bigint unixtime),它存在于Flink-SQL中的Spark-SQL中。我的目标是转换此格式:1439799094进入这种格式:2015-05-18 05:43:37

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

产品推荐

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
基于 Flink CDC 打造 企业级实时数据集成方案
李劲松|Flink Table Store 典型应用场景
立即下载 立即下载 立即下载