|
Change Parameter Type leaderRetriever : GatewayRetriever<? extends RestfulGateway> to leaderRetriever : GatewayRetriever<? extends DispatcherGateway> in method public WebSubmissionExtension(configuration Configuration, restAddressFuture CompletableFuture<String>, leaderRetriever GatewayRetriever<? extends DispatcherGateway>, responseHeaders Map<String,String>, jarDir Path, executor Executor, timeout Time) in class org.apache.flink.runtime.webmonitor.WebSubmissionExtension |
From |
To |
|
Change Parameter Type leaderRetriever : GatewayRetriever<? extends RestfulGateway> to leaderRetriever : GatewayRetriever<? extends DispatcherGateway> in method public JarRunHandler(localRestAddress CompletableFuture<String>, leaderRetriever GatewayRetriever<? extends DispatcherGateway>, timeout Time, responseHeaders Map<String,String>, messageHeaders MessageHeaders<EmptyRequestBody,JarRunResponseBody,JarRunMessageParameters>, jarDir Path, configuration Configuration, executor Executor) in class org.apache.flink.runtime.webmonitor.handlers.JarRunHandler |
From |
To |
|
Change Parameter Type leaderRetriever : GatewayRetriever<? extends RestfulGateway> to leaderRetriever : GatewayRetriever<? extends DispatcherGateway> in method public loadWebSubmissionExtension(leaderRetriever GatewayRetriever<? extends DispatcherGateway>, restAddressFuture CompletableFuture<String>, timeout Time, responseHeaders Map<String,String>, uploadDir Path, executor Executor, configuration Configuration) : WebMonitorExtension in class org.apache.flink.runtime.webmonitor.WebMonitorUtils |
From |
To |
|
Change Parameter Type gateway : RestfulGateway to gateway : DispatcherGateway in method protected handleRequest(request HandlerRequest<EmptyRequestBody,JarRunMessageParameters>, gateway DispatcherGateway) : CompletableFuture<JarRunResponseBody> in class org.apache.flink.runtime.webmonitor.handlers.JarRunHandler |
From |
To |