问答 2023-05-01 来自:开发者社区

请问下,Flink CDC中我用checkpoint恢复任务,为什么会报这异常呀?

请问下,Flink CDC中我用checkpoint恢复任务,为什么会报这异常呀?

阿里云文档 2023-05-01

Dataphin如何解决使用Flink脚本任务运行报SQL语法错误

问题描述Dataphin使用Flink脚本任务运行报SQL语法错误。解决方案Dataphin Flink SQL中不支持DDL建表语法,CREATE建表需要使用创建元表的方式代替。适用于Dataphin

问答 2023-04-28 来自:开发者社区

Flink这个任务从ck启动报错端口无法连接,不从ck启动的话就正常,请问下是原因呢?

Flink这个任务从ck启动报错端口无法连接,不从ck启动的话就正常,请问下是原因呢? tm应该是挂了,好像没开历史服务器0.0 正确的怎么写?

问答 2023-04-28 来自:开发者社区

比如有一台服务器8核32G,如果部署flink 任务,假如一个任务并行度给2,只能跑4个任务?

比如有一台服务器8核32G,如果部署flink on yarn任务的话,假如一个任务并行度给2,是不是只能跑4个任务?

问答 2023-04-26 来自:开发者社区

flink任务里面能用本地缓存吗(比如把数据存在HashMap里)?我把分库分表的表关系(如user

flink任务里面能用本地缓存吗(比如把数据存在HashMap里)?我把分库分表的表关系(如user0~user1000写到user表)缓存在HashMap里,把任务提交到集群环境后,HashMap打印出来发现是空的;在本地运行时是有值的

问答 2023-04-26 来自:开发者社区

flink任务中我这个检查点报错超时方便帮忙看一下嘛?我这个时间设计的是不是不合适?

flink任务中我这个检查点报错超时方便帮忙看一下嘛?我这个时间设计的是不是不合适?

问答 2023-04-26 来自:开发者社区

flink 任务insert into TWORKSHEET_hudi select * from

flink 任务insert into TWORKSHEET_hudi select * from TWORKSHEET where TCTIME BETWEEN '2017-06-1 23:59:59' AND '2019-09-25 23:59:59'; index_bootstrap阶段报错org.apache.hudi.exception.HoodieIOException: Cou...

问答 2023-04-26 来自:开发者社区

flink运行出现错误,除了webui上看,还有什么地方能看?就是有的任务,他运行然后挂掉了,然后y

flink运行出现错误,除了webui上看,还有什么地方能看?就是有的任务,他运行然后挂掉了,然后yarn上,只剩history了,点history里面的log啥也没有,你遇到过这种情况吗?

问答 2023-04-26 来自:开发者社区

用flink-cdc同步mysql的数据,有没有办法监控任务的同步情况,比如同步到哪个binlog

用flink-cdc同步mysql的数据,有没有办法监控任务的同步情况,比如同步到哪个binlog 哪个位置了

问答 2023-04-26 来自:开发者社区

请教个问题,flink cdc同步mysql数据到iceberg。任务运行一段时间后,表的结构改了(

请教个问题,flink cdc同步mysql数据到iceberg。任务运行一段时间后,表的结构改了(比如新增了2个字段),如果人工手动把ddl也同步到iceberg了,这时候任务要怎么处理才能同步数据?

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注