Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4601#discussion_r139684288
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherRestEndpoint.java
---
@@ -77,8 +74,11 @@ protected void setupChannelHandlers(Router router,
CompletableFuture<String> res
optWebContent = Optional.empty();
}
- optWebContent.ifPresent(
- webContentHandler -> router.GET("/:*",
webContentHandler));
+ return optWebContent
+ .map(webContent ->
+ Collections.singleton(
+ Tuple2.<RestHandlerSpecification,
ChannelInboundHandler>of(WebContentHandlerSpecification.getInstance(),
webContent)))
+ .orElseGet(() -> Collections.emptySet());
--- End diff --
sure
---
