Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6189#discussion_r197069574 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java --- @@ -212,6 +271,86 @@ public void shutdown(Time timeout) { executor); } + private interface RequestProcessor<T> { + T createRequest(HttpRequest request, ByteBuf jsonPayload) throws IOException; --- End diff -- Remove this method
---