Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4699#discussion_r141316258
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractRestHandler.java
---
@@ -117,11 +117,26 @@ protected void respondAsLeader(final
ChannelHandlerContext ctx, Routed routed, T
}
}
+ final HandlerRequest<R, M> handlerRequest;
+
+ try {
+ handlerRequest = new HandlerRequest<>(request,
messageHeaders.getUnresolvedMessageParameters(), routed.pathParams(),
routed.queryParams());
+ } catch (HandlerRequestException hre) {
+ log.error("Could not create the handler
request.", hre);
+
+ HandlerUtils.sendErrorResponse(
+ ctx,
+ httpRequest,
+ new
ErrorResponseBody(String.format("Could not create the handler request: %s",
hre.getMessage())),
--- End diff --
Sure, can change this.
---
