DBMS_LOGMNR.add_logfile 无法添加重复的日志文件 这是什么原因

[taoyameng]

[debezium-damengconnector-dameng-server-change-event-source-coordinator] ERROR org.devlive.connector.dameng.logminer.LogMinerHelper - Failed to execute statement: [DBMS_LOGMNR.add_logfile] 无法添加重复的日志文件
[debezium-damengconnector-dameng-server-change-event-source-coordinator] ERROR org.devlive.connector.dameng.logminer.LogMinerHelper - Mining session stopped due to the {}
dm.jdbc.driver.DMException: [DBMS_LOGMNR.add_logfile] 无法添加重复的日志文件
at dm.jdbc.driver.DBError.throwException(DBError.java:635)
at dm.jdbc.c.a.n.J(MSG.java:221)
at dm.jdbc.c.a.n.G(MSG.java:181)
at dm.jdbc.c.a.n.F(MSG.java:162)
at dm.jdbc.c.a.a(DBAccess.java:759)
at dm.jdbc.c.a.a(DBAccess.java:311)
at dm.jdbc.c.a.a(DBAccess.java:401)
at dm.jdbc.driver.DmdbPreparedStatement.executeInner(DmdbPreparedStatement.java:221)
at dm.jdbc.driver.DmdbPreparedStatement.do_execute(DmdbPreparedStatement.java:310)
at dm.jdbc.driver.DmdbPreparedStatement.execute(DmdbPreparedStatement.java:1630)
at org.devlive.connector.dameng.logminer.LogMinerHelper.executeCallableStatement(LogMinerHelper.java:770)
at org.devlive.connector.dameng.logminer.LogMinerHelper.setRedoLogFilesForMining(LogMinerHelper.java:528)
at org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource.initializeRedoLogsForMining(LogMinerStreamingChangeEventSource.java:261)
at org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:139)
at org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:62)
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174)
at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141)
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:842)
[debezium-damengconnector-dameng-server-change-event-source-coordinator] ERROR io.debezium.pipeline.ErrorHandler - Producer failure

[qianmoQ]

SELECT * FROM V$LOGMNR_SESSION;

查看一下当前活动的 LogMiner 会话

[taoyameng]

执行了sql之后出现
[执行语句1]:
SELECT * FROM V$LOGMNR_SESSION;
执行失败(语句1)
第1 行附近出现错误[-2106]:
无效的表或视图名[V$LOGMNR_SESSION]

我的达梦版本是 DM Database Server x64 V8 DB Version: 0x7000b

[qianmoQ]

执行了sql之后出现 [执行语句1]: SELECT * FROM V$LOGMNR_SESSION; 执行失败(语句1) 第1 行附近出现错误[-2106]: 无效的表或视图名[V$LOGMNR_SESSION]

我的达梦版本是 DM Database Server x64 V8 DB Version: 0x7000b

出现这个错误可以给一些上下文日志用于分析，我需要知道之前发生了什么，之后发生了什么

[taoyameng]

我不太清楚需要提供哪些上下文日志，是Java程序运行的日志吗

[qianmoQ]

我不太清楚需要提供哪些上下文日志，是Java程序运行的日志吗

是的，从开始运行，到出现这个错误！出现错误后是否停止了运行？还是有其他的发生？还需要确认的是是否按照 https://github.com/devlive-community/dameng-connector?tab=readme-ov-file#%E8%BE%BE%E6%A2%A6%E6%95%B0%E6%8D%AE%E5%BA%93-cdc-%E9%85%8D%E7%BD%AE%E6%8C%87%E5%8D%97 教程来进行开启的 CDC 功能呢

[taoyameng]

我重新装了达梦库，现在不报错了，但是程序启动后，idea的控制台上没有打印数据

[Legacy Source Thread - Source: dameng_source_table[1] -> ConstraintEnforcer[2] -> Sink: Collect table sink (1/1)#0] WARN org.apache.kafka.connect.runtime.WorkerConfig - The worker has been configured with one or more internal converter properties ([internal.key.converter, internal.value.converter]). Support for these properties was deprecated in version 2.0 and removed in version 3.0, and specifying them will have no effect. Instead, an instance of the JsonConverter with schemas.enable set to false will be used. For more information, please visit http://kafka.apache.org/documentation/#upgrade and consult the upgrade notesfor the 3.0 release.
[Legacy Source Thread - Source: dameng_source_table[1] -> ConstraintEnforcer[2] -> Sink: Collect table sink (1/1)#0] WARN org.apache.kafka.connect.runtime.WorkerConfig - Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results.
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask - Starting DamengConnectorTask with configuration:
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    connector.class = org.devlive.connector.dameng.DamengConnector
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    include.schema.changes = false
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    tombstones.on.delete = false
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    offset.storage.file.filename = 
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    value.converter = org.apache.kafka.connect.json.JsonConverter
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    database.history.instance.name = 45f8d02d-95ad-4c54-a55e-610c8a6de899
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    key.converter = org.apache.kafka.connect.json.JsonConverter
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    database.history.file.filename = history-ENDPOINT_MONITOR-ENDPOINT_MONITOR.DATA_GEN.txt
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    database.dbname = ENDPOINT_MONITOR
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    database.user = ENDPOINT_MONITOR
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    database.server.id = 5001
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    offset.storage = org.apache.flink.cdc.debezium.internal.FlinkOffsetBackingStore
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    database.connection.adapter = LogMiner
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    database.server.name = dameng-server
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    offset.flush.timeout.ms = 5000
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    database.port = 5236
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    offset.flush.interval.ms = 9223372036854775807
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    internal.key.converter = org.apache.kafka.connect.json.JsonConverter
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    database.serverTimezone = UTC
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    database.hostname = localhost
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    database.password = ********
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    name = engine
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    internal.value.converter = org.apache.kafka.connect.json.JsonConverter
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    table.include.list = ENDPOINT_MONITOR\.ENDPOINT_MONITOR.DATA_GEN
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask -    database.history = org.apache.flink.cdc.debezium.internal.FlinkDatabaseSchemaHistory
[debezium-engine] INFO org.devlive.connector.dameng.DamengConnection - Database Version: Oracle Database 18g Enterprise Edition Release 18.2.0.1.0 - 64bit Production
[debezium-engine] INFO io.debezium.connector.common.BaseSourceTask - No previous offsets found
[debezium-engine] INFO io.debezium.util.Threads - Requested thread factory for connector DamengConnector, id = dameng-server named = change-event-source-coordinator
[debezium-engine] INFO io.debezium.util.Threads - Creating thread debezium-damengconnector-dameng-server-change-event-source-coordinator
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.pipeline.ChangeEventSourceCoordinator - Metrics registered
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.pipeline.ChangeEventSourceCoordinator - Context created
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 1 - Preparing
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 2 - Determining captured tables
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Adding table ENDPOINT_MONITOR.SYSDBA.##HISTOGRAMS_TABLE to the list of capture schema tables
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Adding table ENDPOINT_MONITOR.SYSDBA.##PLAN_TABLE to the list of capture schema tables
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Adding table ENDPOINT_MONITOR.ENDPOINT_MONITOR.DATA_GEN to the list of capture schema tables
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Adding table ENDPOINT_MONITOR.ENDPOINT_MONITOR.USER to the list of capture schema tables
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Adding table ENDPOINT_MONITOR.ENDPOINT_MONITOR.ENDPOINT to the list of capture schema tables
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Adding table ENDPOINT_MONITOR.ENDPOINT_MONITOR.ENDPOINT_DIR to the list of capture schema tables
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Adding table ENDPOINT_MONITOR.ENDPOINT_MONITOR.RECORD to the list of capture schema tables
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Adding table ENDPOINT_MONITOR.CTISYS.SYSCONTEXTINDEXES to the list of capture schema tables
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 3 - Locking captured tables []
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 4 - Determining snapshot offset
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 5 - Reading structure of captured tables
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 6 - Persisting schema history
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshot step 7 - Snapshotting data
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.relational.RelationalSnapshotChangeEventSource - Snapshotting contents of 0 tables while still in transaction
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.pipeline.source.AbstractSnapshotChangeEventSource - Snapshot - Final stage
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.pipeline.ChangeEventSourceCoordinator - Snapshot ended with SnapshotResult [status=COMPLETED, offset=OracleOffsetContext [scn=63184]]
[debezium-damengconnector-dameng-server-change-event-source-coordinator] WARN io.debezium.relational.RelationalDatabaseSchema - After applying the include/exclude list filters, no changes will be captured. Please check your configuration!
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.pipeline.ChangeEventSourceCoordinator - Connected metrics set to 'true'
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.pipeline.ChangeEventSourceCoordinator - Starting streaming
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63184, endScn=63196, offsetContext.getScn=63184, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63196, endScn=63203, offsetContext.getScn=63196, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63203, endScn=63211, offsetContext.getScn=63203, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63211, endScn=63218, offsetContext.getScn=63211, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63218, endScn=63226, offsetContext.getScn=63218, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63226, endScn=63233, offsetContext.getScn=63226, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63233, endScn=63241, offsetContext.getScn=63233, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63241, endScn=63249, offsetContext.getScn=63241, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63249, endScn=63257, offsetContext.getScn=63249, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63257, endScn=63265, offsetContext.getScn=63257, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63265, endScn=63273, offsetContext.getScn=63265, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63273, endScn=63281, offsetContext.getScn=63273, strategy=CATALOG_IN_REDO, continuous=false
[Checkpoint Timer] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering checkpoint 1 (type=CheckpointType{name='Checkpoint', sharingFilesStrategy=FORWARD_BACKWARD}) @ 1747473199960 for job 955196ef93eff1023621b8f747f5c6cc.
[jobmanager-io-thread-4] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Completed checkpoint 1 for job 955196ef93eff1023621b8f747f5c6cc (1120 bytes, checkpointDuration=83 ms, finalizationTime=0 ms).
[Source: dameng_source_table[1] -> ConstraintEnforcer[2] -> Sink: Collect table sink (1/1)#0] WARN org.apache.flink.cdc.debezium.DebeziumSourceFunction - Consumer subtask 0 received confirmation for unknown checkpoint id 1
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63281, endScn=63289, offsetContext.getScn=63281, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63289, endScn=63297, offsetContext.getScn=63289, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63297, endScn=63305, offsetContext.getScn=63297, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63305, endScn=63313, offsetContext.getScn=63305, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63313, endScn=63321, offsetContext.getScn=63313, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63321, endScn=63329, offsetContext.getScn=63321, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63329, endScn=63337, offsetContext.getScn=63329, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63337, endScn=63345, offsetContext.getScn=63337, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63345, endScn=63353, offsetContext.getScn=63345, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63353, endScn=63362, offsetContext.getScn=63353, strategy=CATALOG_IN_REDO, continuous=false
[Checkpoint Timer] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering checkpoint 2 (type=CheckpointType{name='Checkpoint', sharingFilesStrategy=FORWARD_BACKWARD}) @ 1747473229963 for job 955196ef93eff1023621b8f747f5c6cc.
[jobmanager-io-thread-8] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Completed checkpoint 2 for job 955196ef93eff1023621b8f747f5c6cc (1120 bytes, checkpointDuration=0 ms, finalizationTime=0 ms).
[Source: dameng_source_table[1] -> ConstraintEnforcer[2] -> Sink: Collect table sink (1/1)#0] WARN org.apache.flink.cdc.debezium.DebeziumSourceFunction - Consumer subtask 0 received confirmation for unknown checkpoint id 2
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63362, endScn=63370, offsetContext.getScn=63362, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63370, endScn=63378, offsetContext.getScn=63370, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63378, endScn=63386, offsetContext.getScn=63378, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63386, endScn=63394, offsetContext.getScn=63386, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63394, endScn=63402, offsetContext.getScn=63394, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63402, endScn=63410, offsetContext.getScn=63402, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63410, endScn=63419, offsetContext.getScn=63410, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63419, endScn=63426, offsetContext.getScn=63419, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63426, endScn=63434, offsetContext.getScn=63426, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63434, endScn=63442, offsetContext.getScn=63434, strategy=CATALOG_IN_REDO, continuous=false
[Checkpoint Timer] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering checkpoint 3 (type=CheckpointType{name='Checkpoint', sharingFilesStrategy=FORWARD_BACKWARD}) @ 1747473259966 for job 955196ef93eff1023621b8f747f5c6cc.
[jobmanager-io-thread-13] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Completed checkpoint 3 for job 955196ef93eff1023621b8f747f5c6cc (1120 bytes, checkpointDuration=4 ms, finalizationTime=0 ms).
[Source: dameng_source_table[1] -> ConstraintEnforcer[2] -> Sink: Collect table sink (1/1)#0] WARN org.apache.flink.cdc.debezium.DebeziumSourceFunction - Consumer subtask 0 received confirmation for unknown checkpoint id 3
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63442, endScn=63449, offsetContext.getScn=63442, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63449, endScn=63457, offsetContext.getScn=63449, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63457, endScn=63466, offsetContext.getScn=63457, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63466, endScn=63474, offsetContext.getScn=63466, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63474, endScn=63483, offsetContext.getScn=63474, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63483, endScn=63491, offsetContext.getScn=63483, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63491, endScn=63499, offsetContext.getScn=63491, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63499, endScn=63507, offsetContext.getScn=63499, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63507, endScn=63515, offsetContext.getScn=63507, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63515, endScn=63523, offsetContext.getScn=63515, strategy=CATALOG_IN_REDO, continuous=false
[Checkpoint Timer] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering checkpoint 4 (type=CheckpointType{name='Checkpoint', sharingFilesStrategy=FORWARD_BACKWARD}) @ 1747473289959 for job 955196ef93eff1023621b8f747f5c6cc.
[jobmanager-io-thread-18] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Completed checkpoint 4 for job 955196ef93eff1023621b8f747f5c6cc (1120 bytes, checkpointDuration=8 ms, finalizationTime=0 ms).
[Source: dameng_source_table[1] -> ConstraintEnforcer[2] -> Sink: Collect table sink (1/1)#0] WARN org.apache.flink.cdc.debezium.DebeziumSourceFunction - Consumer subtask 0 received confirmation for unknown checkpoint id 4
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63523, endScn=63531, offsetContext.getScn=63523, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63531, endScn=63539, offsetContext.getScn=63531, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63539, endScn=63547, offsetContext.getScn=63539, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63547, endScn=63555, offsetContext.getScn=63547, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63555, endScn=63563, offsetContext.getScn=63555, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63563, endScn=63571, offsetContext.getScn=63563, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63571, endScn=63579, offsetContext.getScn=63571, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63579, endScn=63587, offsetContext.getScn=63579, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63587, endScn=63595, offsetContext.getScn=63587, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63595, endScn=63603, offsetContext.getScn=63595, strategy=CATALOG_IN_REDO, continuous=false
[Checkpoint Timer] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering checkpoint 5 (type=CheckpointType{name='Checkpoint', sharingFilesStrategy=FORWARD_BACKWARD}) @ 1747473319964 for job 955196ef93eff1023621b8f747f5c6cc.
[jobmanager-io-thread-23] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Completed checkpoint 5 for job 955196ef93eff1023621b8f747f5c6cc (1120 bytes, checkpointDuration=2 ms, finalizationTime=0 ms).
[Source: dameng_source_table[1] -> ConstraintEnforcer[2] -> Sink: Collect table sink (1/1)#0] WARN org.apache.flink.cdc.debezium.DebeziumSourceFunction - Consumer subtask 0 received confirmation for unknown checkpoint id 5
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63603, endScn=63611, offsetContext.getScn=63603, strategy=CATALOG_IN_REDO, continuous=false
[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO org.devlive.connector.dameng.logminer.LogMinerStreamingChangeEventSource - Ending log mining startScn=63611, endScn=63619, offsetContext.getScn=63611, strategy=CATALOG_IN_REDO, continuous=false

[taoyameng]

之前是因为sql配置里面的表名问题，现在报错如下
大概定位到这里了 执行

SELECT * FROM "ENDPOINT_MONITOR"."ENDPOINT_MONITOR"."DATA_GEN" AS OF SCN 71661

的时候报错了

[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.pipeline.source.AbstractSnapshotChangeEventSource - Snapshot - Final stage
[debezium-damengconnector-dameng-server-change-event-source-coordinator] ERROR io.debezium.pipeline.ErrorHandler - Producer failure
io.debezium.DebeziumException: org.apache.kafka.connect.errors.ConnectException: Snapshotting of table ENDPOINT_MONITOR.ENDPOINT_MONITOR.DATA_GEN failed
	at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:85)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:155)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:137)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266)
	at java.util.concurrent.FutureTask.run(FutureTask.java)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.connect.errors.ConnectException: Snapshotting of table ENDPOINT_MONITOR.ENDPOINT_MONITOR.DATA_GEN failed
	at io.debezium.relational.RelationalSnapshotChangeEventSource.createDataEventsForTable(RelationalSnapshotChangeEventSource.java:420)
	at io.debezium.relational.RelationalSnapshotChangeEventSource.createDataEvents(RelationalSnapshotChangeEventSource.java:316)
	at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:132)
	at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76)
	... 9 more
Caused by: dm.jdbc.driver.DMException: 第 1 行, 第 47 列[OF]附近出现错误: 
语法分析出错
	at dm.jdbc.driver.DBError.throwException(DBError.java:635)
	at dm.jdbc.c.a.n.J(MSG.java:221)
	at dm.jdbc.c.a.n.G(MSG.java:181)
	at dm.jdbc.c.a.n.F(MSG.java:162)
	at dm.jdbc.c.a.a(DBAccess.java:759)
	at dm.jdbc.c.a.a(DBAccess.java:195)
	at dm.jdbc.driver.DmdbStatement.executeInner(DmdbStatement.java:695)
	at dm.jdbc.driver.DmdbStatement.do_executeQuery(DmdbStatement.java:203)
	at dm.jdbc.driver.DmdbStatement.executeQuery(DmdbStatement.java:981)
	at io.debezium.relational.RelationalSnapshotChangeEventSource.createDataEventsForTable(RelationalSnapshotChangeEventSource.java:373)

[qianmoQ]

之前是因为sql配置里面的表名问题，现在报错如下 大概定位到这里了 执行

SELECT * FROM "ENDPOINT_MONITOR"."ENDPOINT_MONITOR"."DATA_GEN" AS OF SCN 71661

的时候报错了

[debezium-damengconnector-dameng-server-change-event-source-coordinator] INFO io.debezium.pipeline.source.AbstractSnapshotChangeEventSource - Snapshot - Final stage
[debezium-damengconnector-dameng-server-change-event-source-coordinator] ERROR io.debezium.pipeline.ErrorHandler - Producer failure
io.debezium.DebeziumException: org.apache.kafka.connect.errors.ConnectException: Snapshotting of table ENDPOINT_MONITOR.ENDPOINT_MONITOR.DATA_GEN failed
	at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:85)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.doSnapshot(ChangeEventSourceCoordinator.java:155)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:137)
	at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266)
	at java.util.concurrent.FutureTask.run(FutureTask.java)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.connect.errors.ConnectException: Snapshotting of table ENDPOINT_MONITOR.ENDPOINT_MONITOR.DATA_GEN failed
	at io.debezium.relational.RelationalSnapshotChangeEventSource.createDataEventsForTable(RelationalSnapshotChangeEventSource.java:420)
	at io.debezium.relational.RelationalSnapshotChangeEventSource.createDataEvents(RelationalSnapshotChangeEventSource.java:316)
	at io.debezium.relational.RelationalSnapshotChangeEventSource.doExecute(RelationalSnapshotChangeEventSource.java:132)
	at io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.execute(AbstractSnapshotChangeEventSource.java:76)
	... 9 more
Caused by: dm.jdbc.driver.DMException: 第 1 行, 第 47 列[OF]附近出现错误: 
语法分析出错
	at dm.jdbc.driver.DBError.throwException(DBError.java:635)
	at dm.jdbc.c.a.n.J(MSG.java:221)
	at dm.jdbc.c.a.n.G(MSG.java:181)
	at dm.jdbc.c.a.n.F(MSG.java:162)
	at dm.jdbc.c.a.a(DBAccess.java:759)
	at dm.jdbc.c.a.a(DBAccess.java:195)
	at dm.jdbc.driver.DmdbStatement.executeInner(DmdbStatement.java:695)
	at dm.jdbc.driver.DmdbStatement.do_executeQuery(DmdbStatement.java:203)
	at dm.jdbc.driver.DmdbStatement.executeQuery(DmdbStatement.java:981)
	at io.debezium.relational.RelationalSnapshotChangeEventSource.createDataEventsForTable(RelationalSnapshotChangeEventSource.java:373)

开启一下Oracle的兼容模式

[taoyameng]

已经开启了的， 使用

SELECT para_name,para_type,para_value FROM V$DM_INI WHERE PARA_NAME = 'COMPATIBLE_MODE';

COMPATIBLE_MODE IN FILE 2

[qianmoQ]

已经开启了的， 使用

SELECT para_name,para_type,para_value FROM V$DM_INI WHERE PARA_NAME = 'COMPATIBLE_MODE';

COMPATIBLE_MODE IN FILE 2

列出现了关键字 OF，看一下

[taoyameng]

-- 这条语句可以成功执行
SELECT * FROM "ENDPOINT_MONITOR"."DATA_GEN" WHEN TIMESTAMP '2025-05-21 17:23:41';

-- 这条语句就出现语法错误
SELECT * FROM "ENDPOINT_MONITOR"."DATA_GEN" AS OF SCN 71661;

我看了安装包里面的文档 文档里只能使用 WHEN TIMESTAMP 和 WHEN TRXID 来做闪回查询，但是在官网上的文档上发现是支持AS OF SCN|LSN的，那就是版本问题了，就是不知道如何兼容这个情况，毕竟如果在线上的话 数据库版本也没人敢随便换的

[qianmoQ]

-- 这条语句可以成功执行
SELECT * FROM "ENDPOINT_MONITOR"."DATA_GEN" WHEN TIMESTAMP '2025-05-21 17:23:41';

-- 这条语句就出现语法错误
SELECT * FROM "ENDPOINT_MONITOR"."DATA_GEN" AS OF SCN 71661;

我看了安装包里面的文档 文档里只能使用 WHEN TIMESTAMP 和 WHEN TRXID 来做闪回查询，但是在官网上的文档上发现是支持AS OF SCN|LSN的，那就是版本问题了，就是不知道如何兼容这个情况，毕竟如果在线上的话 数据库版本也没人敢随便换的

哪个版本呢？我看能否兼容一下

[taoyameng]

-- 这条语句可以成功执行
SELECT * FROM "ENDPOINT_MONITOR"."DATA_GEN" WHEN TIMESTAMP '2025-05-21 17:23:41';

-- 这条语句就出现语法错误
SELECT * FROM "ENDPOINT_MONITOR"."DATA_GEN" AS OF SCN 71661;

我看了安装包里面的文档 文档里只能使用 WHEN TIMESTAMP 和 WHEN TRXID 来做闪回查询，但是在官网上的文档上发现是支持AS OF SCN|LSN的，那就是版本问题了，就是不知道如何兼容这个情况，毕竟如果在线上的话 数据库版本也没人敢随便换的

哪个版本呢？我看能否兼容一下

我的版本是我的达梦版本是 DM Database Server x64 V8 DB Version: 0x7000b，闪回查询语法是 <闪回查询子句>::=WHEN |