We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a26621f commit ecd926aCopy full SHA for ecd926a
chunjun-core/src/main/java/com/dtstack/chunjun/sink/format/BaseRichOutputFormat.java
@@ -551,8 +551,12 @@ public synchronized FormatState getFormatState() throws Exception {
551
"getFormatState:Start preCommit, rowsOfCurrentTransaction: {}",
552
rowsOfCurrentTransaction);
553
preCommit();
554
+ checkTimerWriteException();
555
} catch (Exception e) {
556
LOG.error("preCommit error, e = {}", ExceptionUtil.getErrorMessage(e));
557
+ if (e instanceof NoRestartException) {
558
+ throw e;
559
+ }
560
} finally {
561
flushEnable.compareAndSet(true, false);
562
}
0 commit comments