From 499a1f61b825779faffad9ec198fea06e9336fe6 Mon Sep 17 00:00:00 2001 From: jchipmunk Date: Wed, 3 Apr 2024 21:58:21 +0300 Subject: [PATCH] DBZ-7737 Column CON_ID is missing in view V$THREAD in Oracle 11 --- .../java/io/debezium/connector/oracle/OracleConnection.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnection.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnection.java index 343b7f440..931e190a3 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnection.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleConnection.java @@ -809,8 +809,10 @@ public RedoThreadState getRedoThreadState() throws SQLException { threadBuilder = threadBuilder.lastRedoSequenceNumber(rs.getLong("LAST_REDO_SEQUENCE#")) .lastRedoBlock(rs.getLong("LAST_REDO_BLOCK")) .lastRedoScn(readScnColumnAsScn(rs, "LAST_REDO_CHANGE#")) - .lastRedoTime(readTimestampAsInstant(rs, "LAST_REDO_TIME")) - .conId(rs.getLong("CON_ID")); + .lastRedoTime(readTimestampAsInstant(rs, "LAST_REDO_TIME")); + } + if (getOracleVersion().getMajor() >= 12) { + threadBuilder = threadBuilder.conId(rs.getLong("CON_ID")); } builder = threadBuilder.build(); }