实时计算 Flink版操作报错之抽取Oracle11g时,报错: "Retrieve schema history failed, the schema records for engine ... has been removed",怎么处理

本文涉及的产品
实时计算 Flink 版,5000CU*H 3个月
简介: 在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。

问题一:测试flinkcdc3.0 同步mysql到doris,就是docs里的例子,怎么都不成功?


测试flinkcdc3.0 同步mysql到doris,就是docs里的例子,17kb的源库,怎么都不成功?flink版本1.17.2source: type: mysql hostname: localhost port: 3306 username: root password: 123456 tables: app_db..* server-id: 5400 server-time-zone: UTCsink: type: doris fenodes: 127.0.0.1:8030 username: root password: "" table.create.properties.light_schema_change: true table.create.properties.replication_num: 1pipeline: name: Sync MySQL Database to Doris parallelism: 1``2023-12-13 22:47:11java.lang.IllegalStateException: Failed to send request to coordinator: com.ververica.cdc.runtime.operators.schema.event.SchemaChangeRequest@9b5c3d87Caused by: java.util.concurrent.ExecutionException: java.util.concurrent.TimeoutException: Invocation of [RemoteRpcInvocation(JobMasterOperatorEventGateway.sendRequestToCoordinator(OperatorID, SerializedValue))] at recipient [akka.tcp://flink@localhost:6123/user/rpc/jobmanager_3] timed out. This is usually caused by: 1) Akka failed sending the message silently, due to problems like oversized payload or serialization failures. In that case, you should find detailed error information in the logs. 2) The recipient needs more time for responding, due to problems like slow machines or network jitters. In that case, you can try to increase akka.ask.timeout. at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395) at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999) at com.ververica.cdc.runtime.operators.schema.SchemaOperator.sendRequestToCoordinator(SchemaOperator.java:123) ... 26 moreCaused by: java.util.concurrent.TimeoutException: Invocation of [RemoteRpcInvocation(JobMasterOperatorEventGateway.sendRequestToCoordinator(OperatorID, SerializedValue))] at recipient [akka.tcp://flink@localhost:6123/user/rpc/jobmanager_3] timed out. This is usually caused by: 1) Akka failed sending the message silently, due to problems like oversized payload or serialization failures. In that case, you should find detailed error information in the logs. 2) The recipient needs more time for responding, due to problems like slow machines or network jitters. In that case, you can try to increase akka.ask.timeout. at com.sun.proxy.$Proxy25.sendRequestToCoordinator(Unknown Source) at org.apache.flink.runtime.taskexecutor.rpc.RpcTaskOperatorEventGateway.sendRequestToCoordinator(RpcTaskOperatorEventGateway.java:73) at com.ververica.cdc.runtime.operators.schema.SchemaOperator.sendRequestToCoordinator(SchemaOperator.java:121) ... 26 moreCaused by: akka.pattern.AskTimeoutException: Ask timed out on [Actor[akka.tcp://flink@localhost:6123/user/rpc/jobmanager_3#1975425594]] after [10000 ms]. Message of type [org.apache.flink.runtime.rpc.messages.RemoteFencedMessage]. A typical reason forAskTimeoutException` is that the recipient actor didn't send a reply.


参考回答:

从你提供的错误信息来看,问题可能是由于Flink CDC在向JobManager发送请求时超时导致的。以下是一些可能的解决方法:

  1. 网络问题:检查本地网络连接是否正常,确保Flink和MySQL之间的通信没有被阻塞。
  2. Akka ask timeout:根据错误信息,你可以尝试增加Akka的ask timeout值。在Flink的flink-conf.yaml配置文件中添加或修改以下配置:
akka.ask.timeout: 30 s
  1. 这将把默认的10秒超时时间增加到30秒。你可以根据实际情况调整这个值。
  2. Flink版本兼容性:确认你使用的Flink版本(1.17.2)与Flink CDC 3.0是否兼容。如果存在兼容性问题,尝试使用与Flink CDC 3.0兼容的Flink版本。
  3. 检查Flink和MySQL的配置:确保你在Flink CDC配置中提供的MySQL主机名、端口、用户名和密码是正确的,并且MySQL服务器允许来自Flink CDC的连接。
  4. 查看Flink和MySQL的日志:查看Flink和MySQL的日志,查找可能的错误或警告信息,这些信息可能会帮助你找到问题的原因。
  5. 确认Doris配置:确保你在Flink CDC配置中提供的Doris Fenodes地址、用户名和密码是正确的,并且Doris服务器允许来自Flink CDC的连接。
  6. 更新或重新安装Flink CDC:如果你已经确认了所有的配置都是正确的,但问题仍然存在,你可能需要更新或重新安装Flink CDC,以确保你正在使用的是最新版本并且没有安装错误。


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/580693



问题二:Flink CDC中mysqlbinlog保存期限是0,为啥还会报这个找不到binlog的错误呢?


Flink CDC中mysqlbinlog保存期限是0,为啥还会报这个找不到binlog的错误呢?Caused by: java.lang.IllegalStateException: The connector is trying to read binlog starting at Struct{version=1.9.7.Final,connector=mysql,name=mysql_binlog_source,ts_ms=1702519739599,db=,server_id=0,file=mysql-bin.000001,pos=54782888,row=0}, but this is no longer available on the server. Reconfigure the connector to use a snapshot when needed. polardb mysql我是从savepoint恢复任务,本地mysql测试正常


参考回答:

云端数据库并不是永久存储binlog的,你是看官网介绍binlog时间吧,永远存储binlog,要命了,我建议你去看文档,他只是显示给你0,实际是达到25%的存储或者几天就刷到云端了


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/580691



问题三:Flink CDC这个异常可能是什么原因导致的吗?


Flink CDC这个异常可能是什么原因导致的吗?

Caused by: java.lang.IllegalStateException: Retrieve schema history failed, the schema records for engine 4e267c1c-99d6-4113-b64e-92367c231e09 has been removed, this might because the debezium engine has been shutdown due to other errors.

场景:flink1.16.0 + flink cdc 2.3.0 抽取Oracle11g的时候,产生的异常?


参考回答:

这个异常 "Retrieve schema history failed, the schema records for engine ... has been removed, this might because the debezium engine has been shutdown due to other errors" 可能是由以下原因导致的:

  • Debezium 引擎意外关闭或者重启,导致 schema 历史记录丢失。
  • Flink CDC 连接器在处理 Oracle CDC 数据时遇到了未知错误或者异常,导致Debezium 引擎被关闭。
  • 系统资源不足或者网络问题,导致 Flink CDC 或者 Debezium 引擎无法正常运行。

为了解决这个问题,你可以尝试以下方法:

  • 检查 Flink CDC 和 Debezium 的日志和错误信息,查找可能的错误根源和解决方案。
  • 确保你的系统资源(如 CPU、内存和磁盘空间)充足,并且网络连接稳定。
  • 考虑更新到最新的 Flink CDC 和 Debezium 版本,以获取最新的 bug 修复和性能优化。


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/580688



问题四:为什么Flink CDC默认分配的server-id会重复?


在使用Flink CDC读取MySQL数据时,如果没有手动指定server-id,会报告有相同的server-id错误。一般来说,手动指定server-id可以规避这种情况。但是,手动指定server-id时如何确保与MySQL主从同步使用的不重复?又如何知道哪些server-id尚未使用?另外,为什么Flink CDC默认分配的server-id会重复?


参考回答:

手动指定吧, flink cdc 默认分配的是5400-6400区间,不指定会重复的,而且string 的范围都可以


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/580678



问题五:flinkcdc mongodb 报错?


flinkcdc mongodb 报错? 0 [flink-akka.actor.default-dispatcher-7] ERROR org.apache.flink.runtime.source.coordinator.SourceCoordinator - Failed to create Source Enumerator for source Source: MongoDBIncrementalSource

java.lang.NoSuchMethodError: org.apache.avro.Schema$Field.defaultVal()Ljava/lang/Object;


参考回答:

java.lang.NoSuchMethodError 基本是依赖冲突,并且是版本不一致的的那种


关于本问题的更多回答可点击原文查看:

https://developer.aliyun.com/ask/580669

相关实践学习
基于Hologres轻松玩转一站式实时仓库
本场景介绍如何利用阿里云MaxCompute、实时计算Flink和交互式分析服务Hologres开发离线、实时数据融合分析的数据大屏应用。
Linux入门到精通
本套课程是从入门开始的Linux学习课程,适合初学者阅读。由浅入深案例丰富,通俗易懂。主要涉及基础的系统操作以及工作中常用的各种服务软件的应用、部署和优化。即使是零基础的学员,只要能够坚持把所有章节都学完,也一定会受益匪浅。
相关文章
|
4天前
|
消息中间件 Java 关系型数据库
实时计算 Flink版操作报错合集之从 PostgreSQL 读取数据并写入 Kafka 时,遇到 "initial slot snapshot too large" 的错误,该怎么办
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
551 0
|
4天前
|
存储 SQL 关系型数据库
实时计算 Flink版操作报错合集之按时间恢复时,报错:在尝试读取binlog时发现所需的binlog位置不再可用,该怎么办
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
487 0
|
4天前
|
消息中间件 资源调度 Java
实时计算 Flink版操作报错合集之遇到了缺少包的错误,已经添加了相应的 jar 包,仍然出现同样的报错,该怎么解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
527 2
|
4天前
|
SQL JSON 数据库
实时计算 Flink版操作报错合集之写入Hudi时,遇到从 COW(Copy-On-Write)表类型转换为 MOR(Merge-On-Read)表类型时报字段错误,该怎么办
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
4天前
|
监控 Oracle 关系型数据库
实时计算 Flink版操作报错合集之在配置连接时,添加了scan.startup.mode参数后,出现报错。是什么导致的
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
600 0
|
4天前
|
消息中间件 Oracle 关系型数据库
实时计算 Flink版操作报错合集之连接RabbitMQ时遇到Could not find any factory for identifier 'rabbitmq' that implements 'org.apache.flink.table.factories.DynamicTableFactory'错误,该怎么办
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
255 0
|
4天前
|
SQL 关系型数据库 MySQL
实时计算 Flink版操作报错合集之CDC任务在异常后整个record sent从0初始化开始,是什么导致的
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
362 0
|
4天前
|
Java 关系型数据库 流计算
实时计算 Flink版操作报错合集之配置cats进行从MySQL到StarRocks的数据同步任务时遇到报错,该怎么办
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
289 0
|
4天前
|
关系型数据库 数据库 流计算
实时计算 Flink版操作报错合集之在使用Flink CDC TiDB Connector时,无法获取到事件,该怎么办
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
308 0
|
4天前
|
消息中间件 关系型数据库 MySQL
实时计算 Flink版操作报错合集之遇到依赖问题该怎么解决
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
326 0

热门文章

最新文章

相关产品

  • 实时计算 Flink版
  • 推荐镜像

    更多