[2023-02-28 10:16:49,499] INFO [oracle_debezium_connector_3|task-0] Starting OracleConnectorTask with configuration: (io.debezium.connector.common.BaseSourceTask:124) [2023-02-28 10:16:47,498] INFO [oracle_debezium_connector_3|task-0] Awaiting end of restart backoff period after a retriable error (io.debezium.connector.common.BaseSourceTask:211) [2023-02-28 10:16:46,785] INFO [oracle_debezium_connector_3|task-0|offsets] WorkerSourceTask{id=oracle_debezium_connector_3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:505) [2023-02-28 10:16:45,498] INFO [oracle_debezium_connector_3|task-0] Awaiting end of restart backoff period after a retriable error (io.debezium.connector.common.BaseSourceTask:211) [2023-02-28 10:16:43,497] INFO [oracle_debezium_connector_3|task-0] Awaiting end of restart backoff period after a retriable error (io.debezium.connector.common.BaseSourceTask:211) [2023-02-28 10:16:41,497] INFO [oracle_debezium_connector_3|task-0] Awaiting end of restart backoff period after a retriable error (io.debezium.connector.common.BaseSourceTask:211) [2023-02-28 10:16:39,497] INFO [oracle_debezium_connector_3|task-0] Awaiting end of restart backoff period after a retriable error (io.debezium.connector.common.BaseSourceTask:211) [2023-02-28 10:16:39,497] WARN [oracle_debezium_connector_3|task-0] WorkerSourceTask{id=oracle_debezium_connector_3-0} failed to poll records from SourceTask. Will retry operation. (org.apache.kafka.connect.runtime.WorkerSourceTask:293) org.apache.kafka.connect.errors.RetriableException: An exception occurred in the change event producer. This connector will be restarted. at io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:46) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:222) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60) 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(Unknown Source) at java.base/java.util.concurrent.FutureTask.run(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.base/java.lang.Thread.run(Unknown Source) Caused by: java.sql.SQLRecoverableException: IO Error: Connection reset by peer at oracle.jdbc.driver.T4CStatement.executeForDescribe(T4CStatement.java:779) at oracle.jdbc.driver.OracleStatement.executeMaybeDescribe(OracleStatement.java:983) at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1168) at oracle.jdbc.driver.OracleStatement.executeQuery(OracleStatement.java:1362) at oracle.jdbc.driver.OracleStatementWrapper.executeQuery(OracleStatementWrapper.java:369) at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:635) at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:504) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.getCurrentRedoLogSequences(LogMinerStreamingChangeEventSource.java:493) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.hasLogSwitchOccurred(LogMinerStreamingChangeEventSource.java:426) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:193) ... 9 more Suppressed: java.sql.SQLRecoverableException: Closed Connection at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:3525) at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:1478) at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:1461) at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:122) at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:631) ... 13 more Caused by: java.io.IOException: Connection reset by peer at java.base/sun.nio.ch.FileDispatcherImpl.read0(Native Method) at java.base/sun.nio.ch.SocketDispatcher.read(Unknown Source) at java.base/sun.nio.ch.IOUtil.readIntoNativeBuffer(Unknown Source) at java.base/sun.nio.ch.IOUtil.read(Unknown Source) at java.base/sun.nio.ch.IOUtil.read(Unknown Source) at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source) at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:174) at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:555) at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:258) at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:190) at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:132) at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:105) at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:91) at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:784) at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:449) at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:410) at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:269) at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:655) at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:229) at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:41) at oracle.jdbc.driver.T4CStatement.executeForDescribe(T4CStatement.java:765) ... 18 more [2023-02-28 10:16:39,497] INFO [oracle_debezium_connector_3|task-0] App info kafka.producer for MYORA-dbhistory unregistered (org.apache.kafka.common.utils.AppInfoParser:83) [2023-02-28 10:16:39,496] INFO [oracle_debezium_connector_3|task-0] Metrics reporters closed (org.apache.kafka.common.metrics.Metrics:669) [2023-02-28 10:16:39,496] INFO [oracle_debezium_connector_3|task-0] Closing reporter org.apache.kafka.common.metrics.JmxReporter (org.apache.kafka.common.metrics.Metrics:663) [2023-02-28 10:16:39,496] INFO [oracle_debezium_connector_3|task-0] Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:659) [2023-02-28 10:16:39,495] INFO [oracle_debezium_connector_3|task-0] [Producer clientId=MYORA-dbhistory] Closing the Kafka producer with timeoutMillis = 30000 ms. (org.apache.kafka.clients.producer.KafkaProducer:1208) [2023-02-28 10:16:39,495] INFO [oracle_debezium_connector_3|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:956) [2023-02-28 10:16:39,494] ERROR [oracle_debezium_connector_3|task-0] Exception while closing the heartbeat JDBC connection (io.debezium.heartbeat.DatabaseHeartbeatImpl:73) java.sql.SQLRecoverableException: IO Error: Connection reset by peer at oracle.jdbc.driver.T4CConnection.logoff(T4CConnection.java:1006) at oracle.jdbc.driver.PhysicalConnection.close(PhysicalConnection.java:2268) at io.debezium.jdbc.JdbcConnection.lambda$doClose$3(JdbcConnection.java:955) at java.base/java.util.concurrent.FutureTask.run(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.base/java.lang.Thread.run(Unknown Source) Caused by: java.io.IOException: Connection reset by peer at java.base/sun.nio.ch.FileDispatcherImpl.read0(Native Method) at java.base/sun.nio.ch.SocketDispatcher.read(Unknown Source) at java.base/sun.nio.ch.IOUtil.readIntoNativeBuffer(Unknown Source) at java.base/sun.nio.ch.IOUtil.read(Unknown Source) at java.base/sun.nio.ch.IOUtil.read(Unknown Source) at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source) at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:174) at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:555) at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:258) at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:190) at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:132) at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:105) at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:91) at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:784) at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:449) at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:410) at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:269) at oracle.jdbc.driver.T4C7Ocommoncall.doOLOGOFF(T4C7Ocommoncall.java:64) at oracle.jdbc.driver.T4CConnection.logoff(T4CConnection.java:995) ... 6 more [2023-02-28 10:16:39,493] WARN [oracle_debezium_connector_3|task-0] Going to restart connector after 10 sec. after a retriable exception (io.debezium.connector.common.BaseSourceTask:235) [2023-02-28 10:16:39,302] INFO [oracle_debezium_connector_3|task-0] Connected metrics set to 'false' (io.debezium.pipeline.ChangeEventSourceCoordinator:236) [2023-02-28 10:16:39,302] INFO [oracle_debezium_connector_3|task-0] Finished streaming (io.debezium.pipeline.ChangeEventSourceCoordinator:175) [2023-02-28 10:16:39,302] INFO [oracle_debezium_connector_3|task-0] Offsets: OracleOffsetContext [scn=12160644541497, commit_scn=12160644542113] (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:227) [2023-02-28 10:16:39,302] INFO [oracle_debezium_connector_3|task-0] Streaming metrics dump: OracleStreamingChangeEventSourceMetrics{currentScn=12160644542324, oldestScn=12160644541498, committedScn=12160644542122, offsetScn=12160644541345, logMinerQueryCount=337336, totalProcessedRows=168643054, totalCapturedDmlCount=99614151, totalDurationOfFetchingQuery=PT118H22M23.05732S, lastCapturedDmlCount=324, lastDurationOfFetchingQuery=PT0.804698S, maxCapturedDmlCount=15202, maxDurationOfFetchingQuery=PT6.656364S, totalBatchProcessingDuration=PT130H48M59.06617S, lastBatchProcessingDuration=PT0.951883S, maxBatchProcessingThroughput=1561, currentLogFileName=[+DATA/MYORA/ONLINELOG/group_2.262.1091871893, +RECO/MYORA/ONLINELOG/group_2.265.1091871893, +RECO/MYORA/ONLINELOG/group_51.256.1091871785, +DATA/MYORA/ONLINELOG/group_51.283.1091871785], minLogFilesMined=4, maxLogFilesMined=6, redoLogStatus=[+DATA/MYORA/ONLINELOG/group_1.263.1091871893 | ACTIVE, +RECO/MYORA/ONLINELOG/group_1.264.1091871893 | ACTIVE, +DATA/MYORA/ONLINELOG/group_2.262.1091871893 | CURRENT, +RECO/MYORA/ONLINELOG/group_2.265.1091871893 | CURRENT, +RECO/MYORA/ONLINELOG/group_51.256.1091871785 | CURRENT, +DATA/MYORA/ONLINELOG/group_51.283.1091871785 | CURRENT, +DATA/MYORA/ONLINELOG/group_52.284.1091871789 | INACTIVE, +RECO/MYORA/ONLINELOG/group_52.257.1091871789 | INACTIVE, +DATA/MYORA/ONLINELOG/group_53.285.1091871791 | INACTIVE, +RECO/MYORA/ONLINELOG/group_53.258.1091871791 | INACTIVE, +DATA/MYORA/ONLINELOG/group_54.286.1091871791 | INACTIVE, +RECO/MYORA/ONLINELOG/group_54.259.1091871793 | INACTIVE, +DATA/MYORA/ONLINELOG/group_3.267.1091871855 | INACTIVE, +RECO/MYORA/ONLINELOG/group_55.260.1091871793 | INACTIVE, +DATA/MYORA/ONLINELOG/group_4.266.1091871857 | INACTIVE, +RECO/MYORA/ONLINELOG/group_4.262.1091871857 | INACTIVE, +RECO/MYORA/ONLINELOG/group_5.263.1091871857 | INACTIVE, +DATA/MYORA/ONLINELOG/group_5.288.1091871857 | INACTIVE, +RECO/MYORA/ONLINELOG/group_3.261.1091871857 | INACTIVE, +DATA/MYORA/ONLINELOG/group_55.287.1091871793 | INACTIVE], switchCounter=84, batchSize=12000, millisecondToSleepBetweenMiningQuery=2800, hoursToKeepTransaction=0, networkConnectionProblemsCounter0, batchSizeDefault=10000, batchSizeMin=1000, batchSizeMax=100000, sleepTimeDefault=1000, sleepTimeMin=0, sleepTimeMax=3000, sleepTimeIncrement=200, totalParseTime=PT10M49.879106S, totalStartLogMiningSessionDuration=PT37M47.545796S, lastStartLogMiningSessionDuration=PT0.006366S, maxStartLogMiningSessionDuration=PT11.682547S, totalProcessTime=PT130H48M59.06617S, minBatchProcessTime=PT0.359865S, maxBatchProcessTime=PT15.298561S, totalResultSetNextTime=PT10M56.995715S, lagFromTheSource=DurationPT1.807985S, maxLagFromTheSourceDuration=PT6M37.50184S, minLagFromTheSourceDuration=PT0.001957S, lastCommitDuration=PT0.000001S, maxCommitDuration=PT0.210561S, activeTransactions=7, rolledBackTransactions=33357, committedTransactions=34467469, abandonedTransactionIds={}, rolledbackTransactionIds={2a041300ea9c0000=2a041300ea9c0000, e6061c0031910000=e6061c0031910000, e6060f00fe900000=e6060f00fe900000, d8010900c49c0000=d8010900c49c0000, d8011800d59c0000=d8011800d59c0000, 1b030800f59e0000=1b030800f59e0000, 1d0d1f00ee920000=1d0d1f00ee920000, 560e1e00cf950000=560e1e00cf950000, e6041400e9a60000=e6041400e9a60000, de0400004d9e0000=de0400004d9e0000}, registeredDmlCount=99614151, committedDmlCount=99612770, errorCount=1, warningCount=0, scnFreezeCount=0, unparsableDdlCount=0, miningSessionUserGlobalAreaMemory=5249040, miningSessionUserGlobalAreaMaxMemory=6718056, miningSessionProcessGlobalAreaMemory=842211112, miningSessionProcessGlobalAreaMaxMemory=842342184} (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:226) [2023-02-28 10:16:39,302] INFO [oracle_debezium_connector_3|task-0] startScn=12160644542123, endScn=12160644542324 (io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource:225) [2023-02-28 10:16:39,302] ERROR [oracle_debezium_connector_3|task-0] Producer failure (io.debezium.pipeline.ErrorHandler:35) java.sql.SQLRecoverableException: IO Error: Connection reset by peer at oracle.jdbc.driver.T4CStatement.executeForDescribe(T4CStatement.java:779) at oracle.jdbc.driver.OracleStatement.executeMaybeDescribe(OracleStatement.java:983) at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1168) at oracle.jdbc.driver.OracleStatement.executeQuery(OracleStatement.java:1362) at oracle.jdbc.driver.OracleStatementWrapper.executeQuery(OracleStatementWrapper.java:369) at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:635) at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:504) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.getCurrentRedoLogSequences(LogMinerStreamingChangeEventSource.java:493) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.hasLogSwitchOccurred(LogMinerStreamingChangeEventSource.java:426) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:193) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60) 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(Unknown Source) at java.base/java.util.concurrent.FutureTask.run(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.base/java.lang.Thread.run(Unknown Source) Suppressed: java.sql.SQLRecoverableException: Closed Connection at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:3525) at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:1478) at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:1461) at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:122) at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:631) ... 13 more Caused by: java.io.IOException: Connection reset by peer at java.base/sun.nio.ch.FileDispatcherImpl.read0(Native Method) at java.base/sun.nio.ch.SocketDispatcher.read(Unknown Source) at java.base/sun.nio.ch.IOUtil.readIntoNativeBuffer(Unknown Source) at java.base/sun.nio.ch.IOUtil.read(Unknown Source) at java.base/sun.nio.ch.IOUtil.read(Unknown Source) at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source) at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:174) at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:555) at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:258) at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:190) at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:132) at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:105) at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:91) at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:784) at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:449) at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:410) at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:269) at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:655) at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:229) at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:41) at oracle.jdbc.driver.T4CStatement.executeForDescribe(T4CStatement.java:765) ... 18 more [2023-02-28 10:16:39,301] ERROR [oracle_debezium_connector_3|task-0] Mining session stopped due to the {} (io.debezium.connector.oracle.logminer.LogMinerHelper:117) java.sql.SQLRecoverableException: IO Error: Connection reset by peer at oracle.jdbc.driver.T4CStatement.executeForDescribe(T4CStatement.java:779) at oracle.jdbc.driver.OracleStatement.executeMaybeDescribe(OracleStatement.java:983) at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1168) at oracle.jdbc.driver.OracleStatement.executeQuery(OracleStatement.java:1362) at oracle.jdbc.driver.OracleStatementWrapper.executeQuery(OracleStatementWrapper.java:369) at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:635) at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:504) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.getCurrentRedoLogSequences(LogMinerStreamingChangeEventSource.java:493) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.hasLogSwitchOccurred(LogMinerStreamingChangeEventSource.java:426) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:193) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60) 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(Unknown Source) at java.base/java.util.concurrent.FutureTask.run(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.base/java.lang.Thread.run(Unknown Source) Suppressed: java.sql.SQLRecoverableException: Closed Connection at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:3525) at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:1478) at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:1461) at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:122) at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:631) ... 13 more Caused by: java.io.IOException: Connection reset by peer at java.base/sun.nio.ch.FileDispatcherImpl.read0(Native Method) at java.base/sun.nio.ch.SocketDispatcher.read(Unknown Source) at java.base/sun.nio.ch.IOUtil.readIntoNativeBuffer(Unknown Source) at java.base/sun.nio.ch.IOUtil.read(Unknown Source) at java.base/sun.nio.ch.IOUtil.read(Unknown Source) at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source) at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:174) at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:555) at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:258) at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:190) at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:132) at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:105) at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:91) at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:784) at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:449) at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:410) at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:269) at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:655) at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:229) at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:41) at oracle.jdbc.driver.T4CStatement.executeForDescribe(T4CStatement.java:765) ... 18 more [2023-02-28 10:16:39,301] INFO [oracle_debezium_connector_3|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:956) [2023-02-28 10:16:39,296] INFO [oracle_debezium_connector_3|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:956) [2023-02-28 10:16:36,785] INFO [oracle_debezium_connector_3|task-0|offsets] WorkerSourceTask{id=oracle_debezium_connector_3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:505) [2023-02-28 10:16:36,290] WARN [oracle_debezium_connector_3|task-0] Not all LGWR buffers were flushed, waiting 3 seconds for Oracle to flush automatically. (io.debezium.connector.oracle.logminer.logwriter.RacCommitLogWriterFlushStrategy:98) [2023-02-28 10:16:36,272] INFO [oracle_debezium_connector_3|task-0] Database Version: Oracle Database 12c Enterprise Edition Release 12.1.0.2.0 - 64bit Production (io.debezium.connector.oracle.OracleConnection:78) [2023-02-28 10:16:36,151] INFO [oracle_debezium_connector_3|task-0] Database Version: Oracle Database 12c Enterprise Edition Release 12.1.0.2.0 - 64bit Production (io.debezium.connector.oracle.OracleConnection:78) [2023-02-28 10:16:36,061] INFO [oracle_debezium_connector_3|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:956) [2023-02-28 10:16:36,061] INFO [oracle_debezium_connector_3|task-0] Connection gracefully closed (io.debezium.jdbc.JdbcConnection:956) [2023-02-28 10:16:36,060] WARN [oracle_debezium_connector_3|task-0] Failed to flush LGWR buffer on RAC node 'DB*****.COM' (io.debezium.connector.oracle.logminer.logwriter.RacCommitLogWriterFlushStrategy:91) io.debezium.DebeziumException: Failed to flush Oracle LogWriter (LGWR) buffers to disk at io.debezium.connector.oracle.logminer.logwriter.CommitLogWriterFlushStrategy.flush(CommitLogWriterFlushStrategy.java:89) at io.debezium.connector.oracle.logminer.logwriter.RacCommitLogWriterFlushStrategy.flush(RacCommitLogWriterFlushStrategy.java:88) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:178) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60) 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(Unknown Source) at java.base/java.util.concurrent.FutureTask.run(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.base/java.lang.Thread.run(Unknown Source) Caused by: java.sql.SQLRecoverableException: IO Error: Connection reset by peer at oracle.jdbc.driver.T4CStatement.executeForRows(T4CStatement.java:951) at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1205) at oracle.jdbc.driver.OracleStatement.executeInternal(OracleStatement.java:1823) at oracle.jdbc.driver.OracleStatement.execute(OracleStatement.java:1778) at oracle.jdbc.driver.OracleStatementWrapper.execute(OracleStatementWrapper.java:303) at io.debezium.jdbc.JdbcConnection.lambda$execute$2(JdbcConnection.java:424) at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:441) at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:418) at io.debezium.connector.oracle.logminer.logwriter.CommitLogWriterFlushStrategy.flush(CommitLogWriterFlushStrategy.java:86) ... 11 more Suppressed: java.sql.SQLRecoverableException: Closed Connection at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:3525) at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:1478) at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:1461) at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:122) at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:440) ... 13 more Caused by: java.io.IOException: Connection reset by peer at java.base/sun.nio.ch.FileDispatcherImpl.read0(Native Method) at java.base/sun.nio.ch.SocketDispatcher.read(Unknown Source) at java.base/sun.nio.ch.IOUtil.readIntoNativeBuffer(Unknown Source) at java.base/sun.nio.ch.IOUtil.read(Unknown Source) at java.base/sun.nio.ch.IOUtil.read(Unknown Source) at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source) at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:174) at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:555) at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:258) at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:190) at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:132) at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:105) at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:91) at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:784) at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:449) at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:410) at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:269) at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:655) at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:229) at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:41) at oracle.jdbc.driver.T4CStatement.executeForRows(T4CStatement.java:928) ... 19 more [2023-02-28 10:16:36,058] WARN [oracle_debezium_connector_3|task-0] Failed to flush LGWR buffer on RAC node 'DB*****.COM' (io.debezium.connector.oracle.logminer.logwriter.RacCommitLogWriterFlushStrategy:91) io.debezium.DebeziumException: Failed to flush Oracle LogWriter (LGWR) buffers to disk at io.debezium.connector.oracle.logminer.logwriter.CommitLogWriterFlushStrategy.flush(CommitLogWriterFlushStrategy.java:89) at io.debezium.connector.oracle.logminer.logwriter.RacCommitLogWriterFlushStrategy.flush(RacCommitLogWriterFlushStrategy.java:88) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:178) at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:60) 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(Unknown Source) at java.base/java.util.concurrent.FutureTask.run(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) at java.base/java.lang.Thread.run(Unknown Source) Caused by: java.sql.SQLRecoverableException: IO Error: Connection timed out at oracle.jdbc.driver.T4CStatement.executeForRows(T4CStatement.java:951) at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1205) at oracle.jdbc.driver.OracleStatement.executeInternal(OracleStatement.java:1823) at oracle.jdbc.driver.OracleStatement.execute(OracleStatement.java:1778) at oracle.jdbc.driver.OracleStatementWrapper.execute(OracleStatementWrapper.java:303) at io.debezium.jdbc.JdbcConnection.lambda$execute$2(JdbcConnection.java:424) at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:441) at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:418) at io.debezium.connector.oracle.logminer.logwriter.CommitLogWriterFlushStrategy.flush(CommitLogWriterFlushStrategy.java:86) ... 11 more Suppressed: java.sql.SQLRecoverableException: Closed Connection at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:3525) at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:1478) at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:1461) at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:122) at io.debezium.jdbc.JdbcConnection.execute(JdbcConnection.java:440) ... 13 more Caused by: java.io.IOException: Connection timed out at java.base/sun.nio.ch.FileDispatcherImpl.read0(Native Method) at java.base/sun.nio.ch.SocketDispatcher.read(Unknown Source) at java.base/sun.nio.ch.IOUtil.readIntoNativeBuffer(Unknown Source) at java.base/sun.nio.ch.IOUtil.read(Unknown Source) at java.base/sun.nio.ch.IOUtil.read(Unknown Source) at java.base/sun.nio.ch.SocketChannelImpl.read(Unknown Source) at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:174) at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:555) at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:258) at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:190) at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:132) at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:105) at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:91) at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:784) at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalUB1(T4CMAREngineNIO.java:449) at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:410) at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:269) at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:655) at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:229) at oracle.jdbc.driver.T4CStatement.doOall8(T4CStatement.java:41) at oracle.jdbc.driver.T4CStatement.executeForRows(T4CStatement.java:928) ... 19 more [2023-02-28 10:16:26,784] INFO [oracle_debezium_connector_3|task-0|offsets] WorkerSourceTask{id=oracle_debezium_connector_3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:505) [2023-02-28 10:16:16,784] INFO [oracle_debezium_connector_3|task-0|offsets] WorkerSourceTask{id=oracle_debezium_connector_3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:505) [2023-02-28 10:16:06,784] INFO [oracle_debezium_connector_3|task-0|offsets] WorkerSourceTask{id=oracle_debezium_connector_3-0} flushing 0 outstanding messages for offset commit (org.apache.kafka.connect.runtime.WorkerSourceTask:505) ...