为提高效率,提问时请提供以下信息,问题描述清晰可优先响应。
【DM版本】:0x7000d,03134284368-20250430-272000-20149
【操作系统】:win11
【CPU】:
【问题描述】*:testflinkcdc启动报错信息如下:
16:54:32.032[INFO ]The enumerator receives notice from subtask 0 for the stream split assignment.
16:54:32.037[INFO ]Database Version: DB Version: 0x7000d
16:54:32.046[INFO ]dm connector version:3.3.0-2025060315
16:54:32.054[INFO ]Database Version: DB Version: 0x7000d
16:54:32.058[INFO ]dm connector version:3.3.0-2025060315
16:54:32.084[ERROR]Mining session stopped due to the java.lang.NullPointerException
16:54:32.084[ERROR]Mining session stopped due to the java.lang.NullPointerException
16:54:32.085[ERROR]Producer failure
java.lang.NullPointerException: null
at io.debezium.connector.dm.logminer.LogMinerStreamingChangeEventSource.createTableDict(LogMinerStreamingChangeEventSource.java:801) ~[flink-connector-dm-cdc-3.3.0.jar:?]
at io.debezium.connector.dm.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:217) ~[flink-connector-dm-cdc-3.3.0.jar:?]
at org.apache.flink.cdc.connectors.dm.source.reader.fetch.DMStreamFetchTask$RedoLogSplitReadTask.execute(DMStreamFetchTask.java:147) ~[flink-connector-dm-cdc-3.3.0.jar:?]
at org.apache.flink.cdc.connectors.dm.source.reader.fetch.DMStreamFetchTask.execute(DMStreamFetchTask.java:73) ~[flink-connector-dm-cdc-3.3.0.jar:?]
at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceStreamFetcher.lambda$submitTask$0(IncrementalSourceStreamFetcher.java:89) ~[flink-cdc-base-3.3.0.jar:3.3.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264) [?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java) [?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
at java.lang.Thread.run(Thread.java:834) [?:?]
16:54:32.085[ERROR]Producer failure
java.lang.NullPointerException: null
at io.debezium.connector.dm.logminer.LogMinerStreamingChangeEventSource.createTableDict(LogMinerStreamingChangeEventSource.java:801) ~[flink-connector-dm-cdc-3.3.0.jar:?]
at io.debezium.connector.dm.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:217) ~[flink-connector-dm-cdc-3.3.0.jar:?]
at org.apache.flink.cdc.connectors.dm.source.reader.fetch.DMStreamFetchTask$RedoLogSplitReadTask.execute(DMStreamFetchTask.java:147) ~[flink-connector-dm-cdc-3.3.0.jar:?]
at org.apache.flink.cdc.connectors.dm.source.reader.fetch.DMStreamFetchTask.execute(DMStreamFetchTask.java:73) ~[flink-connector-dm-cdc-3.3.0.jar:?]
at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceStreamFetcher.lambda$submitTask$0(IncrementalSourceStreamFetcher.java:89) ~[flink-cdc-base-3.3.0.jar:3.3.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264) [?:?]
at java.util.concurrent.FutureTask.run(FutureTask.java) [?:?]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
at java.lang.Thread.run(Thread.java:834) [?:?]
16:54:32.092[INFO ]startScn=58694, endScn=null
16:54:32.092[INFO ]startScn=58694, endScn=null
16:54:32.092[INFO ]Streaming metrics dump: DMStreamingChangeEventSourceMetrics{currentScn=null, oldestScn=null, committedScn=null, offsetScn=null, logMinerQueryCount=0, totalProcessedRows=0, totalCapturedDmlCount=0, totalDurationOfFetchingQuery=PT0S, lastCapturedDmlCount=0, lastDurationOfFetchingQuery=PT0S, maxCapturedDmlCount=0, maxDurationOfFetchingQuery=PT0S, totalBatchProcessingDuration=PT0S, lastBatchProcessingDuration=PT0S, maxBatchProcessingThroughput=0, currentLogFileName=[], minLogFilesMined=0, maxLogFilesMined=0, switchCounter=0, batchSize=2000000, millisecondToSleepBetweenMiningQuery=1000, hoursToKeepTransaction=0, networkConnectionProblemsCounter0, batchSizeDefault=2000000, batchSizeMin=100000, batchSizeMax=10000000, sleepTimeDefault=1000, sleepTimeMin=0, sleepTimeMax=3000, sleepTimeIncrement=200, totalParseTime=PT0S, totalStartLogMiningSessionDuration=PT0S, lastStartLogMiningSessionDuration=PT0S, maxStartLogMiningSessionDuration=PT0S, totalProcessTime=PT0S, minBatchProcessTime=PT0S, maxBatchProcessTime=PT0S, totalResultSetNextTime=PT0S, lagFromTheSource=DurationPT0S, maxLagFromTheSourceDuration=PT0S, minLagFromTheSourceDuration=PT0S, lastCommitDuration=PT0S, maxCommitDuration=PT0S, activeTransactions=0, rolledBackTransactions=0, committedTransactions=0, abandonedTransactionIds={}, rolledbackTransactionIds={}, registeredDmlCount=0, committedDmlCount=0, errorCount=1, warningCount=0, scnFreezeCount=0, unparsableDdlCount=0, miningSessionUserGlobalAreaMemory=0, miningSessionUserGlobalAreaMaxMemory=0, miningSessionProcessGlobalAreaMemory=0, miningSessionProcessGlobalAreaMaxMemory=0}
16:54:32.092[INFO ]Streaming metrics dump: DMStreamingChangeEventSourceMetrics{currentScn=null, oldestScn=null, committedScn=null, offsetScn=null, logMinerQueryCount=0, totalProcessedRows=0, totalCapturedDmlCount=0, totalDurationOfFetchingQuery=PT0S, lastCapturedDmlCount=0, lastDurationOfFetchingQuery=PT0S, maxCapturedDmlCount=0, maxDurationOfFetchingQuery=PT0S, totalBatchProcessingDuration=PT0S, lastBatchProcessingDuration=PT0S, maxBatchProcessingThroughput=0, currentLogFileName=[], minLogFilesMined=0, maxLogFilesMined=0, switchCounter=0, batchSize=2000000, millisecondToSleepBetweenMiningQuery=1000, hoursToKeepTransaction=0, networkConnectionProblemsCounter0, batchSizeDefault=2000000, batchSizeMin=100000, batchSizeMax=10000000, sleepTimeDefault=1000, sleepTimeMin=0, sleepTimeMax=3000, sleepTimeIncrement=200, totalParseTime=PT0S, totalStartLogMiningSessionDuration=PT0S, lastStartLogMiningSessionDuration=PT0S, maxStartLogMiningSessionDuration=PT0S, totalProcessTime=PT0S, minBatchProcessTime=PT0S, maxBatchProcessTime=PT0S, totalResultSetNextTime=PT0S, lagFromTheSource=DurationPT0S, maxLagFromTheSourceDuration=PT0S, minLagFromTheSourceDuration=PT0S, lastCommitDuration=PT0S, maxCommitDuration=PT0S, activeTransactions=0, rolledBackTransactions=0, committedTransactions=0, abandonedTransactionIds={}, rolledbackTransactionIds={}, registeredDmlCount=0, committedDmlCount=0, errorCount=1, warningCount=0, scnFreezeCount=0, unparsableDdlCount=0, miningSessionUserGlobalAreaMemory=0, miningSessionUserGlobalAreaMaxMemory=0, miningSessionProcessGlobalAreaMemory=0, miningSessionProcessGlobalAreaMaxMemory=0}
16:54:32.092[INFO ]Offsets: DmOffsetContext [scn=58694, commit_scn=CommitScn [redoThreadCommitScns={1=RedoThreadCommitScn{thread=1, commitScn=0, txIds=[]}}]]
16:54:32.092[INFO ]Offsets: DmOffsetContext [scn=58694, commit_scn=CommitScn [redoThreadCommitScns={1=RedoThreadCommitScn{thread=1, commitScn=0, txIds=[]}}]]
16:54:32.094[INFO ]Connection gracefully closed
16:54:32.094[INFO ]Connection gracefully closed