|
Change Parameter Type accumulatorMap : Map<String,Accumulator<?,?>> to accumulatorMap : Map<String,OptionalFailure<Accumulator<?,?>>> in method private checkUserAccumulators(expected int, accumulatorMap Map<String,OptionalFailure<Accumulator<?,?>>>) : boolean in class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase |
From |
To |
|
Change Parameter Type serializedUserAccumulators : Map<String,SerializedValue<Object>> to serializedUserAccumulators : Map<String,SerializedValue<OptionalFailure<Object>>> in method public JobAccumulatorsInfo(jobAccumulators List<JobAccumulator>, userAccumulators List<UserTaskAccumulator>, serializedUserAccumulators Map<String,SerializedValue<OptionalFailure<Object>>>) in class org.apache.flink.runtime.rest.messages.JobAccumulatorsInfo |
From |
To |
|
Change Parameter Type accumulatorResults : Map<String,SerializedValue<Object>> to accumulatorResults : Map<String,SerializedValue<OptionalFailure<Object>>> in method public accumulatorResults(accumulatorResults Map<String,SerializedValue<OptionalFailure<Object>>>) : Builder in class org.apache.flink.runtime.jobmaster.JobResult.Builder |
From |
To |
|
Change Parameter Type serializedUserAccumulators : Map<String,SerializedValue<Object>> to serializedUserAccumulators : Map<String,SerializedValue<OptionalFailure<Object>>> in method public setSerializedUserAccumulators(serializedUserAccumulators Map<String,SerializedValue<OptionalFailure<Object>>>) : ArchivedExecutionGraphBuilder in class org.apache.flink.runtime.rest.handler.legacy.utils.ArchivedExecutionGraphBuilder |
From |
To |
|
Change Parameter Type accumulators : Map<String,SerializedValue<Object>> to accumulators : Map<String,SerializedValue<OptionalFailure<Object>>> in method public SerializedJobExecutionResult(jobID JobID, netRuntime long, accumulators Map<String,SerializedValue<OptionalFailure<Object>>>) in class org.apache.flink.runtime.client.SerializedJobExecutionResult |
From |
To |
|
Change Parameter Type accumulatorResults : Map<String,SerializedValue<Object>> to accumulatorResults : Map<String,SerializedValue<OptionalFailure<Object>>> in method private JobResult(jobId JobID, accumulatorResults Map<String,SerializedValue<OptionalFailure<Object>>>, netRuntime long, serializedThrowable SerializedThrowable) in class org.apache.flink.runtime.jobmaster.JobResult |
From |
To |
|
Change Parameter Type archivedAccs : Map<String,SerializedValue<Object>> to archivedAccs : Map<String,SerializedValue<OptionalFailure<Object>>> in method private compareSerializedAccumulators(runtimeAccs Map<String,SerializedValue<OptionalFailure<Object>>>, archivedAccs Map<String,SerializedValue<OptionalFailure<Object>>>) : void in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraphTest |
From |
To |
|
Change Parameter Type accumulators : Map<String,Object> to accumulators : Map<String,OptionalFailure<Object>> in method public JobExecutionResult(jobID JobID, netRuntime long, accumulators Map<String,OptionalFailure<Object>>) in class org.apache.flink.api.common.JobExecutionResult |
From |
To |
|
Change Parameter Type serializedUserAccumulators : Map<String,SerializedValue<Object>> to serializedUserAccumulators : Map<String,SerializedValue<OptionalFailure<Object>>> in method public ArchivedExecutionGraph(jobID JobID, jobName String, tasks Map<JobVertexID,ArchivedExecutionJobVertex>, verticesInCreationOrder List<ArchivedExecutionJobVertex>, stateTimestamps long[], state JobStatus, failureCause ErrorInfo, jsonPlan String, archivedUserAccumulators StringifiedAccumulatorResult[], serializedUserAccumulators Map<String,SerializedValue<OptionalFailure<Object>>>, executionConfig ArchivedExecutionConfig, isStoppable boolean, jobCheckpointingConfiguration CheckpointCoordinatorConfiguration, checkpointStatsSnapshot CheckpointStatsSnapshot) in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph |
From |
To |
|
Change Parameter Type runtimeAccs : Map<String,SerializedValue<Object>> to runtimeAccs : Map<String,SerializedValue<OptionalFailure<Object>>> in method private compareSerializedAccumulators(runtimeAccs Map<String,SerializedValue<OptionalFailure<Object>>>, archivedAccs Map<String,SerializedValue<OptionalFailure<Object>>>) : void in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraphTest |
From |
To |
|
Change Parameter Type serializedAccumulators : Map<String,SerializedValue<Object>> to serializedAccumulators : Map<String,SerializedValue<OptionalFailure<Object>>> in method public deserializeAccumulators(serializedAccumulators Map<String,SerializedValue<OptionalFailure<Object>>>, loader ClassLoader) : Map<String,OptionalFailure<Object>> in class org.apache.flink.api.common.accumulators.AccumulatorHelper |
From |
To |
|
Change Parameter Type accs : Map<String,Accumulator<?,?>> to accs : Map<String,OptionalFailure<Accumulator<?,?>>> in method public stringifyAccumulatorResults(accs Map<String,OptionalFailure<Accumulator<?,?>>>) : StringifiedAccumulatorResult[] in class org.apache.flink.runtime.accumulators.StringifiedAccumulatorResult |
From |
To |
|
Change Return Type Map<String,Object> to Map<String,OptionalFailure<Object>> in method public deserializeAccumulators(serializedAccumulators Map<String,SerializedValue<OptionalFailure<Object>>>, loader ClassLoader) : Map<String,OptionalFailure<Object>> in class org.apache.flink.api.common.accumulators.AccumulatorHelper |
From |
To |
|
Change Return Type Map<String,Object> to Map<String,OptionalFailure<Object>> in method public getAccumulators(jobID JobID, loader ClassLoader) : Map<String,OptionalFailure<Object>> in class org.apache.flink.client.program.MiniClusterClient |
From |
To |
|
Change Return Type Map<String,Object> to Map<String,OptionalFailure<Object>> in method public getAccumulators(jobID JobID, loader ClassLoader) : Map<String,OptionalFailure<Object>> in class org.apache.flink.client.program.rest.RestClusterClient |
From |
To |
|
Change Return Type Map<String,SerializedValue<Object>> to Map<String,SerializedValue<OptionalFailure<Object>>> in method private parseAccumulatorResults(p JsonParser, ctxt DeserializationContext) : Map<String,SerializedValue<OptionalFailure<Object>>> in class org.apache.flink.runtime.rest.messages.json.JobResultDeserializer |
From |
To |
|
Change Return Type Map<String,Accumulator<?,?>> to Map<String,OptionalFailure<Accumulator<?,?>>> in method public aggregateUserAccumulators() : Map<String,OptionalFailure<Accumulator<?,?>>> in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Return Type Map<String,SerializedValue<Object>> to Map<String,SerializedValue<OptionalFailure<Object>>> in method public getAccumulatorResults() : Map<String,SerializedValue<OptionalFailure<Object>>> in class org.apache.flink.runtime.jobmaster.JobResult |
From |
To |
|
Change Return Type Map<String,SerializedValue<Object>> to Map<String,SerializedValue<OptionalFailure<Object>>> in method public getAccumulatorsSerialized() : Map<String,SerializedValue<OptionalFailure<Object>>> in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Return Type void to Accumulator<V,R> in method private mergeSingle(target Accumulator<?,?>, toMerge Accumulator<?,?>) : Accumulator<V,R> in class org.apache.flink.api.common.accumulators.AccumulatorHelper |
From |
To |
|
Change Return Type Map<String,Object> to Map<String,OptionalFailure<Object>> in method public getAccumulators(jobID JobID) : Map<String,OptionalFailure<Object>> in class org.apache.flink.client.program.ClusterClient |
From |
To |
|
Change Return Type Map<String,Object> to Map<String,OptionalFailure<Object>> in method public getAccumulators(jobID JobID, loader ClassLoader) : Map<String,OptionalFailure<Object>> in class org.apache.flink.client.program.ClusterClient |
From |
To |
|
Change Return Type Map<String,SerializedValue<Object>> to Map<String,SerializedValue<OptionalFailure<Object>>> in method public getSerializedUserAccumulators() : Map<String,SerializedValue<OptionalFailure<Object>>> in class org.apache.flink.runtime.rest.messages.JobAccumulatorsInfo |
From |
To |
|
Change Return Type Map<String,SerializedValue<Object>> to Map<String,SerializedValue<OptionalFailure<Object>>> in method public getAccumulatorsSerialized() : Map<String,SerializedValue<OptionalFailure<Object>>> in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph |
From |
To |
|
Change Return Type Map<String,Object> to Map<String,OptionalFailure<Object>> in method public toResultMap(accumulators Map<String,Accumulator<?,?>>) : Map<String,OptionalFailure<Object>> in class org.apache.flink.api.common.accumulators.AccumulatorHelper |
From |
To |
|
Change Return Type Map<String,SerializedValue<Object>> to Map<String,SerializedValue<OptionalFailure<Object>>> in method public getSerializedAccumulatorResults() : Map<String,SerializedValue<OptionalFailure<Object>>> in class org.apache.flink.runtime.client.SerializedJobExecutionResult |
From |
To |
|
Change Return Type Map<String,Object> to Map<String,OptionalFailure<Object>> in method public getAccumulators(jobID JobID) : Map<String,OptionalFailure<Object>> in class org.apache.flink.client.program.MiniClusterClient |
From |
To |
|
Change Return Type Map<String,SerializedValue<Object>> to Map<String,SerializedValue<OptionalFailure<Object>>> in method public getAccumulatorsSerialized() : Map<String,SerializedValue<OptionalFailure<Object>>> in class org.apache.flink.runtime.executiongraph.AccessExecutionGraph |
From |
To |
|
Change Variable Type serializedUserTaskAccumulators : Map<String,SerializedValue<Object>> to serializedUserTaskAccumulators : Map<String,SerializedValue<OptionalFailure<Object>>> in method protected handleRequest(request HandlerRequest<EmptyRequestBody,JobAccumulatorsMessageParameters>, gateway DispatcherGateway) : CompletableFuture<JobAccumulatorsInfo> in class org.apache.flink.client.program.rest.RestClusterClientTest.TestAccumulatorHandler |
From |
To |
|
Change Variable Type serializedAccumulators : Map<String,SerializedValue<Object>> to serializedAccumulators : Map<String,SerializedValue<OptionalFailure<Object>>> in method public getAccumulators(jobID JobID, loader ClassLoader) : Map<String,OptionalFailure<Object>> in class org.apache.flink.client.program.ClusterClient |
From |
To |
|
Change Variable Type serializedUserAccumulators : Map<String,SerializedValue<Object>> to serializedUserAccumulators : Map<String,SerializedValue<OptionalFailure<Object>>> in method public createFrom(executionGraph ExecutionGraph) : ArchivedExecutionGraph in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraph |
From |
To |
|
Change Variable Type origMap : Map<String,SerializedValue<Object>> to origMap : Map<String,SerializedValue<OptionalFailure<Object>>> in method public testSerialization() : void in class org.apache.flink.runtime.client.SerializedJobExecutionResultTest |
From |
To |
|
Change Variable Type accumulatorMap : Map<String,Accumulator<?,?>> to accumulatorMap : Map<String,OptionalFailure<Accumulator<?,?>>> in method public stringifyingResultsShouldReportNullAccumulatorWithNonnullValueAndTypeString() : void in class org.apache.flink.runtime.accumulators.StringifiedAccumulatorResultTest |
From |
To |
|
Change Variable Type accumulators : Map<String,Object> to accumulators : Map<String,OptionalFailure<Object>> in method public deserializeAccumulators(serializedAccumulators Map<String,SerializedValue<OptionalFailure<Object>>>, loader ClassLoader) : Map<String,OptionalFailure<Object>> in class org.apache.flink.api.common.accumulators.AccumulatorHelper |
From |
To |
|
Change Variable Type accumulatorResults : Map<String,SerializedValue<Object>> to accumulatorResults : Map<String,SerializedValue<OptionalFailure<Object>>> in method public serialize(result JobResult, gen JsonGenerator, provider SerializerProvider) : void in class org.apache.flink.runtime.rest.messages.json.JobResultSerializer |
From |
To |
|
Change Variable Type accumulatorMap : Map<String,Accumulator<?,?>> to accumulatorMap : Map<String,OptionalFailure<Accumulator<?,?>>> in method public stringifyingResultsShouldReportNullLocalValueAsNonnullValueString() : void in class org.apache.flink.runtime.accumulators.StringifiedAccumulatorResultTest |
From |
To |
|
Change Variable Type userAccumulators : Map<String,Accumulator<?,?>> to userAccumulators : Map<String,OptionalFailure<Accumulator<?,?>>> in method public testHandleRequest() : void in class org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptAccumulatorsHandlerTest |
From |
To |
|
Change Variable Type userAccumulators : Map<String,Accumulator<?,?>> to userAccumulators : Map<String,OptionalFailure<Accumulator<?,?>>> in method public aggregateUserAccumulators() : Map<String,OptionalFailure<Accumulator<?,?>>> in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Variable Type accumulatorResults : Map<String,SerializedValue<Object>> to accumulatorResults : Map<String,SerializedValue<OptionalFailure<Object>>> in method public deserialize(p JsonParser, ctxt DeserializationContext) : JobResult in class org.apache.flink.runtime.rest.messages.json.JobResultDeserializer |
From |
To |
|
Change Variable Type serializedUserTaskAccumulators : Map<String,SerializedValue<Object>> to serializedUserTaskAccumulators : Map<String,SerializedValue<OptionalFailure<Object>>> in method protected handleRequest(request HandlerRequest<EmptyRequestBody,JobAccumulatorsMessageParameters>, graph AccessExecutionGraph) : JobAccumulatorsInfo in class org.apache.flink.runtime.rest.handler.job.JobAccumulatorsHandler |
From |
To |
|
Change Variable Type value : Object to value : OptionalFailure<Object> in method public deserializeAccumulators(serializedAccumulators Map<String,SerializedValue<OptionalFailure<Object>>>, loader ClassLoader) : Map<String,OptionalFailure<Object>> in class org.apache.flink.api.common.accumulators.AccumulatorHelper |
From |
To |
|
Change Variable Type result : Map<String,Object> to result : Map<String,OptionalFailure<Object>> in method public getAccumulators(jobID JobID, loader ClassLoader) : Map<String,OptionalFailure<Object>> in class org.apache.flink.client.program.rest.RestClusterClient |
From |
To |
|
Change Variable Type accumulators : Map<String,Object> to accumulators : Map<String,OptionalFailure<Object>> in method protected executeAndSavepoint(env StreamExecutionEnvironment, savepointPath String, expectedAccumulators Tuple2<String,Integer>...) : void in class org.apache.flink.test.checkpointing.utils.SavepointMigrationTestBase |
From |
To |
|
Change Variable Type entry : Map.Entry<String,SerializedValue<Object>> to entry : Map.Entry<String,SerializedValue<OptionalFailure<Object>>> in method public deserializeAccumulators(serializedAccumulators Map<String,SerializedValue<OptionalFailure<Object>>>, loader ClassLoader) : Map<String,OptionalFailure<Object>> in class org.apache.flink.api.common.accumulators.AccumulatorHelper |
From |
To |
|
Change Variable Type userAccumulators : Map<String,Accumulator<?,?>> to userAccumulators : Map<String,OptionalFailure<Accumulator<?,?>>> in method public getAggregatedUserAccumulatorsStringified() : StringifiedAccumulatorResult[] in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex |
From |
To |
|
Change Variable Type accumulators : Map<String,Object> to accumulators : Map<String,OptionalFailure<Object>> in method protected restoreAndExecute(env StreamExecutionEnvironment, savepointPath String, expectedAccumulators Tuple2<String,Integer>...) : void in class org.apache.flink.test.checkpointing.utils.SavepointMigrationTestBase |
From |
To |
|
Change Variable Type value : Object to value : OptionalFailure<Object> in method public testSerialization() : void in class org.apache.flink.runtime.client.SerializedJobExecutionResultTest |
From |
To |
|
Change Variable Type accumulatorMap : Map<String,Accumulator<?,?>> to accumulatorMap : Map<String,OptionalFailure<Accumulator<?,?>>> in method public stringifyingResultsShouldIncorporateAccumulatorLocalValueDirectly() : void in class org.apache.flink.runtime.accumulators.StringifiedAccumulatorResultTest |
From |
To |
|
Change Variable Type accumulatorsSerialized : Map<String,SerializedValue<Object>> to accumulatorsSerialized : Map<String,SerializedValue<OptionalFailure<Object>>> in method public getAccumulators(jobID JobID, loader ClassLoader) : Map<String,OptionalFailure<Object>> in class org.apache.flink.client.program.MiniClusterClient |
From |
To |
|
Change Variable Type accumulatorResults : Map<String,SerializedValue<Object>> to accumulatorResults : Map<String,SerializedValue<OptionalFailure<Object>>> in method private parseAccumulatorResults(p JsonParser, ctxt DeserializationContext) : Map<String,SerializedValue<OptionalFailure<Object>>> in class org.apache.flink.runtime.rest.messages.json.JobResultDeserializer |
From |
To |
|
Change Variable Type accumulatorMap : Map<String,Accumulator<?,?>> to accumulatorMap : Map<String,OptionalFailure<Accumulator<?,?>>> in method public getAccumulatorResultsStringified() : StringifiedAccumulatorResult[] in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Variable Type result : Map<String,Object> to result : Map<String,OptionalFailure<Object>> in method public getAccumulators(jobID JobID, loader ClassLoader) : Map<String,OptionalFailure<Object>> in class org.apache.flink.client.program.MiniClusterClient |
From |
To |
|
Change Variable Type numFinished : Integer to numFinished : OptionalFailure<Object> in method protected restoreAndExecute(env StreamExecutionEnvironment, savepointPath String, expectedAccumulators Tuple2<String,Integer>...) : void in class org.apache.flink.test.checkpointing.utils.SavepointMigrationTestBase |
From |
To |
|
Change Variable Type runtimeAcc : Map.Entry<String,SerializedValue<Object>> to runtimeAcc : Entry<String,SerializedValue<OptionalFailure<Object>>> in method private compareSerializedAccumulators(runtimeAccs Map<String,SerializedValue<OptionalFailure<Object>>>, archivedAccs Map<String,SerializedValue<OptionalFailure<Object>>>) : void in class org.apache.flink.runtime.executiongraph.ArchivedExecutionGraphTest |
From |
To |
|
Change Variable Type entry : Map.Entry<String,SerializedValue<Object>> to entry : Map.Entry<String,SerializedValue<OptionalFailure<Object>>> in method public testSerialization() : void in class org.apache.flink.runtime.client.SerializedJobExecutionResultTest |
From |
To |
|
Change Variable Type accumulatorResults : Map<String,Object> to accumulatorResults : Map<String,OptionalFailure<Object>> in method public execute(program Plan) : JobExecutionResult in class org.apache.flink.api.common.operators.CollectionExecutor |
From |
To |
|
Change Variable Type nameValue : Map.Entry<String,SerializedValue<Object>> to nameValue : Map.Entry<String,SerializedValue<OptionalFailure<Object>>> in method public serialize(result JobResult, gen JsonGenerator, provider SerializerProvider) : void in class org.apache.flink.runtime.rest.messages.json.JobResultSerializer |
From |
To |
|
Change Variable Type accumulators : Map<String,Object> to accumulators : Map<String,OptionalFailure<Object>> in method public testGetAccumulators() : void in class org.apache.flink.client.program.rest.RestClusterClientTest |
From |
To |
|
Change Variable Type acc : Map.Entry<String,SerializedValue<Object>> to acc : Map.Entry<String,SerializedValue<OptionalFailure<Object>>> in method public getAccumulators(jobID JobID, loader ClassLoader) : Map<String,OptionalFailure<Object>> in class org.apache.flink.client.program.MiniClusterClient |
From |
To |
|
Change Variable Type resultMap : Map<String,Object> to resultMap : Map<String,OptionalFailure<Object>> in method public toResultMap(accumulators Map<String,Accumulator<?,?>>) : Map<String,OptionalFailure<Object>> in class org.apache.flink.api.common.accumulators.AccumulatorHelper |
From |
To |
|
Change Variable Type userAccumulators : Map<String,Accumulator<?,?>> to userAccumulators : Map<String,OptionalFailure<Accumulator<?,?>>> in method private verifyResults() : void in class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase |
From |
To |
|
Change Variable Type entry : Map.Entry<String,Accumulator<?,?>> to entry : Map.Entry<String,OptionalFailure<Accumulator<?,?>>> in method public stringifyAccumulatorResults(accs Map<String,OptionalFailure<Accumulator<?,?>>>) : StringifiedAccumulatorResult[] in class org.apache.flink.runtime.accumulators.StringifiedAccumulatorResult |
From |
To |
|
Change Variable Type accumulators : Map<String,Object> to accumulators : Map<String,OptionalFailure<Object>> in method public toJobExecutionResult(loader ClassLoader) : JobExecutionResult in class org.apache.flink.runtime.client.SerializedJobExecutionResult |
From |
To |