从oracle同步多个表到doris库中，执行几次之后就卡主不动了

[qf8505]

把两个同步操作对应的create和insert语句放到两个rediskey中，然后main函数中读取，遍历执行sql，代码如下：sqls.stream().forEach(sql->{
System.out.println(sql);
if(sql.indexOf("insert ")>-1||sql.indexOf("INSERT ")>-1){
stmtSet.addInsertSql(sql);
}else{
tenv.executeSql(sql);
}
});
// 批量执行数据保存
stmtSet.execute().print();
env.execute(jobName);，然后这种方式执行两个同步任务，然后成功启动两个job

但是同步两三次以后，同步就不执行了。也不报错，看日志也是在执行


两个sql格式如上图，就是两个create，一个insert into，请问该如何排查，从哪里看起呢？另外这种执行flink任务的方式有没有问题，会不会是两个任务用的同一个jar导致的互相冲突了吗？

[qf8505]

sql如下："CREATE TABLE CLIENT_CONNECT (" +
"ID BIGINT,OPERATION_TIME TIMESTAMP,ACCOUNT_NAME STRING," +
"PRIMARY KEY (OPERATION_ID) NOT ENFORCED) WITH ( " +
"'connector' = 'oracle-cdc', 'hostname' = '192.168.2.3', 'port' = '1521', " +
"'username' = 'dd', 'password' = 'dd', 'database-name' = 'orcl', " +
"'schema-name' = 'DD', 'table-name' = 'CLIENT_CONNECT');\n" +
"CREATE TABLE DSM_EVENT_CLIENT_CONNECT (" +
"OPERATION_ID BIGINT,OPERATION_TIME TIMESTAMP,ACCOUNT_NAME STRING," +
"PRIMARY KEY (ID) NOT ENFORCED) WITH ( 'connector' = 'doris',\n" +
" 'fenodes' = 'd-1:8030',\n" +
" 'table.identifier' = 'd.CLIENT_CONNECT',\n" +
" 'username' = 'root',\n" +
" 'password' = 'root'\n" +
");" +
"insert into T_CLIENT_CONNECT select ID,OPERATION_TIME,ACCOUNT_NAME from CLIENT_CONNECT\n";

[qf8505]

OPERATION_COMMANDS]) (1/1)#0' did not react to cancelling signal - interrupting; it is stuck for 30 seconds in method:
sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1693)
java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)
java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1729)
java.util.concurrent.CompletableFuture.join(CompletableFuture.java:1934)
org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUpInvoke(StreamTask.java:728)
org.apache.flink.streaming.runtime.tasks.SourceStreamTask.cleanUpInvoke(SourceStreamTask.java:186)
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:662)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
java.lang.Thread.run(Thread.java:748)

2022-06-16 20:22:30,130 WARN io.debezium.pipeline.ChangeEventSourceCoordinator [] - Coordinator didn't stop in the expected time, shutting down executor now
2022-06-16 20:22:30,132 ERROR io.debezium.connector.oracle.logminer.LogMinerHelper [] - Mining session stopped due to the java.sql.SQLRecoverableException: IO Error: Socket read interrupted
2022-06-16 20:22:30,132 ERROR io.debezium.pipeline.ErrorHandler [] - Producer failure
java.sql.SQLRecoverableException: IO Error: Socket read interrupted
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:821) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.OracleStatement.executeMaybeDescribe(OracleStatement.java:983) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1168) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3666) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CPreparedStatement.executeInternal(T4CPreparedStatement.java:1426) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.OraclePreparedStatement.executeQuery(OraclePreparedStatement.java:3713) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.OraclePreparedStatementWrapper.executeQuery(OraclePreparedStatementWrapper.java:1167) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:184) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:152) ~[flink-sql-connector-mysql-cdc-2.1.1.jar:2.1.1]
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:119) ~[flink-sql-connector-mysql-cdc-2.1.1.jar:2.1.1]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
Suppressed: java.sql.SQLRecoverableException: Closed Connection
at oracle.jdbc.driver.PhysicalConnection.needLine(PhysicalConnection.java:3525) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.OracleStatement.closeOrCache(OracleStatement.java:1478) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.OracleStatement.close(OracleStatement.java:1461) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.OracleStatementWrapper.close(OracleStatementWrapper.java:122) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.OraclePreparedStatementWrapper.close(OraclePreparedStatementWrapper.java:98) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource.execute(LogMinerStreamingChangeEventSource.java:200) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:152) ~[flink-sql-connector-mysql-cdc-2.1.1.jar:2.1.1]
at io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:119) ~[flink-sql-connector-mysql-cdc-2.1.1.jar:2.1.1]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_231]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_231]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_231]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_231]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_231]
Caused by: java.io.InterruptedIOException: Socket read interrupted
at oracle.net.nt.TimeoutSocketChannel.handleInterrupt(TimeoutSocketChannel.java:258) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.net.nt.TimeoutSocketChannel.read(TimeoutSocketChannel.java:180) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.net.ns.NSProtocolNIO.doSocketRead(NSProtocolNIO.java:555) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.net.ns.NIOPacket.readHeader(NIOPacket.java:258) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.net.ns.NIOPacket.readPacketFromSocketChannel(NIOPacket.java:190) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:132) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.net.ns.NIOPacket.readFromSocketChannel(NIOPacket.java:105) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.net.ns.NIONSDataChannel.readDataFromSocketChannel(NIONSDataChannel.java:91) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.net.ano.CryptoNIONSDataChannel.readDataFromSocketChannel(Unknown Source) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CMAREngineNIO.prepareForUnmarshall(T4CMAREngineNIO.java:764) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CMAREngineNIO.getNBytes(T4CMAREngineNIO.java:578) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CMAREngineNIO.unmarshalNBytes(T4CMAREngineNIO.java:547) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.DynamicByteArray.unmarshalBuffer(DynamicByteArray.java:295) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.DynamicByteArray.unmarshalCLR(DynamicByteArray.java:210) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CMarshaller$BasicMarshaller.unmarshalBytes(T4CMarshaller.java:129) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CMarshaller$BasicMarshaller.unmarshalOneRow(T4CMarshaller.java:108) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CRawAccessor.unmarshalOneRow(T4CRawAccessor.java:197) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CTTIrxd.unmarshal(T4CTTIrxd.java:1594) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CTTIrxd.unmarshal(T4CTTIrxd.java:1313) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4C8Oall.readRXD(T4C8Oall.java:888) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CTTIfun.receive(T4CTTIfun.java:465) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CTTIfun.doRPC(T4CTTIfun.java:268) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4C8Oall.doOALL(T4C8Oall.java:655) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:270) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:91) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:807) ~[flink-sql-connector-oracle-cdc-2.1.1.jar:2.1.1]
... 14 more
2022-06-16 20:22:30,135 INFO io.debezium.connector.oracle.logminer.LogMinerStreamingChangeEventSource [] - startScn=21302381303427, endScn=21302381306359, offsetContext.getScn()=21302381303427
突然发现有这个错误，这是什么原因呢，是这个导致的吗？