|
Change Parameter Type messageHeaders : MessageHeaders<EmptyRequestBody,JobAccumulatorsInfo,JobMessageParameters> to messageHeaders : MessageHeaders<EmptyRequestBody,JobAccumulatorsInfo,JobAccumulatorsMessageParameters> in method public JobAccumulatorsHandler(localRestAddress CompletableFuture<String>, leaderRetriever GatewayRetriever<? extends RestfulGateway>, timeout Time, responseHeaders Map<String,String>, messageHeaders MessageHeaders<EmptyRequestBody,JobAccumulatorsInfo,JobAccumulatorsMessageParameters>, executionGraphCache ExecutionGraphCache, executor Executor) in class org.apache.flink.runtime.rest.handler.job.JobAccumulatorsHandler |
From |
To |