问题一:Flink CDC看看是哪里配置错了吗?
Flink CDC看看是哪里配置错了吗?我看oracle-cdc里是有driver的,issues好像也有同样的问题
参考回答:
根据你提供的错误信息,看起来你的Flink CDC连接到Oracle数据库时遇到了问题。具体来说,错误信息是"No suitable driver found for jdbc:oracle:thin:@10.201.225.1521/orcl"。
驱动程序问题:如果Oracle JDBC驱动程序没有正确安装或配置,可能会导致这个错误。你可以检查你的Oracle JDBC驱动程序,确保它们正确无误。
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/575900
问题二:flinkcdc读取postgresql报错 ?
flinkcdc读取postgresql报错 ?
参考回答:
根据你提供的错误信息,看起来你的Flink CDC连接到PostgreSQL数据库时遇到了问题。具体来说,错误信息是"java.sql.SQLException: No suitable driver found for jdbc:postgresql"。
这个错误可能是由于以下原因导致的:
驱动程序问题:如果PostgreSQL JDBC驱动程序没有正确安装或配置,可能会导致这个错误。你可以检查你的PostgreSQL JDBC驱动程序,确保它们正确无误。
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/575894
问题三:Flink CDC 中的参数scan.如下图红框但是启动时报错说不支持这个参数。为什么呀?
Flink CDC 中的参数scan.incremental.close-idle-reader.enabled。如下图红框但是启动时报错说不支持这个参数。为什么呀?如下图蓝框使用的flink和pyflink版本都是1.17.1
另外启动这个参数(scan.incremental.close-idle-reader.enabled ) ,是否会在快照执行完成后减少对资源的消耗?
参考回答:
关于你的第一个问题,Flink CDC中的scan.incremental.close-idle-reader.enabled参数是用于控制是否在快照结束后关闭空闲的Reader。这个特性需要Flink版本大于等于1.14。根据你提供的信息,你正在使用的Flink和pyflink版本都是1.17.1,所以理论上是支持这个参数的。如果你在启动时遇到报错说不支持这个参数,可能是其他配置问题或者使用方式有误,建议你详细检查参数配置和使用方法。
至于你的第二个问题,关于scan.incremental.close-idle-reader.enabled参数是否会在快照执行完成后减少对资源的消耗。实际上,这个参数是用来控制是否在空闲状态下关闭binlog读取器(reader)的。如果在快照结束后,有些Reader处于空闲状态,那么启用这个参数可以关闭这些闲置的Reader,从而释放资源。这在一定程度上可以帮助减少对资源的消耗。但是具体可以减少多少资源消耗,还需要根据你的实际业务情况和系统环境来确定。
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/575891
问题四:用Flink CDC 2.3.0 Oracle,找不到驱动,请问各位大神有没有解决方案?
用Flink CDC 2.3.0 Oracle,找不到驱动,请问各位大神有没有解决方案?
参考回答:
如果你在使用Flink CDC 2.3.0读取Oracle数据库时遇到找不到驱动的问题,首先你需要确保你已经添加了相应的依赖。对于Oracle数据库,你需要在项目的pom.xml文件中添加如下依赖:
<org.apache.flink" %% "flink-connector-oracle-cdc" % "2.3.0"
其次,请检查你的Flink版本是否与flink-connector-oracle-cdc版本兼容。在这个例子中,flink-connector-oracle-cdc版本是2.3.0,所以你可能需要使用与该版本兼容的Flink版本。如果依然存在问题,那么可能需要考虑升级或降级Flink或者flink-connector-oracle-cdc的版本,以求达到最佳兼容性。
关于本问题的更多回答可点击原文查看:
https://developer.aliyun.com/ask/575850
问题五:Flink CDC1.17.1有啥办法解决不?
Flink CDC1.17.1有啥办法解决不?2023-11-30 11:20:48
java.lang.UnsupportedOperationException: Currently it is not supported to update the CommittableSummary for a checkpoint coming from the same subtask. Please check the status of FLINK-25920
at org.apache.flink.streaming.runtime.operators.sink.committables.CheckpointCommittableManagerImpl.upsertSummary(CheckpointCommittableManagerImpl.java:83)
at org.apache.flink.streaming.runtime.operators.sink.committables.CommittableCollector.addSummary(CommittableCollector.java:230)
at org.apache.flink.streaming.runtime.operators.sink.committables.CommittableCollector.addMessage(CommittableCollector.java:124)
at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.processElement(CommitterOperator.java:193)
at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:75)
at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:50)
at org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:29)
at org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.emit(SinkWriterOperator.java:224)
at org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.emitCommittables(SinkWriterOperator.java:211)
at org.apache.flink.streaming.runtime.operators.sink.SinkWriterOperator.endInput(SinkWriterOperator.java:183)
at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.endOperatorInput(StreamOperatorWrapper.java:96)
参考回答:
这个问题是由于Flink CDC 1.17.1版本中不支持更新来自同一子任务的检查点CommittableSummary。你可以尝试升级到更高版本的Flink CDC,或者检查你的代码是否有问题。
关于本问题的更多回答可点击原文查看: