Flink CDC里这个是字段属性类型问题吗?

Flink CDC里这个是字段属性类型问题吗?java.lang.IllegalArgumentException: Variable character string length must be between 1 and 2147483647 (both inclusive).

Flink使用滑动窗口时报这个错,这个函数的参数有什么限制吗?必须有时间属性?

Flink使用滑动窗口时报这个错,这个函数的参数有什么限制吗?必须有时间属性?

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

1 课时 |
404 人已学 |
免费

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

1 课时 |
204 人已学 |
免费

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

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

Flink CDC 里source支持debezium.table.exclude.list属性吗?

Flink CDC 里source支持debezium.table.exclude.list属性吗?

Flink CDC 里整库同步的时候要排除表需要怎么配置?我设置debezium属性没有效果怎么办?

Flink CDC 里整库同步的时候要排除表需要怎么配置?我设置debezium属性没有效果怎么办?

Flink CDC 里source支持debezium.table.exclude.list属性吗?

Flink CDC 里source支持debezium.table.exclude.list属性吗?还遇到一个问题,mysql数据库字段类型是time, cdc到Doris的时候异常:Flink doesn't support converting type TIME(0) to Doris typ...

Flink CDC中DataChangeEvent怎么取里面属性的值?

Flink CDC中DataChangeEvent怎么取里面属性的值?这样getString会报BinaryStringData转StringData失败

Flink 中支持的事件时间属性数据类型必须为 TIMESTAMP

Flink 中支持的事件时间属性数据类型必须为 TIMESTAMP 或者 TIMESTAMP_LTZ 2.flinK sql代码里我也设置了时区tableEnv.getConfig().setLocalTimeZone(ZoneId.of("Asia/Shanghai")) 2.currTimest...

Flink的s connector 连接器 socket.timeout 属性配置不了?

Flink的s connector 连接器 socket.timeout 属性配置不了?

有知道怎么修改flink cdc 内嵌的kafka这个属性吗?

有知道怎么修改flink cdc 内嵌的kafka这个属性( kafka.producer.max.request.size )吗? kafka的这个属性默认大小是1M 但是单条数据大小超过了1M,发现数据同步过程中丢失了还没有报错?

flink-connector-jdbc是独立出来了吗? 都有自己的版本号属性了

flink-connector-jdbc是独立出来了吗? 都有自己的版本号属性了

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

产品推荐

社区圈子

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