|
Change Parameter Type taskManagerConfig : RuntimeConfiguration to taskManagerInfo : TaskManagerRuntimeInfo in method public RuntimeEnvironment(jobId JobID, jobVertexId JobVertexID, executionId ExecutionAttemptID, taskName String, taskNameWithSubtasks String, subtaskIndex int, parallelism int, jobConfiguration Configuration, taskConfiguration Configuration, userCodeClassLoader ClassLoader, memManager MemoryManager, ioManager IOManager, bcVarManager BroadcastVariableManager, accumulatorRegistry AccumulatorRegistry, splitProvider InputSplitProvider, distCacheEntries Map<String,Future<Path>>, writers ResultPartitionWriter[], inputGates InputGate[], jobManager ActorGateway, taskManagerInfo TaskManagerRuntimeInfo) in class org.apache.flink.runtime.taskmanager.RuntimeEnvironment |
From |
To |
|
Change Parameter Type taskManagerConfig : RuntimeConfiguration to taskManagerConfig : TaskManagerRuntimeInfo in method public Task(tdd TaskDeploymentDescriptor, memManager MemoryManager, ioManager IOManager, networkEnvironment NetworkEnvironment, bcVarManager BroadcastVariableManager, taskManagerActor ActorGateway, jobManagerActor ActorGateway, actorAskTimeout FiniteDuration, libraryCache LibraryCacheManager, fileCache FileCache, taskManagerConfig TaskManagerRuntimeInfo) in class org.apache.flink.runtime.taskmanager.Task |
From |
To |