Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5430#discussion_r168149188 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/JobTerminationHeaders.java --- @@ -32,7 +32,7 @@ private static final JobTerminationHeaders INSTANCE = new JobTerminationHeaders(); - private JobTerminationHeaders() {} + protected JobTerminationHeaders() {} --- End diff -- I don't think this is needed.
---