hwanju commented on a change in pull request #14499:
URL: https://github.com/apache/flink/pull/14499#discussion_r549124277
##########
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
##########
@@ -869,6 +883,8 @@ private boolean triggerCheckpoint(
"invokable was not in state running.",
checkpointMetaData.getCheckpointId(), getName(), e);
return false;
}
+ } finally {
+
FlinkUserSecurityManager.unmonitorSystemExitForCurrentThread();
}
Review comment:
This is to protect against user-defined checkpoint function, but
couldn't find a fast way to cover this in unit test (other than manual test).
As user-defined checkpoint is unlikely to have exit function, I am fine to
remove this instrumentation, so please let me know.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
