This is an automated email from the ASF dual-hosted git repository.
sxnan pushed a change to branch config-2.0
in repository https://gitbox.apache.org/repos/asf/flink.git
discard 432ff6b27e7 [FLINK-34168][config] Refactor callers that use deprecated
get/setString
discard ea0c689ff38 [FLINK-34168][config] Refactor callers that use get/setLong
discard d9627fce7b5 [FLINK-34168][config] Refactor callers that use get/setInt
discard e479685e01c [FLINK-34168][config] Refactor callers that use
get/setFloat
discard a7bf9f7a80c [FLINK-34168][config] Refactor callers that use
get/setDouble
discard 67cc6a96290 [FLINK-34168][config] Refactor callers that use
get/setClass
discard 2505542741e [FLINK-34168][config] Refactor callers that use
get/setBoolean
add 2c16d884abd [FLINK-36125] Fix concurrent duplicated discard of logical
file in cp file-merging (#25236)
add c58a6ebbae5 [FLINK-35389][State/ForSt] Async list state (#25126)
add 5e36124c2b2 [FLINK-36198][network] Remove code of legacy hybrid
shuffle mode.
add ae1d7c1c8e6 [FLINK-36198][network] Remove deprecated config options
related to legacy hybrid shuffle
add 13cd826b51d [FLINK-36198][network] Change document related to hybrid
shuffle
add 3f39a7b0822 [FLINK-36119] Conditional interfaces for StateFuture
(#25244)
add 57bc16948be [FLINK-36201][Coordination] Don't use
StateLocalitySlotAssigner when local recovery is disabled
add a13b7eaa28a [FLINK-36149][state] Make the RocksdbCompactFilter
parameters take effect directly at the statebackend level. (#25257)
add 277706d8cb2 [FLINK-35049][state] Implement Map Async State API for
ForStStateBackend (#24812)
add be25a140f01 [FLINK-36217][tests] Remove powermock usage (#25287)
add 7adeecd3445 [FLINK-34510][Runtime/State]Rename RestoreMode to
RecoveryClaimMode (#25192)
add c11632674a8 [FLINK-35580] Prevent potential JVM crashes from async
compaction when RocksDB is already closed.
add a0ace618ad1 [FLINK-35580] Register async compact task with the
backend's lifecycle instead of the restore lifecycle.
add 9b2b922a159 [FLINK-35580] Introduce artificial map key for
RegisteredStateMetaInfoBase for safe deduplication in
RocksDBIncrementalRestoreOperation.
add 9ba7e670512 [FLINK-35580] Handle async compaction exceptions in
RocksDB restore.
add deeb42ec897 [FLINK-35580] Improve logging and problem analysis in
RockDBHandle.
add 42757607f23 [FLINK-35580] Fix synchronization issue when closing
RocksDBWriteBatchWrapper
add 830a17155cf [FLINK-35580] Ensure RocksDB working directory is created
before opening DB.
add 95ef07b789b [FLINK-35580] Improve logging for IngestDB to make key
range checks more observable.
add 1f303a218f4 [FLINK-36012] [runtime] Integrate StateTransitionManager
into WaitingForResources state
add 62e986da8e3 [FLINK-36234][Docs] Add 1.20 to PreviousDocs list
add 8ea55e1eb05 [FLINK-35972][state/runtime] Async process a runnable with
a key provided (#25289)
add c0176fd6794 [FLINK-33677][core] Remove flink-conf.yaml from flink dist.
add e3a48c2a58a [FLINK-34085][config] Remove deprecated string
configuration keys (#25302)
add be43295635a [FLINK-34168][config] Refactor callers that use
get/setBoolean
add 810e56b57e3 [FLINK-34168][config] Refactor callers that use
get/setClass
add 8ed4f0aed0b [FLINK-34168][config] Refactor callers that use
get/setDouble
add 8524ed944ec [FLINK-34168][config] Refactor callers that use
get/setFloat
add af300450b3b [FLINK-34168][config] Refactor callers that use get/setInt
add bed87844b6b [FLINK-34168][config] Refactor callers that use get/setLong
add 6de8869e519 [FLINK-34168][config] Refactor callers that use deprecated
get/setString
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (432ff6b27e7)
\
N -- N -- N refs/heads/config-2.0 (6de8869e519)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
docs/config.toml | 1 +
docs/content.zh/docs/ops/batch/batch_shuffle.md | 10 -
docs/content/docs/ops/batch/batch_shuffle.md | 10 -
.../generated/all_taskmanager_network_section.html | 2 +-
.../netty_shuffle_environment_configuration.html | 2 +-
.../rocksdb_configurable_configuration.html | 12 +
docs/static/generated/rest_v1_dispatcher.yml | 16 +-
.../apache/flink/client/cli/CliFrontendParser.java | 16 +-
.../apache/flink/client/cli/ProgramOptions.java | 6 +-
.../flink/client/cli/CliFrontendRunTest.java | 18 +-
.../api/java/hadoop/mapred/utils/HadoopUtils.java | 26 +-
.../StandaloneApplicationClusterEntryPoint.java | 12 +-
.../flink/api/common/state/v2/StateFuture.java | 97 ++
.../common/serialization/SerializerConfigImpl.java | 7 -
.../flink/api/common/state/StateTtlConfig.java | 20 +-
.../flink/configuration/ConfigConstants.java | 1699 +-------------------
.../apache/flink/configuration/Configuration.java | 44 +-
.../ConfigurationFileMigrationUtils.java | 173 ++
.../flink/configuration/ConfigurationUtils.java | 83 +-
.../configuration/DelegatingConfiguration.java | 18 +-
.../flink/configuration/GlobalConfiguration.java | 128 +-
.../NettyShuffleEnvironmentOptions.java | 68 +-
.../apache/flink/configuration/RestOptions.java | 6 +-
.../flink/configuration/StateRecoveryOptions.java | 8 +-
.../{RestoreMode.java => RecoveryClaimMode.java} | 8 +-
.../apache/flink/core/fs/ICloseableRegistry.java | 15 -
.../flink/core/state/CompletedStateFuture.java | 80 +
.../apache/flink/core/state/StateFutureImpl.java | 285 ++++
.../serialization/SerializerConfigImplTest.java | 16 -
.../flink/api/common/state/StateTtlConfigTest.java | 6 +-
.../ConfigurationFileMigrationUtilsTest.java | 93 ++
.../flink/configuration/ConfigurationTest.java | 146 +-
.../configuration/ConfigurationUtilsTest.java | 112 +-
.../configuration/GlobalConfigurationTest.java | 58 -
.../ReadableWritableConfigurationTest.java | 62 +-
.../apache/flink/core/fs/InitOutputPathTest.java | 46 +-
.../apache/flink/core/state/StateFutureTest.java | 69 +
.../src/main/flink-bin/bin/bash-java-utils.sh | 5 +-
.../src/main/flink-bin/bin/config-parser-utils.sh | 9 +-
flink-dist/src/main/flink-bin/bin/config.sh | 2 +-
.../src/main/flink-bin/bin/migrate-config-file.sh | 2 +-
flink-dist/src/test/bin/runBashJavaUtilsCmd.sh | 4 +-
flink-end-to-end-tests/test-scripts/common.sh | 3 +-
.../org/apache/flink/runtime/util/HadoopUtils.java | 33 +-
.../runtime/fs/hdfs/HadoopConfigLoadingTest.java | 62 +-
.../KubernetesCheckpointRecoveryFactory.java | 6 +-
.../flink/kubernetes/utils/KubernetesUtils.java | 8 +-
.../optimizer/plantranslate/JobGraphGenerator.java | 3 +-
.../reference/pyflink.table/table_environment.rst | 2 +-
flink-python/pyflink/common/configuration.py | 12 +-
flink-python/pyflink/pyflink_gateway_server.py | 36 +-
.../runtime/webmonitor/handlers/JarRunHandler.java | 19 +-
.../webmonitor/handlers/JarRunRequestBody.java | 25 +-
.../handlers/JarRunHandlerParameterTest.java | 6 +-
.../webmonitor/handlers/JarRunRequestBodyTest.java | 6 +-
flink-runtime/pom.xml | 13 -
.../runtime/checkpoint/CheckpointCoordinator.java | 4 +-
.../runtime/checkpoint/CheckpointProperties.java | 16 +-
.../checkpoint/CheckpointRecoveryFactory.java | 6 +-
.../runtime/checkpoint/CompletedCheckpoint.java | 8 +-
.../EmbeddedCompletedCheckpointStore.java | 8 +-
.../PerJobCheckpointRecoveryFactory.java | 10 +-
.../StandaloneCheckpointRecoveryFactory.java | 6 +-
.../StandaloneCompletedCheckpointStore.java | 14 +-
.../ZooKeeperCheckpointRecoveryFactory.java | 6 +-
.../checkpoint/filemerging/LogicalFile.java | 8 +-
.../cleanup/CheckpointResourcesCleanupRunner.java | 6 +-
.../EmbeddedHaServicesWithLeadershipControl.java | 4 +-
.../io/network/NettyShuffleServiceFactory.java | 14 +-
.../network/partition/ResultPartitionFactory.java | 109 +-
.../partition/hybrid/BufferIndexAndChannel.java | 39 -
.../network/partition/hybrid/HsBufferContext.java | 140 --
.../io/network/partition/hybrid/HsConsumerId.java | 63 -
.../io/network/partition/hybrid/HsDataView.java | 66 -
.../network/partition/hybrid/HsFileDataIndex.java | 115 --
.../partition/hybrid/HsFileDataIndexImpl.java | 292 ----
.../partition/hybrid/HsFileDataManager.java | 435 -----
.../partition/hybrid/HsFullSpillingStrategy.java | 159 --
.../partition/hybrid/HsMemoryDataManager.java | 409 -----
.../hybrid/HsMemoryDataManagerOperation.java | 70 -
.../partition/hybrid/HsMemoryDataSpiller.java | 169 --
.../network/partition/hybrid/HsOutputMetrics.java | 49 -
.../partition/hybrid/HsResultPartition.java | 334 ----
.../hybrid/HsSelectiveSpillingStrategy.java | 133 --
.../partition/hybrid/HsSpillingInfoProvider.java | 104 --
.../partition/hybrid/HsSpillingStrategy.java | 178 --
.../partition/hybrid/HsSpillingStrategyUtils.java | 129 --
.../partition/hybrid/HsSubpartitionConsumer.java | 311 ----
.../HsSubpartitionConsumerInternalOperations.java | 39 -
.../HsSubpartitionConsumerMemoryDataManager.java | 212 ---
.../partition/hybrid/HsSubpartitionFileReader.java | 68 -
.../hybrid/HsSubpartitionFileReaderImpl.java | 570 -------
.../hybrid/HsSubpartitionMemoryDataManager.java | 473 ------
.../hybrid/HybridShuffleConfiguration.java | 299 ----
.../hybrid/index/FileRegionWriteReadUtils.java | 66 -
.../runtime/jobgraph/SavepointConfigOptions.java | 8 +-
.../runtime/jobgraph/SavepointRestoreSettings.java | 41 +-
.../runtime/jobmanager/HighAvailabilityMode.java | 3 +-
.../flink/runtime/minicluster/MiniCluster.java | 6 +-
.../operators/sort/ExternalSorterBuilder.java | 4 +-
.../flink/runtime/scheduler/SchedulerUtils.java | 8 +-
.../scheduler/adaptive/AdaptiveScheduler.java | 50 +-
.../adaptive/AdaptiveSchedulerFactory.java | 10 +-
.../adaptive/DefaultStateTransitionManager.java | 88 +-
.../runtime/scheduler/adaptive/Executing.java | 12 +-
.../scheduler/adaptive/StateTransitionManager.java | 11 -
.../scheduler/adaptive/WaitingForResources.java | 109 +-
.../allocator/SlotSharingSlotAllocator.java | 19 +-
.../flink/runtime/shuffle/NettyShuffleMaster.java | 8 +-
.../state/CompositeKeySerializationUtils.java | 12 +
.../runtime/state/RegisteredStateMetaInfoBase.java | 46 +
.../flink/runtime/state/SharedStateRegistry.java | 13 +-
.../runtime/state/SharedStateRegistryFactory.java | 6 +-
.../runtime/state/SharedStateRegistryImpl.java | 6 +-
.../apache/flink/runtime/state/StateBackend.java | 6 +-
.../flink/runtime/state/v2/InternalKeyedState.java | 6 +-
.../NettyShuffleEnvironmentConfiguration.java | 33 +-
.../runtime/util/ConfigurationParserUtils.java | 19 +-
.../apache/flink/runtime/util/ZooKeeperUtils.java | 8 +-
.../AsyncStateProcessingOperator.java | 9 +
.../flink/streaming/runtime/tasks/StreamTask.java | 4 +-
.../CheckpointCoordinatorFailureTest.java | 4 +-
.../CheckpointCoordinatorRestoringTest.java | 8 +-
.../checkpoint/CheckpointCoordinatorTest.java | 10 +-
.../CheckpointCoordinatorTriggeringTest.java | 8 +-
.../checkpoint/CompletedCheckpointTest.java | 8 +-
.../DefaultCompletedCheckpointStoreTest.java | 4 +-
.../checkpoint/PerJobCheckpointRecoveryTest.java | 10 +-
.../TestingCheckpointRecoveryFactory.java | 4 +-
.../ZooKeeperCompletedCheckpointStoreITCase.java | 4 +-
.../ZooKeeperCompletedCheckpointStoreTest.java | 4 +-
.../FileMergingSnapshotManagerTestBase.java | 4 +
.../clusterframework/BootstrapToolsTest.java | 18 +-
.../dispatcher/DispatcherCleanupITCase.java | 8 +-
.../CheckpointResourcesCleanupRunnerTest.java | 4 +-
.../io/network/NettyShuffleEnvironmentBuilder.java | 2 -
.../network/partition/ResultPartitionBuilder.java | 21 +-
.../partition/ResultPartitionFactoryTest.java | 65 +-
.../partition/hybrid/HsBufferContextTest.java | 143 --
.../network/partition/hybrid/HsConsumerIdTest.java | 43 -
.../partition/hybrid/HsFileDataIndexImplTest.java | 143 --
.../partition/hybrid/HsFileDataManagerTest.java | 523 ------
.../hybrid/HsFullSpillingStrategyTest.java | 172 --
.../partition/hybrid/HsMemoryDataManagerTest.java | 291 ----
.../partition/hybrid/HsMemoryDataSpillerTest.java | 207 ---
.../partition/hybrid/HsResultPartitionTest.java | 742 ---------
.../hybrid/HsSelectiveSpillingStrategyTest.java | 168 --
.../hybrid/HsSpillingStrategyUtilsTest.java | 74 -
...sSubpartitionConsumerMemoryDataManagerTest.java | 204 ---
.../hybrid/HsSubpartitionFileReaderImplTest.java | 776 ---------
.../HsSubpartitionMemoryDataManagerTest.java | 480 ------
.../partition/hybrid/HsSubpartitionViewTest.java | 442 -----
.../partition/hybrid/HybridShuffleTestUtils.java | 61 -
.../partition/hybrid/TestingFileDataIndex.java | 106 --
.../partition/hybrid/TestingHsDataView.java | 129 --
.../hybrid/TestingMemoryDataManagerOperation.java | 156 --
.../hybrid/TestingSpillingInfoProvider.java | 235 ---
.../partition/hybrid/TestingSpillingStrategy.java | 138 --
...stingSubpartitionConsumerInternalOperation.java | 46 -
.../hybrid/index/FileRegionWriteReadUtilsTest.java | 118 --
.../jobgraph/SavepointRestoreSettingsTest.java | 6 +-
.../jobmanager/HighAvailabilityModeTest.java | 15 +-
.../runtime/scheduler/SchedulerUtilsTest.java | 10 +-
.../adaptive/AdaptiveSchedulerBuilder.java | 12 +-
.../scheduler/adaptive/AdaptiveSchedulerTest.java | 193 ++-
.../DefaultStateTransitionManagerTest.java | 34 +-
.../runtime/scheduler/adaptive/ExecutingTest.java | 51 +-
.../adaptive/TestingStateTransitionManager.java | 39 +-
.../adaptive/WaitingForResourcesTest.java | 255 ++-
.../allocator/SlotSharingSlotAllocatorTest.java | 42 +-
.../runtime/state/SharedStateRegistryTest.java | 4 +-
.../runtime/util/bash/FlinkConfigLoaderTest.java | 183 +--
.../org/apache/flink/state/forst/ContextKey.java | 26 +
.../flink/state/forst/ForStDBBunchPutRequest.java | 112 ++
.../flink/state/forst/ForStDBGetRequest.java | 36 +-
.../flink/state/forst/ForStDBIterRequest.java | 186 +++
...BGetRequest.java => ForStDBListGetRequest.java} | 52 +-
.../flink/state/forst/ForStDBMapCheckRequest.java | 83 +
.../state/forst/ForStDBMapEntryIterRequest.java | 117 ++
.../state/forst/ForStDBMapKeyIterRequest.java | 79 +
.../state/forst/ForStDBMapValueIterRequest.java | 78 +
.../flink/state/forst/ForStDBPutRequest.java | 55 +-
.../flink/state/forst/ForStDBSingleGetRequest.java | 43 +-
.../state/forst/ForStDBWriteBatchWrapper.java} | 26 +-
.../state/forst/ForStGeneralMultiGetOperation.java | 14 +-
.../apache/flink/state/forst/ForStInnerTable.java | 4 +-
...etOperation.java => ForStIterateOperation.java} | 29 +-
.../flink/state/forst/ForStKeyedStateBackend.java | 58 +-
.../state/forst/ForStKeyedStateBackendBuilder.java | 1 +
.../flink/state/forst/ForStListIterator.java | 48 +
.../{ForStValueState.java => ForStListState.java} | 83 +-
.../apache/flink/state/forst/ForStMapIterator.java | 71 +
.../apache/flink/state/forst/ForStMapState.java | 307 ++++
.../flink/state/forst/ForStStateExecutor.java | 24 +-
.../state/forst/ForStStateRequestClassifier.java | 64 +-
.../apache/flink/state/forst/ForStValueState.java | 4 +-
.../state/forst/ForStWriteBatchOperation.java | 21 +-
.../flink/state/forst/ListDelimitedSerializer.java | 94 ++
.../state/forst/ForStDBIterateOperationTest.java | 230 +++
.../state/forst/ForStDBOperationTestBase.java | 106 +-
.../forst/ForStGeneralMultiGetOperationTest.java | 155 +-
.../state/forst/ForStStateBackendConfigTest.java | 3 -
.../flink/state/forst/ForStStateExecutorTest.java | 123 +-
.../state/forst/ForStWriteBatchOperationTest.java | 180 +++
.../state/EmbeddedRocksDBStateBackend.java | 4 +-
.../state/RocksDBConfigurableOptions.java | 20 +
.../state/RocksDBIncrementalCheckpointUtils.java | 222 ++-
.../streaming/state/RocksDBKeyedStateBackend.java | 8 +-
.../state/RocksDBKeyedStateBackendBuilder.java | 43 +-
.../streaming/state/RocksDBOperationUtils.java | 26 +-
.../streaming/state/RocksDBResourceContainer.java | 13 +
.../streaming/state/RocksDBWriteBatchWrapper.java | 58 +
.../state/restore/RocksDBFullRestoreOperation.java | 4 +-
.../streaming/state/restore/RocksDBHandle.java | 11 +-
.../RocksDBHeapTimersFullRestoreOperation.java | 4 +-
.../RocksDBIncrementalRestoreOperation.java | 229 +--
.../state/restore/RocksDBRestoreResult.java | 11 +-
.../state/ttl/RocksDbTtlCompactFiltersManager.java | 45 +-
.../streaming/state/RocksDBRecoveryTest.java | 47 +-
.../state/RocksDBStateBackendConfigTest.java | 3 -
.../contrib/streaming/state/RocksDBTestUtils.java | 2 +-
.../state/RocksDBWriteBatchWrapperTest.java | 57 +
.../AbstractAsyncStateStreamOperator.java | 19 +
.../AbstractAsyncStateStreamOperatorV2.java | 19 +
.../AbstractAsyncStateStreamOperatorTest.java | 68 +
.../AbstractAsyncStateStreamOperatorV2Test.java | 96 +-
.../plan/nodes/exec/testutils/RestoreTestBase.java | 4 +-
.../powermock/extensions/configuration.properties | 19 -
.../ChangelogRecoverySwitchStateBackendITCase.java | 4 +-
.../ResumeCheckpointManuallyITCase.java | 77 +-
.../test/checkpointing/SavepointFormatITCase.java | 4 +-
.../flink/test/checkpointing/SavepointITCase.java | 11 +-
.../SnapshotFileMergingCompatibilityITCase.java | 48 +-
.../flink/test/runtime/HybridShuffleITCase.java | 21 +-
.../flink/yarn/entrypoint/YarnEntrypointUtils.java | 16 -
.../flink/yarn/YarnFileStageTestS3ITCase.java | 2 -
pom.xml | 32 +-
tools/maven/suppressions-core.xml | 4 -
tools/maven/suppressions-runtime.xml | 3 -
239 files changed, 5153 insertions(+), 14460 deletions(-)
create mode 100644
flink-core/src/main/java/org/apache/flink/configuration/ConfigurationFileMigrationUtils.java
rename
flink-core/src/main/java/org/apache/flink/core/execution/{RestoreMode.java =>
RecoveryClaimMode.java} (90%)
create mode 100644
flink-core/src/test/java/org/apache/flink/configuration/ConfigurationFileMigrationUtilsTest.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/BufferIndexAndChannel.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsBufferContext.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsConsumerId.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsDataView.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataIndex.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataIndexImpl.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataManager.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFullSpillingStrategy.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManagerOperation.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataSpiller.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsOutputMetrics.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsResultPartition.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSelectiveSpillingStrategy.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSpillingInfoProvider.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSpillingStrategy.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSpillingStrategyUtils.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionConsumer.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionConsumerInternalOperations.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionConsumerMemoryDataManager.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReader.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderImpl.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionMemoryDataManager.java
delete mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HybridShuffleConfiguration.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsBufferContextTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsConsumerIdTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataIndexImplTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFileDataManagerTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsFullSpillingStrategyTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManagerTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataSpillerTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsResultPartitionTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSelectiveSpillingStrategyTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSpillingStrategyUtilsTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionConsumerMemoryDataManagerTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionFileReaderImplTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionMemoryDataManagerTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/HsSubpartitionViewTest.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/TestingFileDataIndex.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/TestingHsDataView.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/TestingMemoryDataManagerOperation.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/TestingSpillingInfoProvider.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/TestingSpillingStrategy.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/TestingSubpartitionConsumerInternalOperation.java
delete mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/hybrid/index/FileRegionWriteReadUtilsTest.java
create mode 100644
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBBunchPutRequest.java
create mode 100644
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBIterRequest.java
copy
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/{ForStDBGetRequest.java
=> ForStDBListGetRequest.java} (53%)
create mode 100644
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBMapCheckRequest.java
create mode 100644
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBMapEntryIterRequest.java
create mode 100644
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBMapKeyIterRequest.java
create mode 100644
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBMapValueIterRequest.java
rename
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/BufferWithIdentity.java
=>
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBSingleGetRequest.java
(50%)
copy
flink-state-backends/{flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBWriteBatchWrapper.java
=>
flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStDBWriteBatchWrapper.java}
(88%)
copy
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/{ForStGeneralMultiGetOperation.java
=> ForStIterateOperation.java} (68%)
create mode 100644
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStListIterator.java
copy
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/{ForStValueState.java
=> ForStListState.java} (63%)
create mode 100644
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStMapIterator.java
create mode 100644
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStMapState.java
create mode 100644
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ListDelimitedSerializer.java
create mode 100644
flink-state-backends/flink-statebackend-forst/src/test/java/org/apache/flink/state/forst/ForStDBIterateOperationTest.java
delete mode 100644
flink-test-utils-parent/flink-test-utils-junit/src/main/resources/org/powermock/extensions/configuration.properties
