[ 27-09-2024 04:04:04.425 ] [ blc-127.0.0.1:6033 ] [ ERROR ] io.debezium.DebeziumException: Error processing binlog event at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:301) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$30(MySqlStreamingChangeEventSource.java:879) at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:1263) at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:1089) at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:648) at com.github.shyiko.mysql.binlog.BinaryLogClient$7.run(BinaryLogClient.java:949) at java.base/java.lang.Thread.run(Thread.java:829) Caused by: io.debezium.DebeziumException: Database error while executing incremental snapshot for table 'DataCollection{id={table_name}, additionalCondition=id in ({list_of_primary_keys}) AND orgId = {org_id}, surrogateKey=}' at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.readChunk(AbstractIncrementalSnapshotChangeEventSource.java:411) at io.debezium.connector.mysql.strategy.mysql.MySqlReadOnlyIncrementalSnapshotChangeEventSource.processTransactionStartedEvent(MySqlReadOnlyIncrementalSnapshotChangeEventSource.java:159) at io.debezium.connector.mysql.strategy.mysql.MySqlReadOnlyIncrementalSnapshotChangeEventSource.processTransactionStartedEvent(MySqlReadOnlyIncrementalSnapshotChangeEventSource.java:83) at io.debezium.pipeline.EventDispatcher.dispatchTransactionStartedEvent(EventDispatcher.java:354) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleTransactionBegin(MySqlStreamingChangeEventSource.java:544) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleQueryEvent(MySqlStreamingChangeEventSource.java:483) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$18(MySqlStreamingChangeEventSource.java:849) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleTransactionPayload(MySqlStreamingChangeEventSource.java:612) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.lambda$execute$19(MySqlStreamingChangeEventSource.java:850) at io.debezium.connector.mysql.MySqlStreamingChangeEventSource.handleEvent(MySqlStreamingChangeEventSource.java:281) ... 6 common frames omitted Caused by: io.debezium.DebeziumException: Snapshotting of table {table_name} failed at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.createDataEventsForTable(AbstractIncrementalSnapshotChangeEventSource.java:682) at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.readChunk(AbstractIncrementalSnapshotChangeEventSource.java:385) ... 15 common frames omitted Caused by: java.sql.SQLException: Streaming result set com.mysql.cj.protocol.a.result.ResultsetRowsStreaming@39bc5403 is still active. No statements may be issued when any streaming result sets are open and in use on a given connection. Ensure that you have called .close() on any active streaming result sets before attempting more queries. at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:130) at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) at com.mysql.cj.jdbc.StatementImpl.executeSimpleNonQuery(StatementImpl.java:1242) at com.mysql.cj.jdbc.StatementImpl.setupStreamingTimeout(StatementImpl.java:636) at com.mysql.cj.jdbc.ClientPreparedStatement.executeQuery(ClientPreparedStatement.java:943) at io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotChangeEventSource.createDataEventsForTable(AbstractIncrementalSnapshotChangeEventSource.java:638) ... 16 common frames omitted