diff --git a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleErrorHandler.java b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleErrorHandler.java index c8e707107..8b96f5ae7 100644 --- a/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleErrorHandler.java +++ b/debezium-connector-oracle/src/main/java/io/debezium/connector/oracle/OracleErrorHandler.java @@ -60,8 +60,8 @@ public class OracleErrorHandler extends ErrorHandler { */ @Immutable private static final Set RETRIABLE_ORA600_ERROR_MESSAGES = Collect.unmodifiableSet( - "krvrdGetUID" // Changes made to object identifier (schema change) - ); + "krvrdGetUID", // Changes made to object identifier (schema change) + "krvrdccs10"); public OracleErrorHandler(OracleConnectorConfig connectorConfig, ChangeEventQueue queue, ErrorHandler replacedErrorHandler) { super(OracleConnector.class, connectorConfig, queue, replacedErrorHandler);