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. Error code: 0; SQLSTATE: S1000.

[yonghaozhang]

hi team, we use flink cdc connnector mysql connector 1.2.0. Recently, we have encountered following issue, could someone help here.

com.alibaba.ververica.cdc.debezium.DebeziumSourceFunction 353 - Reporting error: org.apache.kafka.connect.errors.ConnectException: Streaming result set com.mysql.cj.protocol.a.result.ResultsetRowsStreaming@5d4f2831 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. Error code: 0; SQLSTATE: S1000. at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230) ~[blob_p-2d1e247995024fa8beecab031c5d249b8b2fa92d-45e375726a8ebf3431a67943b268f25b:?] at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:207) ~[blob_p-2d1e247995024fa8beecab031c5d249b8b2fa92d-45e375726a8ebf3431a67943b268f25b:?] at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:831) ~[blob_p-2d1e247995024fa8beecab031c5d249b8b2fa92d-45e375726a8ebf3431a67943b268f25b:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_282] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_282] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_282] Caused by: java.sql.SQLException: Streaming result set com.mysql.cj.protocol.a.result.ResultsetRowsStreaming@5d4f2831 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:129) ~[blob_p-2d1e247995024fa8beecab031c5d249b8b2fa92d-45e375726a8ebf3431a67943b268f25b:?] at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) ~[blob_p-2d1e247995024fa8beecab031c5d249b8b2fa92d-45e375726a8ebf3431a67943b268f25b:?] at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122) ~[blob_p-2d1e247995024fa8beecab031c5d249b8b2fa92d-45e375726a8ebf3431a67943b268f25b:?] at com.mysql.cj.jdbc.ConnectionImpl.commit(ConnectionImpl.java:813) ~[blob_p-2d1e247995024fa8beecab031c5d249b8b2fa92d-45e375726a8ebf3431a67943b268f25b:?] at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:747) ~[blob_p-2d1e247995024fa8beecab031c5d249b8b2fa92d-45e375726a8ebf3431a67943b268f25b:?] ... 3 more