Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4767#discussion_r142633088
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractRestHandler.java
---
@@ -157,7 +160,12 @@ protected void respondAsLeader(final
ChannelHandlerContext ctx, Routed routed, T
HandlerUtils.sendErrorResponse(ctx, httpRequest, new
ErrorResponseBody("Internal server error."),
HttpResponseStatus.INTERNAL_SERVER_ERROR);
}
} else {
- HandlerUtils.sendResponse(ctx,
httpRequest, resp, messageHeaders.getResponseStatusCode());
+ if (resp instanceof
WebSocketUpgradeResponseBody) {
+ upgradeToWebSocket(ctx, routed,
(WebSocketUpgradeResponseBody) resp);
--- End diff --
help me out here. After the upgrade is complete, which parts of the
AbstractRestHandler class are still used?
---
