This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.17 in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.17 by this push: new 9f067c4a825 [FLINK-33442] Copy local state collection preventively 9f067c4a825 is described below commit 9f067c4a825c51d5856fa77ff66d6cbcb9a62336 Author: Roman Khachatryan <khachatryan.ro...@gmail.com> AuthorDate: Thu Nov 2 21:46:14 2023 +0000 [FLINK-33442] Copy local state collection preventively --- .../streaming/state/restore/RocksDBIncrementalRestoreOperation.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBIncrementalRestoreOperation.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBIncrementalRestoreOperation.java index 5a89403617e..6fbae63c432 100644 --- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBIncrementalRestoreOperation.java +++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBIncrementalRestoreOperation.java @@ -164,7 +164,7 @@ public class RocksDBIncrementalRestoreOperation<K> implements RocksDBRestoreOper || !Objects.equals(theFirstStateHandle.getKeyGroupRange(), keyGroupRange)); if (isRescaling) { - restoreWithRescaling(restoreStateHandles); + restoreWithRescaling(new ArrayList<>(restoreStateHandles)); } else { restoreWithoutRescaling(theFirstStateHandle); }