问题一：Flink CDC中oracle的cdc遇到这个错误，有没有哪位朋友碰到过？
Flink CDC中oracle的cdc遇到这个错误，有没有哪位朋友碰到过，Caused by: io.debezium.connector.oracle.logminer.parser.DmlParserException: Unknown supported SQL '/ No SQL_REDO for temporary tables /'
at io.debezium.connector.oracle.logminer.parser.LogMinerDmlParser.parse(LogMinerDmlParser.java:80)
at io.debezium.connector.oracle.logminer.processor.AbstractLogMinerEventProcessor.parseDmlStatement(AbstractLogMinerEventProcessor.java:1078)
... 16 more？
参考回答：
这个错误看起来是由于在Flink CDC中使用Oracle CDC时，遇到了不支持的SQL语句导致的。具体来说，错误信息中的"No SQL_REDO for temporary tables"表示Oracle LogMiner无法处理临时表的SQL_REDO记录。
为了解决这个问题，您可以尝试以下几种方法：
- 检查您的SQL语句，确保不要涉及到临时表。如果需要使用临时表，可以考虑在其他地方进行处理，或者使用其他方式来实现所需的功能。
- 检查您的Oracle配置，确保已经开启了归档日志和补充日志。这是因为Flink CDC基于Debezium的LogMiner实现，LogMiner需要使用Oracle的归档日志和补充日志来获取变更数据。
- 检查您的Flink程序，确保正确创建了Oracle CDC连接。
- 如果可能，尝试升级您的Oracle版本，因为某些不兼容的问题可能在较新的版本中得到解决。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/574222
问题二：Flink CDC采用flink on yarn跑cdc任务，是资源的问题吗？
Flink CDC采用flink on yarn跑cdc任务，container意外退出，是资源的问题吗？ 
参考回答：
Container意外退出可能有多种原因，包括但不限于资源问题、程序异常、系统故障等。以下是一些可能的解决方法：
- 检查资源使用情况：如果你的任务在YARN上运行，你可以查看YARN的Web UI，看是否有资源不足的情况。如果有资源不足的情况，你可能需要增加容器的大小，或者减少并行度。
- 检查日志：你可以查看任务的日志，看是否有异常信息。如果有异常信息，你可能需要修复程序的bug，或者调整配置。
- 重启任务：如果任务意外退出，你可以尝试重启任务。在大多数情况下，重启任务可以解决大部分问题。
- 优化程序：如果你的任务经常意外退出，你可能需要优化你的程序。这可能包括优化数据的读取和写入，优化计算的逻辑，以及优化内存的使用。
- 增加容错机制：你可以增加容错机制，比如重试策略，以便在任务失败时能够自动恢复。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/574221
问题三：Flink CDC2.4.2mysql和sqlserver在一起集群启动任务，一个错误引发了两个包？
Flink CDC2.4.2mysql和sqlserver在一起集群启动任务，报错，这个错误看起来像是包冲突了，一个错误引发了两个包？ 
参考回答：
根据代码内容，Flink CDC 2.4.2 mysql和sqlserver在一起集群启动任务时，一个错误引发了两个包的异常。具体来说，io.debezium.DebeziumException异常导致db history topic的内容完全或部分丢失，需要检查数据库历史主题配置并重新执行快照。而[link-sql-connector-mysql-cdc-2.4.2.jar:2.4.2]和[link-sql-connector-sqlserver-cdc-2.4.2.jar:2.4.2]是两个包的引用，可能与异常有关。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/574220
问题四：Flink CDC报这样的错。有处理过吗？
Flink CDC报这样的错。有处理过吗？ Caused by: java.lang.ClassNotFoundException: io.debezium.connector.common.RelationalBaseSourceConnector 
参考回答：
这个错误是由于找不到io.debezium.connector.common.RelationalBaseSourceConnector类导致的。要解决这个问题，你需要将Debezium Connector的依赖添加到你的项目中。
如果你使用的是Maven，可以在pom.xml文件中添加以下依赖：
<dependency> <groupId>io.debezium</groupId> <artifactId>debezium-connector-mysql</artifactId> <version>1.7.2.Final</version> </dependency>
如果你使用的是Gradle，可以在build.gradle文件中添加以下依赖：
implementation 'io.debezium:debezium-connector-mysql:1.7.2.Final'
注意：请根据你的实际情况选择合适的版本号。
关于本问题的更多回答可点击原文查看：
https://developer.aliyun.com/ask/574215
问题五：Flink CDC中MongoDBcdc同步出现这个错误？
Flink CDC中MongoDBcdc同步出现这个错误？2023-11-22 12:18:19,518 INFO com.mongodb.kafka.connect.source.MongoSourceTask [] - Resuming the change stream after the previous offset using resumeAfter: {_data=BsonBinary{type=0, data=[-126, 101, 88, 114, 76, 0, 0, 0, 31, 70, 100, 95, 105, 100, 0, 100, 95, -83, -26, 117, -127, 68, 101, 12, -43, 57, 80, -67, 0, 90, 16, 4, 31, 67, -38, -86, -13, -116, 65, 3, -112, 76, -33, -53, -19, 7, 57, 78, 4]}}
2023-11-22 12:18:19,572 INFO com.mongodb.kafka.connect.source.MongoSourceTask [] - An exception occurred when trying to get the next item from the Change Stream
com.mongodb.MongoQueryException: Query failed with error code 40576 and error message 'resume of change notification was not possible, as the resume point may no longer be in the oplog. '搜了下可能是oplog的日志大小问题，但是我看了服务器配置是这么大，102400MB还能打爆不成
参考回答：
从错误信息来看，这个问题是由于MongoDB的Change Streams无法从上次的位置恢复导致的。这可能是由于OPLOG（操作日志）的日志大小问题引起的。
MongoDB的Change Streams依赖于OPLOG来跟踪数据库的变化。如果OPLOG的大小超过了MongoDB配置的阈值，那么Change Streams就无法从上次的位置恢复，而是从头开始读取OPLOG。
解决这个问题的方法之一是增加OPLOG的大小。你可以通过修改MongoDB的配置文件来实现这一点。在MongoDB的配置文件中，你可以找到oplogSizeGB这一项，将其值增加即可。
另一种方法是减少OPLOG的增长速度。你可以通过修改MongoDB的配置文件来实现这一点。在MongoDB的配置文件中，你可以找到writeConcern这一项，将其值改为majority或quorum即可。
请注意，改变OPLOG的大小或增长速度可能需要重启MongoDB服务才能生效。
关于本问题的更多回答可点击原文查看：
