春秋

确实如此，这个不好修复

发现在任务停止的时候会报错，导致任务保存失败 [Legacy Source Thread - Source: sqlservercdcsourcefactory -> Sink: kafkasinkfactory (1/1)#0] ERROR c.d.f.c.sqlservercdc.inputFormat.SqlServerCdcInputFormat - takeEvent interrupted error:java.lang.InterruptedException at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2088) at java.util.concurrent.LinkedBlockingDeque.pollFirst(LinkedBlockingDeque.java:522) at java.util.concurrent.LinkedBlockingDeque.poll(LinkedBlockingDeque.java:684) at com.dtstack.flinkx.connector.sqlservercdc.inputFormat.SqlServerCdcInputFormat.nextRecordInternal(SqlServerCdcInputFormat.java:127) at com.dtstack.flinkx.source.format.BaseRichInputFormat.nextRecord(BaseRichInputFormat.java:192) at...