XComp commented on a change in pull request #18536:
URL: https://github.com/apache/flink/pull/18536#discussion_r796555258
##########
File path:
flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherFailoverITCase.java
##########
@@ -109,12 +114,16 @@ public void
testRecoverFromCheckpointAfterJobGraphRemovalOfTerminatedJobFailed()
final JobID jobId = jobGraph.getJobID();
// Construct job graph store.
- final Error jobGraphRemovalError = new Error("Unable to remove job
graph.");
+ final Error temporaryError = new Error("Unable to remove job graph.");
+ final AtomicReference<? extends Error> temporaryErrorRef =
Review comment:
I guess, the initial intention was to have `Error` as the selection
condition in [ExceptionUtils.findThrowable(throwable,
Error.class)](https://github.com/apache/flink/blob/master/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherFailoverITCase.java#L134)
further down in the the test code. I left it like that because it doesn't
cause any harm...
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
