|
Change Parameter Type request : HandlerRequest<EmptyRequestBody,JobTerminationMessageParameters> to request : HandlerRequest<EmptyRequestBody,JobCancellationMessageParameters> in method public handleRequest(request HandlerRequest<EmptyRequestBody,JobCancellationMessageParameters>, gateway RestfulGateway) : CompletableFuture<EmptyResponseBody> in class org.apache.flink.runtime.rest.handler.job.JobCancellationHandler |
From |
To |
|
Change Parameter Type request : HandlerRequest<EmptyRequestBody,JobTerminationMessageParameters> to request : HandlerRequest<EmptyRequestBody,JobCancellationMessageParameters> in method protected handleRequest(request HandlerRequest<EmptyRequestBody,JobCancellationMessageParameters>, gateway DispatcherGateway) : CompletableFuture<EmptyResponseBody> in class org.apache.flink.client.program.rest.RestClusterClientTest.TestJobCancellationHandler |
From |
To |
|
Change Parameter Type messageHeaders : MessageHeaders<EmptyRequestBody,EmptyResponseBody,JobTerminationMessageParameters> to messageHeaders : MessageHeaders<EmptyRequestBody,EmptyResponseBody,JobCancellationMessageParameters> in method public JobCancellationHandler(leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, headers Map<String,String>, messageHeaders MessageHeaders<EmptyRequestBody,EmptyResponseBody,JobCancellationMessageParameters>, defaultTerminationMode TerminationModeQueryParameter.TerminationMode) in class org.apache.flink.runtime.rest.handler.job.JobCancellationHandler |
From |
To |
|
Change Variable Type operator : StoppableStreamSource<String,InfiniteSource<String>> to operator : StreamSource<String,InfiniteSource<String>> in method public testAutomaticWatermarkContext() : void in class org.apache.flink.streaming.runtime.operators.StreamSourceOperatorWatermarksTest |
From |
To |
|
Change Variable Type jobStopTerminationHandler : JobTerminationHandler to jobStopTerminationHandler : JobCancellationHandler in method protected initializeHandlers(localAddressFuture CompletableFuture<String>) : List<Tuple2<RestHandlerSpecification,ChannelInboundHandler>> in class org.apache.flink.runtime.webmonitor.WebMonitorEndpoint |
From |
To |
|
Change Variable Type jobCancelTerminationHandler : JobTerminationHandler to jobCancelTerminationHandler : JobCancellationHandler in method protected initializeHandlers(localAddressFuture CompletableFuture<String>) : List<Tuple2<RestHandlerSpecification,ChannelInboundHandler>> in class org.apache.flink.runtime.webmonitor.WebMonitorEndpoint |
From |
To |
|
Change Variable Type terminationHandler : TestJobTerminationHandler to terminationHandler : TestJobCancellationHandler in method public testJobSubmitCancel() : void in class org.apache.flink.client.program.rest.RestClusterClientTest |
From |
To |
|
Change Variable Type params : JobTerminationMessageParameters to params : JobCancellationMessageParameters in method public cancel(jobID JobID) : void in class org.apache.flink.client.program.rest.RestClusterClient |
From |
To |