问答 2025-01-08 来自:开发者社区

flink cdc实时同步oracle数据库到kafka报错

flink cdc实时同步oracle数据库到kafka,我自己新建的测试表可以正常同步存量和增量数据,用另一张千万级别数据的表直接启动报错Caused by: java.io.IOException: io.debezium.DebeziumException: The db history topic or its content is fully or partially missing.....

问答 2024-12-04 来自:开发者社区

flink1.20通过web提交wordcount.jar运行报错

flink版本:1.20.0 wordcount.jar是从flink的镜像中的example文件夹下拷贝出来的 在页面submit的时候报错 Server Response Message:org.apache.flink.runtime.rest.handler.RestHandlerException: Could not execute application. at org.ap...

问答 2024-11-29 来自:开发者社区

flink on yarn ,所有提交方式都报错

这是报错页面这是容器里额得报错信息,改了好多地方都不行,大家帮忙看看呢

问答 2024-11-25 来自:开发者社区

alink任务本地正常运行,发布到flink集群后报错

本地运行一个alink任务,大概流程监听kafka中的数据,并作为入参结合已经使用线性回归算法训练好的数据集做运行,可以正常运行得到结果。但是,将该任务通过flink web ui发布到集群后,运行就报错了。flink是1.13版本,alink是1.6.0版本,可能是什么问题导致的?

问答 2024-10-25 来自:开发者社区

flink1.20.0 部署后发布报错,是怎么回事,各种配置都配置了

下面是我的配置config.yaml,为什么这个taskmanager参数指定了IP,就无法发布成功了? configured separately for each TaskManager. host: 192.168.95.113 jobmanager: The host interface the JobManager will bind to. By default, this is...

问答 2024-09-20 来自:开发者社区

Flink1.19.1 S3(minio)保存检查点报错

2024-09-19 17:54:02,076 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Triggering checkpoint 1 (type=CheckpointType{name='Checkpoint', sharingFilesStrategy=FORWARD_BACKWARD})...

问答 2024-09-09 来自:开发者社区

flink CDC MySQL to Paimon发生报错

环境 flink: 1.18.1flink cdc : 3.1.0flink cdc lib: yaml file : source: type: mysql name: MySQL Source hostname: xxxxx port: 3306 username: xxxxx password: xxxxxxxx tables: db_name.tabl...

问答 2024-08-28 来自:开发者社区

flink1.17.0 读取 SLS 报错是对应的版本冲突么?

flink1.17.0 读取 SLS 报错是对应的版本冲突么?java.lang.NoClassDefFoundError: org/apache/flink/api/java/typeutils/ResultTypeQueryable,

问答 2024-08-27 来自:开发者社区

请教下,flink 实时采集mysql 数据报错,有遇到的吗?

请教下,flink 实时采集mysql 数据报错,有遇到的吗?

问答 2024-08-26 来自:开发者社区

flink里pyspark ,通过 spark-submit 这种方式提交作业,报错依赖缺失 咋办?

麻烦想问一下pyspark ,通过 spark-submit 这种方式提交作业,但报错依赖缺失 能否帮忙解决一下哈

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注