Flink CDC导入最新的2.4.0 报出如上错误!我不想打jar包 想在flink sql实?

Flink CDC导入最新的2.4.0 报出如上错误在sql 中可以看到 设置tableau 之前的2.3.0 schema-name支持啊 ? 我不想打jar包 想在flink sql实现 ,把schema-name取消 出现这个错误

请问如果flink用kafka连接器接收到数据源的结构数据,如何在导入hudi表的时候告诉hudi?

请问如果flink用kafka连接器接收到数据源的结构数据,如何在导入hudi表的时候告诉hudi某一条数据是需要删除的呢?

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

1 课时 |
404 人已学 |
免费

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

1 课时 |
204 人已学 |
免费

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

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

咨询个Flink CDC问题,如果oracle数据单表数据变更要关联多表查询,是把多表数据都导入在?

咨询个Flink CDC问题,如果oracle数据单表数据变更要关联多表查询,是把多表数据都导入在flink中计算,还是用单表增量数据通过数据库进行关联查询呢?

各位老哥 Flink CDC中你们同步入湖的时候 遇到delete 的数据怎么搞的呢?我这边是导入

各位老哥 Flink CDC中你们同步入湖的时候 遇到delete 的数据怎么搞的呢?我这边是导入kafka 在sink下游,所以需要delete数据是不是只能先insert ,后 delete啊

Flink CDC中hudi到doris一般怎么导入。datax是自己开发的吗?datax.hudi

Flink CDC中hudi到doris一般怎么导入。datax是自己开发的吗?datax.hudi插件

Flink 这个语句执行完就报这个错,把where条件移除了就能够正常导入,麻烦能帮我看看是哪里语法

Flink 这个语句执行完就报这个错,把where条件移除了就能够正常导入,麻烦能帮我看看是哪里语法的问题?

请帮忙看一下flink cdc导入hudi有什么问题吗?

之前我flink cdc导入hudi表1W条数据不成功,原来是分区字段我用了id结果分区过多,一直写入超时,后来改好了用了几百分区的字段就没问题了,后来我尝试了导入百万数据的表也成功了,现在我尝试导入一亿多条数据的表,等了20多分钟,也不报错,也没内容写入hudi,正常吗?

flinkcdc 同步mysql数据到hbase,flink任务启动,导入全量数据有反压,怎么办?

flinkcdc 同步mysql数据到hbase,flink任务启动,导入全量数据有反压,反压结束以后,新的数据不会写入hbase,看日志无明显错误,怎么办?

flink jdbc 导入doris时,大家有遇到数据版本堆积过多吗?

flink jdbc 导入doris时,大家有遇到数据版本堆积过多吗?大家怎么处理的close wait failed coz rpc error. tablet writer write failed, tablet_id=19142, txn_id=2224, err=-235,

问一下各位大佬,flink sql写入ES报错,但是相关的jar已经导入,怎么办?

问一下各位大佬,flink sql写入ES报错,但是相关的jar已经导入,怎么办?

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

产品推荐

社区圈子

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