Skip to content

Commit b7236a8

Browse files
committed
[hotfix-1772][rdb] 调整rdb errorLimit初始值,当出现脏数据,任务立即停止.
1 parent 1f7b2aa commit b7236a8

File tree

1 file changed

+0
-17
lines changed

1 file changed

+0
-17
lines changed

core/src/main/java/com/dtstack/flink/sql/exception/ExceptionTrace.java

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -20,21 +20,4 @@ public static String traceOriginalCause(Throwable e) {
2020
}
2121
return errorMsg;
2222
}
23-
24-
/**
25-
* 根据异常的种类来判断是否需要强制跳过Flink的重启{@link SuppressRestartsException}
26-
* @param e exception
27-
* @param errorMsg 需要抛出的异常信息
28-
*/
29-
public static void dealExceptionWithSuppressStart(Exception e, String errorMsg) {
30-
if (e instanceof SuppressRestartsException) {
31-
throw new SuppressRestartsException(
32-
new Throwable(
33-
errorMsg
34-
)
35-
);
36-
} else {
37-
throw new RuntimeException(errorMsg);
38-
}
39-
}
4023
}

0 commit comments

Comments
 (0)