(flink) branch release-1.17 updated: [FLINK-33442] Copy local state collection preventively

[roman]

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);
         }