这个应该只是个 error 的日志，方便也发下retry times = 1 和 retry times = 2 的日志看下吗
在 2020-12-03 16:17:27，"yanzi" <[email protected]> 写道： >hi Leonard: > >报错信息如下： >[2020-12-02 22:01:03.403] [ERROR] [jdbc-upsert-output-format-thread-1] >[org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat] >>> JDBC >executeBatch error, retry times = 3 >java.sql.SQLException: No operations allowed after statement closed. > at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:965) >~[mysql-connector-java-5.1.49.jar:5.1.49] > at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:898) >~[mysql-connector-java-5.1.49.jar:5.1.49] > at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:887) >~[mysql-connector-java-5.1.49.jar:5.1.49] > at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:861) >~[mysql-connector-java-5.1.49.jar:5.1.49] > at com.mysql.jdbc.StatementImpl.checkClosed(StatementImpl.java:426) >~[mysql-connector-java-5.1.49.jar:5.1.49] > at > com.mysql.jdbc.PreparedStatement.setString(PreparedStatement.java:3943) >~[mysql-connector-java-5.1.49.jar:5.1.49] > at >org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.lambda$createExternalConverter$57fde215$8(AbstractJdbcRowConverter.java:219) >~[flink-connector-jdbc_2.11-1.11.0.jar:1.11.0] > at >org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.lambda$wrapIntoNullableExternalConverter$2bf50691$1(AbstractJdbcRowConverter.java:193) >~[flink-connector-jdbc_2.11-1.11.0.jar:1.11.0] > at >org.apache.flink.connector.jdbc.internal.converter.AbstractJdbcRowConverter.toExternal(AbstractJdbcRowConverter.java:86) >~[flink-connector-jdbc_2.11-1.11.0.jar:1.11.0] > at >org.apache.flink.connector.jdbc.table.JdbcRowDataOutputFormat.lambda$createKeyedRowExecutor$3fd497bb$1(JdbcRowDataOutputFormat.java:164) >~[flink-connector-jdbc_2.11-1.11.0.jar:1.11.0] > at >org.apache.flink.connector.jdbc.internal.executor.KeyedBatchStatementExecutor.executeBatch(KeyedBatchStatementExecutor.java:71) >~[flink-connector-jdbc_2.11-1.11.0.jar:1.11.0] > at >org.apache.flink.connector.jdbc.table.JdbcRowDataOutputFormat.attemptFlush(JdbcRowDataOutputFormat.java:154) >~[flink-connector-jdbc_2.11-1.11.0.jar:1.11.0] > at >org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat.flush(JdbcBatchingOutputFormat.java:171) >~[flink-connector-jdbc_2.11-1.11.0.jar:1.11.0] > at >org.apache.flink.connector.jdbc.internal.JdbcBatchingOutputFormat.lambda$open$0(JdbcBatchingOutputFormat.java:120) >~[flink-connector-jdbc_2.11-1.11.0.jar:1.11.0] > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) >[?:1.8.0_262] > at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) >[?:1.8.0_262] > at >java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) >[?:1.8.0_262] > at >java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) >[?:1.8.0_262] > at >java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) >[?:1.8.0_262] > at >java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) >[?:1.8.0_262] > at java.lang.Thread.run(Thread.java:748) [?:1.8.0_262] > > > >-- >Sent from: http://apache-flink.147419.n8.nabble.com/
