|
Change Parameter Type localRecoveryMode : LocalRecoveryConfig.LocalRecoveryMode to localRecoveryEnabled : boolean in method public TaskExecutorLocalStateStoresManager(localRecoveryEnabled boolean, localStateRootDirectories File[], discardExecutor Executor) in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |
|
Change Parameter Type recoveryMode : LocalRecoveryMode to localRecoveryEnabled : boolean in method package AbstractLocalRecoveryITCase(backendEnum StateBackendEnum, localRecoveryEnabled boolean) in class org.apache.flink.test.checkpointing.AbstractLocalRecoveryITCase |
From |
To |
|
Change Parameter Type localRecoveryMode : LocalRecoveryConfig.LocalRecoveryMode to localRecoveryEnabled : boolean in method public TaskManagerServicesConfiguration(taskManagerAddress InetAddress, tmpDirPaths String[], localRecoveryStateRootDirectories String[], localRecoveryEnabled boolean, networkConfig NetworkEnvironmentConfiguration, queryableStateConfig QueryableStateConfiguration, numberOfSlots int, configuredMemory long, memoryType MemoryType, preAllocateMemory boolean, memoryFraction float, timerServiceShutdownTimeout long) in class org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration |
From |
To |
|
Change Parameter Type localRecoveryMode : LocalRecoveryMode to localRecoveryEnabled : boolean in method public LocalRecoveryConfig(localRecoveryEnabled boolean, directoryProvider LocalRecoveryDirectoryProvider) in class org.apache.flink.runtime.state.LocalRecoveryConfig |
From |
To |
|
Rename Parameter localRecoveryMode : LocalRecoveryMode to localRecoveryEnabled : boolean in method public LocalRecoveryConfig(localRecoveryEnabled boolean, directoryProvider LocalRecoveryDirectoryProvider) in class org.apache.flink.runtime.state.LocalRecoveryConfig |
From |
To |
|
Rename Parameter localRecoveryMode : LocalRecoveryConfig.LocalRecoveryMode to localRecoveryEnabled : boolean in method public TaskExecutorLocalStateStoresManager(localRecoveryEnabled boolean, localStateRootDirectories File[], discardExecutor Executor) in class org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager |
From |
To |
|
Rename Parameter localRecoveryMode : LocalRecoveryConfig.LocalRecoveryMode to localRecoveryEnabled : boolean in method public TaskManagerServicesConfiguration(taskManagerAddress InetAddress, tmpDirPaths String[], localRecoveryStateRootDirectories String[], localRecoveryEnabled boolean, networkConfig NetworkEnvironmentConfiguration, queryableStateConfig QueryableStateConfiguration, numberOfSlots int, configuredMemory long, memoryType MemoryType, preAllocateMemory boolean, memoryFraction float, timerServiceShutdownTimeout long) in class org.apache.flink.runtime.taskexecutor.TaskManagerServicesConfiguration |
From |
To |
|
Rename Parameter recoveryMode : LocalRecoveryMode to localRecoveryEnabled : boolean in method package AbstractLocalRecoveryITCase(backendEnum StateBackendEnum, localRecoveryEnabled boolean) in class org.apache.flink.test.checkpointing.AbstractLocalRecoveryITCase |
From |
To |