|
Change Parameter Type retriever : JobManagerRetriever to retriever : GatewayRetriever<T> in method public StaticFileServerHandler(retriever GatewayRetriever<T>, localJobManagerAddressPromise CompletableFuture<String>, timeout Time, rootPath File, httpsEnabled boolean) in class org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler |
From |
To |
|
Change Parameter Type retriever : JobManagerRetriever to retriever : GatewayRetriever<JobManagerGateway> in method public RuntimeMonitorHandler(cfg WebMonitorConfig, handler RequestHandler, retriever GatewayRetriever<JobManagerGateway>, localJobManagerAddressFuture CompletableFuture<String>, timeout Time, httpsEnabled boolean) in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler |
From |
To |
|
Change Parameter Type retriever : JobManagerRetriever to retriever : GatewayRetriever<JobManagerGateway> in method public TaskManagerLogHandler(retriever GatewayRetriever<JobManagerGateway>, executor Executor, localJobManagerAddressPromise CompletableFuture<String>, timeout Time, fileMode FileMode, config Configuration, httpsEnabled boolean, blobView BlobView) in class org.apache.flink.runtime.webmonitor.handlers.TaskManagerLogHandler |
From |
To |
|
Change Parameter Type retriever : JobManagerRetriever to retriever : GatewayRetriever<JobManagerGateway> in method public RuntimeMonitorHandlerBase(retriever GatewayRetriever<JobManagerGateway>, localJobManagerAddressFuture CompletableFuture<String>, timeout Time, httpsEnabled boolean) in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandlerBase |
From |
To |
|
Change Parameter Type jobManagerRetriever : JobManagerRetriever to jobManagerRetriever : LeaderGatewayRetriever<JobManagerGateway> in method public WebRuntimeMonitor(config Configuration, leaderRetrievalService LeaderRetrievalService, blobView BlobView, jobManagerRetriever LeaderGatewayRetriever<JobManagerGateway>, queryServiceRetriever MetricQueryServiceRetriever, timeout Time, executor Executor) in class org.apache.flink.runtime.webmonitor.WebRuntimeMonitor |
From |
To |
|
Change Parameter Type jobManagerRetriever : JobManagerRetriever to jobManagerRetriever : LeaderGatewayRetriever<JobManagerGateway> in method public startWebRuntimeMonitor(config Configuration, highAvailabilityServices HighAvailabilityServices, jobManagerRetriever LeaderGatewayRetriever<JobManagerGateway>, queryServiceRetriever MetricQueryServiceRetriever, timeout Time, executor Executor) : WebMonitor in class org.apache.flink.runtime.webmonitor.WebMonitorUtils |
From |
To |
|
Change Parameter Type jobManagerRetriever : JobManagerRetriever to jobManagerRetriever : LeaderGatewayRetriever<JobManagerGateway> in method public startWebMonitorIfConfigured(config Configuration, highAvailabilityServices HighAvailabilityServices, jobManagerRetriever LeaderGatewayRetriever<JobManagerGateway>, queryServiceRetriever MetricQueryServiceRetriever, timeout Time, executor Executor, jobManagerAddress String, logger Logger) : WebMonitor in class org.apache.flink.runtime.clusterframework.BootstrapTools |
From |
To |
|
Change Parameter Type retriever : JobManagerRetriever to retriever : GatewayRetriever<JobManagerGateway> in method public MetricFetcher(retriever GatewayRetriever<JobManagerGateway>, queryServiceRetriever MetricQueryServiceRetriever, executor Executor, timeout Time) in class org.apache.flink.runtime.webmonitor.metrics.MetricFetcher |
From |
To |
|
Change Parameter Type retriever : JobManagerRetriever to retriever : GatewayRetriever<T> in method public StaticFileServerHandler(retriever GatewayRetriever<T>, localJobManagerAddressFuture CompletableFuture<String>, timeout Time, rootPath File, httpsEnabled boolean, logger Logger) in class org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler |
From |
To |
|
Change Parameter Type retriever : AkkaJobManagerRetriever to retriever : GatewayRetriever<JobManagerGateway> in method private waitForLeaderNotification(expectedJobManagerURL String, retriever GatewayRetriever<JobManagerGateway>, deadline Deadline) : void in class org.apache.flink.runtime.webmonitor.WebRuntimeMonitorITCase |
From |
To |
|
Rename Variable redirectingAddress : String to optRedirectingAddress : Optional<CompletableFuture<String>> in method public testGetRedirectAddressWithRemoteAkkaPath() : void in class org.apache.flink.runtime.webmonitor.handlers.HandlerRedirectUtilsTest |
From |
To |
|
Rename Variable optJobManagerGateway : Optional<JobManagerGateway> to optLeader : Optional<T> in method public channelRead0(ctx ChannelHandlerContext, routed Routed) : void in class org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler |
From |
To |
|
Rename Variable redirectAddress : String to optRedirectAddress : Optional<CompletableFuture<String>> in method protected channelRead0(ctx ChannelHandlerContext, routed Routed) : void in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandlerBase |
From |
To |
|
Rename Variable redirectAddress : String to optRedirectAddress : Optional<CompletableFuture<String>> in method public channelRead0(ctx ChannelHandlerContext, routed Routed) : void in class org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler |
From |
To |
|
Change Variable Type redirectingAddress : String to redirectingAddress : Optional<CompletableFuture<String>> in method public testGetRedirectAddressWithLocalAkkaPath() : void in class org.apache.flink.runtime.webmonitor.handlers.HandlerRedirectUtilsTest |
From |
To |
|
Change Variable Type redirectAddress : String to optRedirectAddress : Optional<CompletableFuture<String>> in method public channelRead0(ctx ChannelHandlerContext, routed Routed) : void in class org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler |
From |
To |
|
Change Variable Type optJobManagerGateway : Optional<JobManagerGateway> to optLeader : Optional<T> in method public channelRead0(ctx ChannelHandlerContext, routed Routed) : void in class org.apache.flink.runtime.webmonitor.files.StaticFileServerHandler |
From |
To |
|
Change Variable Type redirectAddress : String to optRedirectAddress : Optional<CompletableFuture<String>> in method protected channelRead0(ctx ChannelHandlerContext, routed Routed) : void in class org.apache.flink.runtime.webmonitor.RuntimeMonitorHandlerBase |
From |
To |
|
Change Variable Type retriever : AkkaJobManagerRetriever to retriever : GatewayRetriever<JobManagerGateway> in method public testUpdate() : void in class org.apache.flink.runtime.webmonitor.metrics.MetricFetcherTest |
From |
To |
|
Change Variable Type redirectingAddress : String to optRedirectingAddress : Optional<CompletableFuture<String>> in method public testGetRedirectAddressWithRemoteAkkaPath() : void in class org.apache.flink.runtime.webmonitor.handlers.HandlerRedirectUtilsTest |
From |
To |