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

ORACLE FLINK运行一段时间后报错

ORACLE FLINK运行一段时间后报错

问答 2025-07-25 来自:开发者社区

flink1.17.2对应的 flinkCDC 是哪个版本,我使用的3.4.0 一直报错序列化异常。

这个是报错内容。[ERROR] Could not execute SQL statement. Reason:java.io.StreamCorruptedException: unexpected block data这是所用的 jar 包

问答 2025-06-12 来自:开发者社区

用hive beeline 访问 flink hiveserver2 endpoint 报错

1. 安装 flink-1.19.2hive-3.1.3hadoop-3.3.6 hive的lib 放入 flink-sql-jdbc-driver-bundle-1.18.0.jar fink的lib 放入antlr-runtime-3.5.2.jarflink-connector-hive_2.12-1.19.2.jarflink-connector-jdbc-3.2.0-1.19.jarh....

问答 2025-02-17 来自:开发者社区

flink cdc 3.1读取数据报错

flink 版本:1.16.2flink cdc 版本 3.0.1数据库:sqlserver 2019 使用table api 通过cdc 捕获数据时直接提示以下报错,这个报错是因为 我少了什么配置吗 2025-02-17 18:17:48,787 ERROR SplitFetcherManager:129 - Received uncaught exception.java.lang.Runt....

问答 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})...

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

产品推荐

阿里云实时计算Flink

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

+关注