Skip to content

Commit 49c27a8

Browse files
authored
[Bug] CheckPoint Failure Options alert not work in specific situation (#4256)
1 parent 9738a5d commit 49c27a8

1 file changed

Lines changed: 6 additions & 5 deletions

File tree

streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/component/FlinkCheckpointProcessor.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -111,14 +111,15 @@ private void processFailedCheckpoint(
111111
FlinkApplication application, @Nonnull CheckPoints.CheckPoint checkPoint,
112112
Long appId) {
113113
Counter counter = checkPointFailedCache.get(appId);
114-
if (counter == null) {
115-
checkPointFailedCache.put(appId, new Counter(checkPoint.getTriggerTimestamp()));
114+
Long ckTriggerTimestamp = checkPoint.getTriggerTimestamp();
115+
Integer cpFailureRateInterval = application.getCpFailureRateInterval();
116+
if (counter == null || counter.getDuration(ckTriggerTimestamp) >= cpFailureRateInterval) {
117+
checkPointFailedCache.put(appId, new Counter(ckTriggerTimestamp));
116118
return;
117119
}
118120

119-
long minute = counter.getDuration(checkPoint.getTriggerTimestamp());
120-
if (minute > application.getCpFailureRateInterval()
121-
|| counter.getCount() < application.getCpMaxFailureInterval()) {
121+
long minute = counter.getDuration(ckTriggerTimestamp);
122+
if (minute > cpFailureRateInterval || counter.getCount() < application.getCpMaxFailureInterval()) {
122123
counter.increment();
123124
return;
124125
}

0 commit comments

Comments
 (0)