|
Change Parameter Type taskStateManager : TestTaskStateManager to taskStateManager : TaskStateManager in method public MockEnvironment(taskName String, memorySize long, inputSplitProvider MockInputSplitProvider, bufferSize int, taskConfiguration Configuration, executionConfig ExecutionConfig, taskStateManager TaskStateManager) in class org.apache.flink.runtime.operators.testutils.MockEnvironment |
From |
To |
|
Change Parameter Type taskStateManager : TestTaskStateManager to taskStateManager : TaskStateManager in method public MockEnvironment(taskName String, memorySize long, inputSplitProvider MockInputSplitProvider, bufferSize int, taskConfiguration Configuration, executionConfig ExecutionConfig, maxParallelism int, parallelism int, subtaskIndex int, userCodeClassLoader ClassLoader, taskStateManager TaskStateManager) in class org.apache.flink.runtime.operators.testutils.MockEnvironment |
From |
To |
|
Change Parameter Type taskStateManager : TestTaskStateManager to taskStateManager : TaskStateManager in method public MockEnvironment(taskName String, memorySize long, inputSplitProvider MockInputSplitProvider, bufferSize int, taskConfiguration Configuration, executionConfig ExecutionConfig, taskStateManager TaskStateManager, maxParallelism int, parallelism int, subtaskIndex int) in class org.apache.flink.runtime.operators.testutils.MockEnvironment |
From |
To |
|
Change Parameter Type taskStateManager : TestTaskStateManager to taskStateManager : TaskStateManager in method public MockEnvironment(taskName String, memorySize long, inputSplitProvider MockInputSplitProvider, bufferSize int, taskStateManager TaskStateManager) in class org.apache.flink.runtime.operators.testutils.MockEnvironment |
From |
To |