You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by hx...@apache.org on 2022/10/31 08:00:37 UTC
[flink] 11/14: [release] Upgrade current version to 1.16 for StatefulJobWBroadcastStateMigrationITCase and create snapshots
This is an automated email from the ASF dual-hosted git repository.
hxb pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 72bd802573c107684685499ca34da0dd7c058cfc
Author: huangxingbo <hx...@apache.org>
AuthorDate: Mon Oct 31 15:46:22 2022 +0800
[release] Upgrade current version to 1.16 for StatefulJobWBroadcastStateMigrationITCase and create snapshots
---
.../StatefulJobWBroadcastStateMigrationITCase.java | 2 +-
.../0ef38721-0cd9-4fc0-8448-06ea17da8425 | Bin 0 -> 786 bytes
.../1019d18f-08e5-4550-8fcd-81c8c33227e2 | Bin 0 -> 786 bytes
.../214dcfd5-fd1a-474a-a5bf-a13ebd5b84da | Bin 0 -> 704 bytes
.../3593bbdf-8dc9-4f82-9dc8-8674665c0e3e | Bin 0 -> 292 bytes
.../41e2b86d-6ed6-446f-a882-51b7f2eb38ab | Bin 0 -> 786 bytes
.../4bf32d46-9914-4886-9fed-450ccc86905d | Bin 0 -> 704 bytes
.../4c42f995-9965-4067-9334-861d77f0efaa | Bin 0 -> 281 bytes
.../54c9775c-d481-48c7-a99c-3577bb7c1c56 | Bin 0 -> 281 bytes
.../57cbc8bd-d7af-4243-b8ee-1a982f2494eb | Bin 0 -> 704 bytes
.../6cba84e4-cc4e-4495-b78d-22cff0e1bec1 | Bin 0 -> 346 bytes
.../7fbbcff8-c574-4bff-bfb7-8fcc9fc6755e | Bin 0 -> 786 bytes
.../9050707e-4414-48f6-9b19-a9d4f69d5c0b | Bin 0 -> 346 bytes
.../9bc508cc-cfab-480a-aa5c-c2212bc7d36c | Bin 0 -> 704 bytes
.../_metadata | Bin 0 -> 3320 bytes
.../ae0756e1-b8b4-49c9-b3c2-0996c71ddb44 | Bin 0 -> 786 bytes
.../b87c7f77-94b3-488d-9b4c-1432a5e39e3e | Bin 0 -> 292 bytes
.../c006d489-6664-4559-9d55-b13f52a7403a | Bin 0 -> 786 bytes
.../c4e599e8-1549-4e42-97c0-0ea0bb128fd3 | Bin 0 -> 346 bytes
.../d829ff78-6728-4b9f-93c0-420096cb534c | Bin 0 -> 786 bytes
.../ebde57d2-6680-4daf-9395-061b2b8f0d18 | Bin 0 -> 786 bytes
.../ff50bb91-0fec-4740-bbc6-a2bffacd529d | Bin 0 -> 346 bytes
.../1818bafa-fda1-47af-9a56-32b27efbf947 | Bin 0 -> 281 bytes
.../2366b0df-90c1-44ea-8d4a-4a616a082eb2 | Bin 0 -> 786 bytes
.../26bbaa77-7183-4e9d-8cdd-505569110a98 | Bin 0 -> 346 bytes
.../28e3b31f-745c-4d5d-b31e-1b8d02822a72 | Bin 0 -> 786 bytes
.../32dc3694-96c4-4341-a4f2-1e5953c0eb79 | Bin 0 -> 786 bytes
.../3843df68-8e6b-428c-bec0-82c1f7187b98 | Bin 0 -> 292 bytes
.../4e7530e7-cc85-493d-82c2-aabbda954d12 | Bin 0 -> 346 bytes
.../6394ef5e-4283-4dce-8f3c-72aab084a8c8 | Bin 0 -> 786 bytes
.../6719bec9-c717-4e09-874c-a0cd059797a1 | Bin 0 -> 346 bytes
.../71c3963a-5e07-42d1-8dfe-91c547eea7cf | Bin 0 -> 786 bytes
.../8fbe5789-c5a8-4d89-b8f7-f7db88596ec8 | Bin 0 -> 704 bytes
.../97f6c7df-f963-4841-85b5-d3741b12ff76 | Bin 0 -> 786 bytes
.../9c63a3e5-54c8-4c92-a0ce-990367e170e8 | Bin 0 -> 346 bytes
.../_metadata | Bin 0 -> 3458 bytes
.../b4cbb71c-59d7-4e1f-bd7e-252158995a63 | Bin 0 -> 704 bytes
.../bf4f5d43-ea9c-49af-a2e7-6f6258f8ca73 | Bin 0 -> 281 bytes
.../c0348fbc-6a9c-409f-8636-7c906c3a0f0d | Bin 0 -> 292 bytes
.../c231e227-3f0d-4059-bd28-d3ae73852dc5 | Bin 0 -> 786 bytes
.../dc429776-bf1f-4cb3-8f1c-ac65b7d33f25 | Bin 0 -> 786 bytes
.../e2ecb84a-379a-4165-b44b-536025b00037 | Bin 0 -> 704 bytes
.../e35de65e-cefb-4b56-9e13-1caff374156c | Bin 0 -> 704 bytes
.../2e39b700-e7ff-4b5e-9027-17d88631f9ac | Bin 0 -> 704 bytes
.../33e9912e-db54-466e-b52e-1de8a7e7e643 | Bin 0 -> 704 bytes
.../3ba97e5c-9e89-4508-95fc-c200cf85c79c | Bin 0 -> 704 bytes
.../471f4083-15b6-4c97-8d93-713abfacbc37 | Bin 0 -> 770 bytes
.../4f8ab9ee-133f-4dca-a83e-81aea37c6a43 | Bin 0 -> 770 bytes
.../5358eecb-51a0-4c3e-8ad4-8677cc77d2db | Bin 0 -> 292 bytes
.../54699f69-0dfd-494b-b4fe-1000bc6364e6 | Bin 0 -> 770 bytes
.../5491d99c-ae9a-4e39-b6e3-02340ee3a8fe | Bin 0 -> 704 bytes
.../5fd6bd5b-e28e-4854-8762-d8f3081218a2 | Bin 0 -> 770 bytes
.../66481c2d-f544-4ad0-a99d-d818ea30de0a | Bin 0 -> 281 bytes
.../80338935-5c3b-4d8c-9178-990d16db5475 | Bin 0 -> 346 bytes
.../8158597f-8051-4038-be62-200e3af3c9b7 | Bin 0 -> 281 bytes
.../_metadata | Bin 0 -> 3157 bytes
.../a0c038b2-cdd4-4256-849a-10e6f13306c3 | Bin 0 -> 770 bytes
.../a6db53a6-7bb3-41dd-af83-a14de7146ec9 | Bin 0 -> 292 bytes
.../b5a361ce-1fa8-4026-845a-20ae8174fe38 | Bin 0 -> 770 bytes
.../c0103aa6-6c88-44ef-af9f-14a53cf62038 | Bin 0 -> 770 bytes
.../c2cf38cb-556e-4994-9dc9-27612c82870e | Bin 0 -> 346 bytes
.../e9d785e5-205f-4f23-938e-73ab621ecc00 | Bin 0 -> 770 bytes
.../ef0e6568-4a6b-4df9-9f87-4852dff90af4 | Bin 0 -> 346 bytes
.../f0a4d522-a3c4-4d54-829b-17947311cb9f | Bin 0 -> 346 bytes
.../0390d116-06b3-42d4-bc39-675b7a52dcfc | Bin 0 -> 704 bytes
.../203f6aa2-f654-4fe8-8c60-5d6a0bc4f6e7 | Bin 0 -> 346 bytes
.../376e2a5f-e03a-4a0b-9320-9f7bea6228a1 | Bin 0 -> 346 bytes
.../3bb74f35-9f8d-4f3f-9018-7d9ef5a2de16 | Bin 0 -> 346 bytes
.../4cb2044a-3a61-4a13-a873-34fab4c79753 | Bin 0 -> 292 bytes
.../83cb91cc-acb8-44e8-93c6-8582ecf43bdc | Bin 0 -> 346 bytes
.../948a610c-ec84-4a36-b82b-c69f9849ff27 | Bin 0 -> 281 bytes
.../94db1a61-29d5-43e0-bcad-3c8ac0be7f1e | Bin 0 -> 704 bytes
.../_metadata | Bin 0 -> 2512 bytes
.../a456fb85-0c41-4186-9dd1-cbf5a4098da5 | Bin 0 -> 704 bytes
.../cb6ad731-8f58-4c1f-984c-2f69a3d8f7f5 | Bin 0 -> 704 bytes
.../eef8265e-a96b-44c3-bd09-dc63b6a7a721 | Bin 0 -> 292 bytes
.../f11589d5-b382-4679-b891-91210453d218 | Bin 0 -> 281 bytes
.../0046924f-7506-4764-b0df-0abb64e5090c | Bin 0 -> 216 bytes
.../054ab4aa-2aa8-4031-97d6-775464674401 | Bin 0 -> 216 bytes
.../0dec7bd0-e63b-4b73-9f19-f66946297055 | Bin 0 -> 704 bytes
.../0e60de9e-a5ea-470c-a9a8-fe4daafc63c3 | Bin 0 -> 216 bytes
.../112f324b-29dc-497a-873d-9c0f330c9077 | Bin 0 -> 292 bytes
.../155bc646-c73a-4d7d-91b5-f5b0bf87f0c6 | 362 +++++++++++++++++++++
.../1b4aec92-0f00-4a2a-bdd5-43b2dc36d075 | 1 +
.../296b75b7-b072-47fa-a7a2-b379cfc6bae2 | 362 +++++++++++++++++++++
.../2a73a906-56db-4e22-9424-11666698c772 | Bin 0 -> 770 bytes
.../35920931-8312-4e75-8b96-22284f4065a9 | 362 +++++++++++++++++++++
.../38d42b00-e95f-4ece-9181-aa6b2cf112c8 | 1 +
.../3ed79b35-9cce-484b-9518-1d8c8e908f72 | 1 +
.../45b19d03-839d-4406-8a5e-c82d0395e817 | Bin 0 -> 346 bytes
.../4c946e1c-67f7-4e78-afef-280fe43c0245 | Bin 0 -> 216 bytes
.../4f475acb-f6d4-448f-a783-9c1aa8a14948 | Bin 0 -> 770 bytes
.../58465b8e-9415-47ac-ba59-3f1858545c7a | Bin 0 -> 216 bytes
.../5de7c098-d4a5-444f-aeea-9ba75eac26f7 | Bin 0 -> 216 bytes
.../63df9706-33e9-4acf-9be4-8eb1b71f4c42 | Bin 0 -> 770 bytes
.../66d713b7-9829-4198-9050-1148e656474a | 362 +++++++++++++++++++++
.../6ffccc86-e6b3-4750-90ab-bd4e3a67badc | Bin 0 -> 770 bytes
.../7181a6d4-8773-43b3-8aea-c12ebb6c2cbf | Bin 0 -> 216 bytes
.../7b06051f-16cc-4671-8148-2299a09ab676 | Bin 0 -> 770 bytes
.../7b69c00e-2dc0-4380-9058-5a8991e91e50 | Bin 0 -> 704 bytes
.../7bce7df8-6286-4cf3-bb0d-bea886feeded | 1 +
.../7e0174af-86ac-4f38-8319-9633c0ee51c4 | Bin 0 -> 281 bytes
.../8502132f-9182-4925-9b1b-8c383fd9c0ad | Bin 0 -> 346 bytes
.../8c7e6de2-2c02-47e7-b62d-ebcc12c745f8 | 1 +
.../8dc0f73d-6e81-42a0-a43e-a4c1af043d22 | Bin 0 -> 770 bytes
.../9174bd29-8a87-4397-9ed9-c983581f797a | Bin 0 -> 704 bytes
.../9356ac80-1be8-451d-8895-e2ec34e4cedb | Bin 0 -> 770 bytes
.../9e22fc6b-b913-4465-9382-9903720344b0 | 362 +++++++++++++++++++++
.../_metadata | Bin 0 -> 5354 bytes
.../ad7138b5-c985-4cb1-a853-c7a7de5886be | Bin 0 -> 346 bytes
.../b997832d-7bbc-4028-8362-a04e9499aff2 | 1 +
.../c04ea0c0-eb22-477e-9f58-9e6e229ef61e | Bin 0 -> 704 bytes
.../c3938f22-a681-4067-891b-df0bd5c9c455 | 362 +++++++++++++++++++++
.../c9e344b7-2ada-4088-b401-525e7230c38f | 362 +++++++++++++++++++++
.../cb905cef-aadb-4a61-9a73-816fb4c0b4bb | 1 +
.../cc0b8716-f251-4429-bcbe-cae8511a9c54 | Bin 0 -> 292 bytes
.../cd4f33b7-6c5d-4681-b7fc-d964b4b42c5f | Bin 0 -> 346 bytes
.../d1b8bd46-68e1-4760-91b7-00cb2ae68fbb | 362 +++++++++++++++++++++
.../d245d07c-0a69-4356-abc2-a24e89869ed2 | Bin 0 -> 281 bytes
.../da9b4d7c-ac30-445d-b3b0-ac742b479b24 | 1 +
.../f94ddae2-a9c7-48fd-86c3-ac2284d7a95c | Bin 0 -> 216 bytes
.../fcb275b6-2a30-45da-9030-f9a86b1b3721 | Bin 0 -> 770 bytes
.../053587a5-8707-44bb-80f0-3ee725ed96bc | Bin 0 -> 770 bytes
.../09d35912-4a55-4bcd-a6a3-360f77f807c8 | Bin 0 -> 704 bytes
.../2e3778c2-a2ff-4787-9938-2fd05c4ea911 | Bin 0 -> 281 bytes
.../30b30745-1e31-4c49-b001-6bad93fe2c14 | Bin 0 -> 704 bytes
.../37e1f016-44ec-45e8-bec4-61c6fe7b8684 | Bin 0 -> 346 bytes
.../41404971-06b4-44da-a68a-910dda186d1f | Bin 0 -> 770 bytes
.../429c5d52-6b34-4b58-a1de-295fd233e72a | Bin 0 -> 346 bytes
.../54dcb3d3-f813-4067-b08b-2bd38cf0f1a9 | Bin 0 -> 770 bytes
.../782450b9-6c45-4ac0-98c6-6da643567ca5 | Bin 0 -> 346 bytes
.../79c9bfd2-ac45-436f-be0c-cc3556561985 | Bin 0 -> 292 bytes
.../88e50b13-f3af-4840-8554-93086cf7f73b | Bin 0 -> 281 bytes
.../8eb80ffc-c7a9-4803-9f62-298cc5358ca9 | Bin 0 -> 704 bytes
.../9642fb8c-81ee-4b8c-b4c2-2328e171bb14 | Bin 0 -> 346 bytes
.../97ff88fa-990b-495f-9bff-179f607c324d | Bin 0 -> 770 bytes
.../_metadata | Bin 0 -> 3157 bytes
.../aa86e0bd-7b33-479d-b055-533225923919 | Bin 0 -> 704 bytes
.../b4b14e36-a896-4e89-b327-50add7bcbbf2 | Bin 0 -> 770 bytes
.../b60925f2-20bb-4dc0-9b4c-a2114781a058 | Bin 0 -> 770 bytes
.../cdf288bc-0b65-4637-ab11-dada9cfaaef3 | Bin 0 -> 292 bytes
.../d7084730-48ee-46a6-95b7-74e16521d058 | Bin 0 -> 770 bytes
.../e6be8162-4006-4c4d-93f3-63267244fb50 | Bin 0 -> 770 bytes
143 files changed, 2905 insertions(+), 1 deletion(-)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StatefulJobWBroadcastStateMigrationITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StatefulJobWBroadcastStateMigrationITCase.java
index 88e5856fc28..e3ea9a1da66 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StatefulJobWBroadcastStateMigrationITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StatefulJobWBroadcastStateMigrationITCase.java
@@ -60,7 +60,7 @@ public class StatefulJobWBroadcastStateMigrationITCase extends SnapshotMigration
private static final int NUM_SOURCE_ELEMENTS = 4;
// TODO increase this to newer version to create and test snapshot migration for newer versions
- private static final FlinkVersion currentVersion = FlinkVersion.v1_15;
+ private static final FlinkVersion currentVersion = FlinkVersion.v1_16;
// TODO change this to CREATE_SNAPSHOT to (re)create binary snapshots
// TODO Note: You should generate the snapshot based on the release branch instead of the
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/0ef38721-0cd9-4fc0-8448-06ea17da8425 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/0ef38721-0cd9-4fc0-8448-06ea17da8425
new file mode 100644
index 00000000000..5be99d80daf
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/0ef38721-0cd9-4fc0-8448-06ea17da8425 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/1019d18f-08e5-4550-8fcd-81c8c33227e2 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/1019d18f-08e5-4550-8fcd-81c8c33227e2
new file mode 100644
index 00000000000..53252da759e
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/1019d18f-08e5-4550-8fcd-81c8c33227e2 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/214dcfd5-fd1a-474a-a5bf-a13ebd5b84da b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/214dcfd5-fd1a-474a-a5bf-a13ebd5b84da
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/214dcfd5-fd1a-474a-a5bf-a13ebd5b84da differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/3593bbdf-8dc9-4f82-9dc8-8674665c0e3e b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/3593bbdf-8dc9-4f82-9dc8-8674665c0e3e
new file mode 100644
index 00000000000..2f020711c6f
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/3593bbdf-8dc9-4f82-9dc8-8674665c0e3e differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/41e2b86d-6ed6-446f-a882-51b7f2eb38ab b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/41e2b86d-6ed6-446f-a882-51b7f2eb38ab
new file mode 100644
index 00000000000..5be99d80daf
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/41e2b86d-6ed6-446f-a882-51b7f2eb38ab differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/4bf32d46-9914-4886-9fed-450ccc86905d b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/4bf32d46-9914-4886-9fed-450ccc86905d
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/4bf32d46-9914-4886-9fed-450ccc86905d differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/4c42f995-9965-4067-9334-861d77f0efaa b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/4c42f995-9965-4067-9334-861d77f0efaa
new file mode 100644
index 00000000000..719c2ab8b97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/4c42f995-9965-4067-9334-861d77f0efaa differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/54c9775c-d481-48c7-a99c-3577bb7c1c56 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/54c9775c-d481-48c7-a99c-3577bb7c1c56
new file mode 100644
index 00000000000..719c2ab8b97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/54c9775c-d481-48c7-a99c-3577bb7c1c56 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/57cbc8bd-d7af-4243-b8ee-1a982f2494eb b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/57cbc8bd-d7af-4243-b8ee-1a982f2494eb
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/57cbc8bd-d7af-4243-b8ee-1a982f2494eb differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/6cba84e4-cc4e-4495-b78d-22cff0e1bec1 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/6cba84e4-cc4e-4495-b78d-22cff0e1bec1
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/6cba84e4-cc4e-4495-b78d-22cff0e1bec1 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/7fbbcff8-c574-4bff-bfb7-8fcc9fc6755e b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/7fbbcff8-c574-4bff-bfb7-8fcc9fc6755e
new file mode 100644
index 00000000000..e6a957bb963
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/7fbbcff8-c574-4bff-bfb7-8fcc9fc6755e differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/9050707e-4414-48f6-9b19-a9d4f69d5c0b b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/9050707e-4414-48f6-9b19-a9d4f69d5c0b
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/9050707e-4414-48f6-9b19-a9d4f69d5c0b differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/9bc508cc-cfab-480a-aa5c-c2212bc7d36c b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/9bc508cc-cfab-480a-aa5c-c2212bc7d36c
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/9bc508cc-cfab-480a-aa5c-c2212bc7d36c differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/_metadata b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/_metadata
new file mode 100644
index 00000000000..4e23ec90e22
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/_metadata differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/ae0756e1-b8b4-49c9-b3c2-0996c71ddb44 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/ae0756e1-b8b4-49c9-b3c2-0996c71ddb44
new file mode 100644
index 00000000000..53252da759e
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/ae0756e1-b8b4-49c9-b3c2-0996c71ddb44 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/b87c7f77-94b3-488d-9b4c-1432a5e39e3e b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/b87c7f77-94b3-488d-9b4c-1432a5e39e3e
new file mode 100644
index 00000000000..2f020711c6f
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/b87c7f77-94b3-488d-9b4c-1432a5e39e3e differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/c006d489-6664-4559-9d55-b13f52a7403a b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/c006d489-6664-4559-9d55-b13f52a7403a
new file mode 100644
index 00000000000..c4f536420f8
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/c006d489-6664-4559-9d55-b13f52a7403a differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/c4e599e8-1549-4e42-97c0-0ea0bb128fd3 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/c4e599e8-1549-4e42-97c0-0ea0bb128fd3
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/c4e599e8-1549-4e42-97c0-0ea0bb128fd3 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/d829ff78-6728-4b9f-93c0-420096cb534c b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/d829ff78-6728-4b9f-93c0-420096cb534c
new file mode 100644
index 00000000000..c4f536420f8
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/d829ff78-6728-4b9f-93c0-420096cb534c differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/ebde57d2-6680-4daf-9395-061b2b8f0d18 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/ebde57d2-6680-4daf-9395-061b2b8f0d18
new file mode 100644
index 00000000000..e6a957bb963
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/ebde57d2-6680-4daf-9395-061b2b8f0d18 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/ff50bb91-0fec-4740-bbc6-a2bffacd529d b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/ff50bb91-0fec-4740-bbc6-a2bffacd529d
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-checkpoint/ff50bb91-0fec-4740-bbc6-a2bffacd529d differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/1818bafa-fda1-47af-9a56-32b27efbf947 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/1818bafa-fda1-47af-9a56-32b27efbf947
new file mode 100644
index 00000000000..719c2ab8b97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/1818bafa-fda1-47af-9a56-32b27efbf947 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/2366b0df-90c1-44ea-8d4a-4a616a082eb2 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/2366b0df-90c1-44ea-8d4a-4a616a082eb2
new file mode 100644
index 00000000000..5be99d80daf
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/2366b0df-90c1-44ea-8d4a-4a616a082eb2 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/26bbaa77-7183-4e9d-8cdd-505569110a98 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/26bbaa77-7183-4e9d-8cdd-505569110a98
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/26bbaa77-7183-4e9d-8cdd-505569110a98 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/28e3b31f-745c-4d5d-b31e-1b8d02822a72 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/28e3b31f-745c-4d5d-b31e-1b8d02822a72
new file mode 100644
index 00000000000..5be99d80daf
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/28e3b31f-745c-4d5d-b31e-1b8d02822a72 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/32dc3694-96c4-4341-a4f2-1e5953c0eb79 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/32dc3694-96c4-4341-a4f2-1e5953c0eb79
new file mode 100644
index 00000000000..e6a957bb963
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/32dc3694-96c4-4341-a4f2-1e5953c0eb79 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/3843df68-8e6b-428c-bec0-82c1f7187b98 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/3843df68-8e6b-428c-bec0-82c1f7187b98
new file mode 100644
index 00000000000..2f020711c6f
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/3843df68-8e6b-428c-bec0-82c1f7187b98 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/4e7530e7-cc85-493d-82c2-aabbda954d12 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/4e7530e7-cc85-493d-82c2-aabbda954d12
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/4e7530e7-cc85-493d-82c2-aabbda954d12 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/6394ef5e-4283-4dce-8f3c-72aab084a8c8 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/6394ef5e-4283-4dce-8f3c-72aab084a8c8
new file mode 100644
index 00000000000..c4f536420f8
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/6394ef5e-4283-4dce-8f3c-72aab084a8c8 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/6719bec9-c717-4e09-874c-a0cd059797a1 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/6719bec9-c717-4e09-874c-a0cd059797a1
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/6719bec9-c717-4e09-874c-a0cd059797a1 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/71c3963a-5e07-42d1-8dfe-91c547eea7cf b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/71c3963a-5e07-42d1-8dfe-91c547eea7cf
new file mode 100644
index 00000000000..53252da759e
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/71c3963a-5e07-42d1-8dfe-91c547eea7cf differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/8fbe5789-c5a8-4d89-b8f7-f7db88596ec8 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/8fbe5789-c5a8-4d89-b8f7-f7db88596ec8
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/8fbe5789-c5a8-4d89-b8f7-f7db88596ec8 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/97f6c7df-f963-4841-85b5-d3741b12ff76 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/97f6c7df-f963-4841-85b5-d3741b12ff76
new file mode 100644
index 00000000000..e6a957bb963
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/97f6c7df-f963-4841-85b5-d3741b12ff76 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/9c63a3e5-54c8-4c92-a0ce-990367e170e8 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/9c63a3e5-54c8-4c92-a0ce-990367e170e8
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/9c63a3e5-54c8-4c92-a0ce-990367e170e8 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/_metadata b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/_metadata
new file mode 100644
index 00000000000..cd3ab6e37d6
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/_metadata differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/b4cbb71c-59d7-4e1f-bd7e-252158995a63 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/b4cbb71c-59d7-4e1f-bd7e-252158995a63
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/b4cbb71c-59d7-4e1f-bd7e-252158995a63 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/bf4f5d43-ea9c-49af-a2e7-6f6258f8ca73 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/bf4f5d43-ea9c-49af-a2e7-6f6258f8ca73
new file mode 100644
index 00000000000..719c2ab8b97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/bf4f5d43-ea9c-49af-a2e7-6f6258f8ca73 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/c0348fbc-6a9c-409f-8636-7c906c3a0f0d b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/c0348fbc-6a9c-409f-8636-7c906c3a0f0d
new file mode 100644
index 00000000000..2f020711c6f
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/c0348fbc-6a9c-409f-8636-7c906c3a0f0d differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/c231e227-3f0d-4059-bd28-d3ae73852dc5 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/c231e227-3f0d-4059-bd28-d3ae73852dc5
new file mode 100644
index 00000000000..53252da759e
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/c231e227-3f0d-4059-bd28-d3ae73852dc5 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/dc429776-bf1f-4cb3-8f1c-ac65b7d33f25 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/dc429776-bf1f-4cb3-8f1c-ac65b7d33f25
new file mode 100644
index 00000000000..c4f536420f8
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/dc429776-bf1f-4cb3-8f1c-ac65b7d33f25 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/e2ecb84a-379a-4165-b44b-536025b00037 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/e2ecb84a-379a-4165-b44b-536025b00037
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/e2ecb84a-379a-4165-b44b-536025b00037 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/e35de65e-cefb-4b56-9e13-1caff374156c b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/e35de65e-cefb-4b56-9e13-1caff374156c
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint-native/e35de65e-cefb-4b56-9e13-1caff374156c differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/2e39b700-e7ff-4b5e-9027-17d88631f9ac b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/2e39b700-e7ff-4b5e-9027-17d88631f9ac
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/2e39b700-e7ff-4b5e-9027-17d88631f9ac differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/33e9912e-db54-466e-b52e-1de8a7e7e643 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/33e9912e-db54-466e-b52e-1de8a7e7e643
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/33e9912e-db54-466e-b52e-1de8a7e7e643 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/3ba97e5c-9e89-4508-95fc-c200cf85c79c b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/3ba97e5c-9e89-4508-95fc-c200cf85c79c
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/3ba97e5c-9e89-4508-95fc-c200cf85c79c differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/471f4083-15b6-4c97-8d93-713abfacbc37 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/471f4083-15b6-4c97-8d93-713abfacbc37
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/471f4083-15b6-4c97-8d93-713abfacbc37 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/4f8ab9ee-133f-4dca-a83e-81aea37c6a43 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/4f8ab9ee-133f-4dca-a83e-81aea37c6a43
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/4f8ab9ee-133f-4dca-a83e-81aea37c6a43 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/5358eecb-51a0-4c3e-8ad4-8677cc77d2db b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/5358eecb-51a0-4c3e-8ad4-8677cc77d2db
new file mode 100644
index 00000000000..2f020711c6f
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/5358eecb-51a0-4c3e-8ad4-8677cc77d2db differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/54699f69-0dfd-494b-b4fe-1000bc6364e6 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/54699f69-0dfd-494b-b4fe-1000bc6364e6
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/54699f69-0dfd-494b-b4fe-1000bc6364e6 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/5491d99c-ae9a-4e39-b6e3-02340ee3a8fe b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/5491d99c-ae9a-4e39-b6e3-02340ee3a8fe
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/5491d99c-ae9a-4e39-b6e3-02340ee3a8fe differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/5fd6bd5b-e28e-4854-8762-d8f3081218a2 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/5fd6bd5b-e28e-4854-8762-d8f3081218a2
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/5fd6bd5b-e28e-4854-8762-d8f3081218a2 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/66481c2d-f544-4ad0-a99d-d818ea30de0a b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/66481c2d-f544-4ad0-a99d-d818ea30de0a
new file mode 100644
index 00000000000..719c2ab8b97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/66481c2d-f544-4ad0-a99d-d818ea30de0a differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/80338935-5c3b-4d8c-9178-990d16db5475 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/80338935-5c3b-4d8c-9178-990d16db5475
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/80338935-5c3b-4d8c-9178-990d16db5475 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/8158597f-8051-4038-be62-200e3af3c9b7 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/8158597f-8051-4038-be62-200e3af3c9b7
new file mode 100644
index 00000000000..719c2ab8b97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/8158597f-8051-4038-be62-200e3af3c9b7 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/_metadata b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/_metadata
new file mode 100644
index 00000000000..01b4ce60e59
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/a0c038b2-cdd4-4256-849a-10e6f13306c3 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/a0c038b2-cdd4-4256-849a-10e6f13306c3
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/a0c038b2-cdd4-4256-849a-10e6f13306c3 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/a6db53a6-7bb3-41dd-af83-a14de7146ec9 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/a6db53a6-7bb3-41dd-af83-a14de7146ec9
new file mode 100644
index 00000000000..2f020711c6f
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/a6db53a6-7bb3-41dd-af83-a14de7146ec9 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/b5a361ce-1fa8-4026-845a-20ae8174fe38 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/b5a361ce-1fa8-4026-845a-20ae8174fe38
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/b5a361ce-1fa8-4026-845a-20ae8174fe38 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/c0103aa6-6c88-44ef-af9f-14a53cf62038 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/c0103aa6-6c88-44ef-af9f-14a53cf62038
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/c0103aa6-6c88-44ef-af9f-14a53cf62038 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/c2cf38cb-556e-4994-9dc9-27612c82870e b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/c2cf38cb-556e-4994-9dc9-27612c82870e
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/c2cf38cb-556e-4994-9dc9-27612c82870e differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/e9d785e5-205f-4f23-938e-73ab621ecc00 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/e9d785e5-205f-4f23-938e-73ab621ecc00
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/e9d785e5-205f-4f23-938e-73ab621ecc00 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/ef0e6568-4a6b-4df9-9f87-4852dff90af4 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/ef0e6568-4a6b-4df9-9f87-4852dff90af4
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/ef0e6568-4a6b-4df9-9f87-4852dff90af4 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/f0a4d522-a3c4-4d54-829b-17947311cb9f b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/f0a4d522-a3c4-4d54-829b-17947311cb9f
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-hashmap-savepoint/f0a4d522-a3c4-4d54-829b-17947311cb9f differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/0390d116-06b3-42d4-bc39-675b7a52dcfc b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/0390d116-06b3-42d4-bc39-675b7a52dcfc
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/0390d116-06b3-42d4-bc39-675b7a52dcfc differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/203f6aa2-f654-4fe8-8c60-5d6a0bc4f6e7 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/203f6aa2-f654-4fe8-8c60-5d6a0bc4f6e7
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/203f6aa2-f654-4fe8-8c60-5d6a0bc4f6e7 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/376e2a5f-e03a-4a0b-9320-9f7bea6228a1 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/376e2a5f-e03a-4a0b-9320-9f7bea6228a1
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/376e2a5f-e03a-4a0b-9320-9f7bea6228a1 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/3bb74f35-9f8d-4f3f-9018-7d9ef5a2de16 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/3bb74f35-9f8d-4f3f-9018-7d9ef5a2de16
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/3bb74f35-9f8d-4f3f-9018-7d9ef5a2de16 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/4cb2044a-3a61-4a13-a873-34fab4c79753 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/4cb2044a-3a61-4a13-a873-34fab4c79753
new file mode 100644
index 00000000000..2f020711c6f
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/4cb2044a-3a61-4a13-a873-34fab4c79753 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/83cb91cc-acb8-44e8-93c6-8582ecf43bdc b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/83cb91cc-acb8-44e8-93c6-8582ecf43bdc
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/83cb91cc-acb8-44e8-93c6-8582ecf43bdc differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/948a610c-ec84-4a36-b82b-c69f9849ff27 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/948a610c-ec84-4a36-b82b-c69f9849ff27
new file mode 100644
index 00000000000..719c2ab8b97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/948a610c-ec84-4a36-b82b-c69f9849ff27 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/94db1a61-29d5-43e0-bcad-3c8ac0be7f1e b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/94db1a61-29d5-43e0-bcad-3c8ac0be7f1e
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/94db1a61-29d5-43e0-bcad-3c8ac0be7f1e differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/_metadata b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/_metadata
new file mode 100644
index 00000000000..490eb230730
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/_metadata differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/a456fb85-0c41-4186-9dd1-cbf5a4098da5 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/a456fb85-0c41-4186-9dd1-cbf5a4098da5
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/a456fb85-0c41-4186-9dd1-cbf5a4098da5 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/cb6ad731-8f58-4c1f-984c-2f69a3d8f7f5 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/cb6ad731-8f58-4c1f-984c-2f69a3d8f7f5
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/cb6ad731-8f58-4c1f-984c-2f69a3d8f7f5 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/eef8265e-a96b-44c3-bd09-dc63b6a7a721 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/eef8265e-a96b-44c3-bd09-dc63b6a7a721
new file mode 100644
index 00000000000..2f020711c6f
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/eef8265e-a96b-44c3-bd09-dc63b6a7a721 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/f11589d5-b382-4679-b891-91210453d218 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/f11589d5-b382-4679-b891-91210453d218
new file mode 100644
index 00000000000..719c2ab8b97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-checkpoint/f11589d5-b382-4679-b891-91210453d218 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/0046924f-7506-4764-b0df-0abb64e5090c b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/0046924f-7506-4764-b0df-0abb64e5090c
new file mode 100644
index 00000000000..4fb93d2e8ac
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/0046924f-7506-4764-b0df-0abb64e5090c differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/054ab4aa-2aa8-4031-97d6-775464674401 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/054ab4aa-2aa8-4031-97d6-775464674401
new file mode 100644
index 00000000000..4fb93d2e8ac
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/054ab4aa-2aa8-4031-97d6-775464674401 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/0dec7bd0-e63b-4b73-9f19-f66946297055 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/0dec7bd0-e63b-4b73-9f19-f66946297055
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/0dec7bd0-e63b-4b73-9f19-f66946297055 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/0e60de9e-a5ea-470c-a9a8-fe4daafc63c3 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/0e60de9e-a5ea-470c-a9a8-fe4daafc63c3
new file mode 100644
index 00000000000..4fb93d2e8ac
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/0e60de9e-a5ea-470c-a9a8-fe4daafc63c3 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/112f324b-29dc-497a-873d-9c0f330c9077 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/112f324b-29dc-497a-873d-9c0f330c9077
new file mode 100644
index 00000000000..2f020711c6f
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/112f324b-29dc-497a-873d-9c0f330c9077 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/155bc646-c73a-4d7d-91b5-f5b0bf87f0c6 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/155bc646-c73a-4d7d-91b5-f5b0bf87f0c6
new file mode 100644
index 00000000000..ef198956648
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/155bc646-c73a-4d7d-91b5-f5b0bf87f0c6
@@ -0,0 +1,362 @@
+# This is a RocksDB option file.
+#
+# For detailed file format spec, please refer to the example file
+# in examples/rocksdb_option_file_example.ini
+#
+
+[Version]
+ rocksdb_version=6.20.3
+ options_file_version=1.1
+
+[DBOptions]
+ max_background_flushes=-1
+ compaction_readahead_size=0
+ strict_bytes_per_sync=false
+ wal_bytes_per_sync=0
+ max_open_files=-1
+ stats_history_buffer_size=1048576
+ max_total_wal_size=0
+ stats_persist_period_sec=600
+ stats_dump_period_sec=0
+ avoid_flush_during_shutdown=false
+ max_subcompactions=1
+ bytes_per_sync=0
+ delayed_write_rate=16777216
+ max_background_compactions=-1
+ max_background_jobs=2
+ delete_obsolete_files_period_micros=21600000000
+ writable_file_max_buffer_size=1048576
+ base_background_compactions=-1
+ allow_data_in_errors=false
+ max_bgerror_resume_count=2147483647
+ best_efforts_recovery=false
+ write_dbid_to_manifest=false
+ atomic_flush=false
+ manual_wal_flush=false
+ two_write_queues=false
+ preserve_deletes=false
+ avoid_flush_during_recovery=false
+ dump_malloc_stats=false
+ info_log_level=INFO_LEVEL
+ access_hint_on_compaction_start=NORMAL
+ use_adaptive_mutex=false
+ max_write_batch_group_size_bytes=1048576
+ wal_recovery_mode=kPointInTimeRecovery
+ bgerror_resume_retry_interval=1000000
+ paranoid_checks=true
+ WAL_size_limit_MB=0
+ allow_concurrent_memtable_write=true
+ allow_ingest_behind=false
+ fail_if_options_file_error=false
+ persist_stats_to_disk=false
+ WAL_ttl_seconds=0
+ wal_dir=/var/folders/52/5ypclyt917l8h1pfdrt_f8lw0000gp/T/junit3132181552529320749/junit4634197453637198439/minicluster_43556b1fee64a718f2d6ddd8fcde6f81/tm_0/tmp/job_9b7e081d5acd797d353af661fbe575e1_op_CoBroadcastWithKeyedOperator_12d7d939fd56473cac7cff0603179a41__1_4__uuid_8045c65d-a9a3-4084-ace3-1be4fe6d52d6/db
+ keep_log_file_num=4
+ table_cache_numshardbits=6
+ max_file_opening_threads=16
+ use_fsync=false
+ unordered_write=false
+ random_access_max_buffer_size=1048576
+ db_write_buffer_size=0
+ allow_2pc=false
+ skip_checking_sst_file_sizes_on_db_open=false
+ write_thread_slow_yield_usec=3
+ skip_stats_update_on_db_open=false
+ track_and_verify_wals_in_manifest=false
+ error_if_exists=false
+ manifest_preallocation_size=4194304
+ is_fd_close_on_exec=true
+ max_log_file_size=26214400
+ advise_random_on_open=true
+ use_direct_reads=false
+ write_thread_max_yield_usec=100
+ enable_write_thread_adaptive_yield=true
+ create_missing_column_families=false
+ create_if_missing=true
+ log_file_time_to_roll=0
+ use_direct_io_for_flush_and_compaction=false
+ avoid_unnecessary_blocking_io=false
+ allow_fallocate=true
+ max_manifest_file_size=1073741824
+ enable_thread_tracking=false
+ recycle_log_file_num=0
+ db_host_id=__hostname__
+ allow_mmap_reads=false
+ log_readahead_size=0
+ enable_pipelined_write=false
+ new_table_reader_for_compaction_inputs=false
+ allow_mmap_writes=false
+
+
+[CFOptions "default"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "default"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/processing_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/processing_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/event_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/event_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/1b4aec92-0f00-4a2a-bdd5-43b2dc36d075 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/1b4aec92-0f00-4a2a-bdd5-43b2dc36d075
new file mode 100644
index 00000000000..cacca7574c0
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/1b4aec92-0f00-4a2a-bdd5-43b2dc36d075
@@ -0,0 +1 @@
+MANIFEST-000004
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/296b75b7-b072-47fa-a7a2-b379cfc6bae2 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/296b75b7-b072-47fa-a7a2-b379cfc6bae2
new file mode 100644
index 00000000000..2e7467edbc0
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/296b75b7-b072-47fa-a7a2-b379cfc6bae2
@@ -0,0 +1,362 @@
+# This is a RocksDB option file.
+#
+# For detailed file format spec, please refer to the example file
+# in examples/rocksdb_option_file_example.ini
+#
+
+[Version]
+ rocksdb_version=6.20.3
+ options_file_version=1.1
+
+[DBOptions]
+ max_background_flushes=-1
+ compaction_readahead_size=0
+ strict_bytes_per_sync=false
+ wal_bytes_per_sync=0
+ max_open_files=-1
+ stats_history_buffer_size=1048576
+ max_total_wal_size=0
+ stats_persist_period_sec=600
+ stats_dump_period_sec=0
+ avoid_flush_during_shutdown=false
+ max_subcompactions=1
+ bytes_per_sync=0
+ delayed_write_rate=16777216
+ max_background_compactions=-1
+ max_background_jobs=2
+ delete_obsolete_files_period_micros=21600000000
+ writable_file_max_buffer_size=1048576
+ base_background_compactions=-1
+ allow_data_in_errors=false
+ max_bgerror_resume_count=2147483647
+ best_efforts_recovery=false
+ write_dbid_to_manifest=false
+ atomic_flush=false
+ manual_wal_flush=false
+ two_write_queues=false
+ preserve_deletes=false
+ avoid_flush_during_recovery=false
+ dump_malloc_stats=false
+ info_log_level=INFO_LEVEL
+ access_hint_on_compaction_start=NORMAL
+ use_adaptive_mutex=false
+ max_write_batch_group_size_bytes=1048576
+ wal_recovery_mode=kPointInTimeRecovery
+ bgerror_resume_retry_interval=1000000
+ paranoid_checks=true
+ WAL_size_limit_MB=0
+ allow_concurrent_memtable_write=true
+ allow_ingest_behind=false
+ fail_if_options_file_error=false
+ persist_stats_to_disk=false
+ WAL_ttl_seconds=0
+ wal_dir=/var/folders/52/5ypclyt917l8h1pfdrt_f8lw0000gp/T/junit3132181552529320749/junit4634197453637198439/minicluster_43556b1fee64a718f2d6ddd8fcde6f81/tm_0/tmp/job_9b7e081d5acd797d353af661fbe575e1_op_CoBroadcastWithKeyedOperator_12d7d939fd56473cac7cff0603179a41__2_4__uuid_4f9fc037-fbd1-4c49-832a-592be39b5fe2/db
+ keep_log_file_num=4
+ table_cache_numshardbits=6
+ max_file_opening_threads=16
+ use_fsync=false
+ unordered_write=false
+ random_access_max_buffer_size=1048576
+ db_write_buffer_size=0
+ allow_2pc=false
+ skip_checking_sst_file_sizes_on_db_open=false
+ write_thread_slow_yield_usec=3
+ skip_stats_update_on_db_open=false
+ track_and_verify_wals_in_manifest=false
+ error_if_exists=false
+ manifest_preallocation_size=4194304
+ is_fd_close_on_exec=true
+ max_log_file_size=26214400
+ advise_random_on_open=true
+ use_direct_reads=false
+ write_thread_max_yield_usec=100
+ enable_write_thread_adaptive_yield=true
+ create_missing_column_families=false
+ create_if_missing=true
+ log_file_time_to_roll=0
+ use_direct_io_for_flush_and_compaction=false
+ avoid_unnecessary_blocking_io=false
+ allow_fallocate=true
+ max_manifest_file_size=1073741824
+ enable_thread_tracking=false
+ recycle_log_file_num=0
+ db_host_id=__hostname__
+ allow_mmap_reads=false
+ log_readahead_size=0
+ enable_pipelined_write=false
+ new_table_reader_for_compaction_inputs=false
+ allow_mmap_writes=false
+
+
+[CFOptions "default"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "default"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/processing_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/processing_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/event_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/event_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/2a73a906-56db-4e22-9424-11666698c772 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/2a73a906-56db-4e22-9424-11666698c772
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/2a73a906-56db-4e22-9424-11666698c772 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/35920931-8312-4e75-8b96-22284f4065a9 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/35920931-8312-4e75-8b96-22284f4065a9
new file mode 100644
index 00000000000..6450ffb19f3
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/35920931-8312-4e75-8b96-22284f4065a9
@@ -0,0 +1,362 @@
+# This is a RocksDB option file.
+#
+# For detailed file format spec, please refer to the example file
+# in examples/rocksdb_option_file_example.ini
+#
+
+[Version]
+ rocksdb_version=6.20.3
+ options_file_version=1.1
+
+[DBOptions]
+ max_background_flushes=-1
+ compaction_readahead_size=0
+ strict_bytes_per_sync=false
+ wal_bytes_per_sync=0
+ max_open_files=-1
+ stats_history_buffer_size=1048576
+ max_total_wal_size=0
+ stats_persist_period_sec=600
+ stats_dump_period_sec=0
+ avoid_flush_during_shutdown=false
+ max_subcompactions=1
+ bytes_per_sync=0
+ delayed_write_rate=16777216
+ max_background_compactions=-1
+ max_background_jobs=2
+ delete_obsolete_files_period_micros=21600000000
+ writable_file_max_buffer_size=1048576
+ base_background_compactions=-1
+ allow_data_in_errors=false
+ max_bgerror_resume_count=2147483647
+ best_efforts_recovery=false
+ write_dbid_to_manifest=false
+ atomic_flush=false
+ manual_wal_flush=false
+ two_write_queues=false
+ preserve_deletes=false
+ avoid_flush_during_recovery=false
+ dump_malloc_stats=false
+ info_log_level=INFO_LEVEL
+ access_hint_on_compaction_start=NORMAL
+ use_adaptive_mutex=false
+ max_write_batch_group_size_bytes=1048576
+ wal_recovery_mode=kPointInTimeRecovery
+ bgerror_resume_retry_interval=1000000
+ paranoid_checks=true
+ WAL_size_limit_MB=0
+ allow_concurrent_memtable_write=true
+ allow_ingest_behind=false
+ fail_if_options_file_error=false
+ persist_stats_to_disk=false
+ WAL_ttl_seconds=0
+ wal_dir=/var/folders/52/5ypclyt917l8h1pfdrt_f8lw0000gp/T/junit3132181552529320749/junit4634197453637198439/minicluster_43556b1fee64a718f2d6ddd8fcde6f81/tm_0/tmp/job_9b7e081d5acd797d353af661fbe575e1_op_CoBroadcastWithKeyedOperator_56a26c4c54bda3adf3700194db4afe93__1_4__uuid_e4e2b227-2892-4ad7-bb73-42941086fd31/db
+ keep_log_file_num=4
+ table_cache_numshardbits=6
+ max_file_opening_threads=16
+ use_fsync=false
+ unordered_write=false
+ random_access_max_buffer_size=1048576
+ db_write_buffer_size=0
+ allow_2pc=false
+ skip_checking_sst_file_sizes_on_db_open=false
+ write_thread_slow_yield_usec=3
+ skip_stats_update_on_db_open=false
+ track_and_verify_wals_in_manifest=false
+ error_if_exists=false
+ manifest_preallocation_size=4194304
+ is_fd_close_on_exec=true
+ max_log_file_size=26214400
+ advise_random_on_open=true
+ use_direct_reads=false
+ write_thread_max_yield_usec=100
+ enable_write_thread_adaptive_yield=true
+ create_missing_column_families=false
+ create_if_missing=true
+ log_file_time_to_roll=0
+ use_direct_io_for_flush_and_compaction=false
+ avoid_unnecessary_blocking_io=false
+ allow_fallocate=true
+ max_manifest_file_size=1073741824
+ enable_thread_tracking=false
+ recycle_log_file_num=0
+ db_host_id=__hostname__
+ allow_mmap_reads=false
+ log_readahead_size=0
+ enable_pipelined_write=false
+ new_table_reader_for_compaction_inputs=false
+ allow_mmap_writes=false
+
+
+[CFOptions "default"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "default"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/processing_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/processing_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/event_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/event_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/38d42b00-e95f-4ece-9181-aa6b2cf112c8 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/38d42b00-e95f-4ece-9181-aa6b2cf112c8
new file mode 100644
index 00000000000..cacca7574c0
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/38d42b00-e95f-4ece-9181-aa6b2cf112c8
@@ -0,0 +1 @@
+MANIFEST-000004
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/3ed79b35-9cce-484b-9518-1d8c8e908f72 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/3ed79b35-9cce-484b-9518-1d8c8e908f72
new file mode 100644
index 00000000000..cacca7574c0
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/3ed79b35-9cce-484b-9518-1d8c8e908f72
@@ -0,0 +1 @@
+MANIFEST-000004
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/45b19d03-839d-4406-8a5e-c82d0395e817 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/45b19d03-839d-4406-8a5e-c82d0395e817
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/45b19d03-839d-4406-8a5e-c82d0395e817 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/4c946e1c-67f7-4e78-afef-280fe43c0245 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/4c946e1c-67f7-4e78-afef-280fe43c0245
new file mode 100644
index 00000000000..4fb93d2e8ac
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/4c946e1c-67f7-4e78-afef-280fe43c0245 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/4f475acb-f6d4-448f-a783-9c1aa8a14948 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/4f475acb-f6d4-448f-a783-9c1aa8a14948
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/4f475acb-f6d4-448f-a783-9c1aa8a14948 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/58465b8e-9415-47ac-ba59-3f1858545c7a b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/58465b8e-9415-47ac-ba59-3f1858545c7a
new file mode 100644
index 00000000000..4fb93d2e8ac
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/58465b8e-9415-47ac-ba59-3f1858545c7a differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/5de7c098-d4a5-444f-aeea-9ba75eac26f7 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/5de7c098-d4a5-444f-aeea-9ba75eac26f7
new file mode 100644
index 00000000000..4fb93d2e8ac
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/5de7c098-d4a5-444f-aeea-9ba75eac26f7 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/63df9706-33e9-4acf-9be4-8eb1b71f4c42 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/63df9706-33e9-4acf-9be4-8eb1b71f4c42
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/63df9706-33e9-4acf-9be4-8eb1b71f4c42 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/66d713b7-9829-4198-9050-1148e656474a b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/66d713b7-9829-4198-9050-1148e656474a
new file mode 100644
index 00000000000..7e16471a2f9
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/66d713b7-9829-4198-9050-1148e656474a
@@ -0,0 +1,362 @@
+# This is a RocksDB option file.
+#
+# For detailed file format spec, please refer to the example file
+# in examples/rocksdb_option_file_example.ini
+#
+
+[Version]
+ rocksdb_version=6.20.3
+ options_file_version=1.1
+
+[DBOptions]
+ max_background_flushes=-1
+ compaction_readahead_size=0
+ strict_bytes_per_sync=false
+ wal_bytes_per_sync=0
+ max_open_files=-1
+ stats_history_buffer_size=1048576
+ max_total_wal_size=0
+ stats_persist_period_sec=600
+ stats_dump_period_sec=0
+ avoid_flush_during_shutdown=false
+ max_subcompactions=1
+ bytes_per_sync=0
+ delayed_write_rate=16777216
+ max_background_compactions=-1
+ max_background_jobs=2
+ delete_obsolete_files_period_micros=21600000000
+ writable_file_max_buffer_size=1048576
+ base_background_compactions=-1
+ allow_data_in_errors=false
+ max_bgerror_resume_count=2147483647
+ best_efforts_recovery=false
+ write_dbid_to_manifest=false
+ atomic_flush=false
+ manual_wal_flush=false
+ two_write_queues=false
+ preserve_deletes=false
+ avoid_flush_during_recovery=false
+ dump_malloc_stats=false
+ info_log_level=INFO_LEVEL
+ access_hint_on_compaction_start=NORMAL
+ use_adaptive_mutex=false
+ max_write_batch_group_size_bytes=1048576
+ wal_recovery_mode=kPointInTimeRecovery
+ bgerror_resume_retry_interval=1000000
+ paranoid_checks=true
+ WAL_size_limit_MB=0
+ allow_concurrent_memtable_write=true
+ allow_ingest_behind=false
+ fail_if_options_file_error=false
+ persist_stats_to_disk=false
+ WAL_ttl_seconds=0
+ wal_dir=/var/folders/52/5ypclyt917l8h1pfdrt_f8lw0000gp/T/junit3132181552529320749/junit4634197453637198439/minicluster_43556b1fee64a718f2d6ddd8fcde6f81/tm_0/tmp/job_9b7e081d5acd797d353af661fbe575e1_op_CoBroadcastWithKeyedOperator_12d7d939fd56473cac7cff0603179a41__4_4__uuid_da05d6c5-563c-49aa-9404-29e2895366ed/db
+ keep_log_file_num=4
+ table_cache_numshardbits=6
+ max_file_opening_threads=16
+ use_fsync=false
+ unordered_write=false
+ random_access_max_buffer_size=1048576
+ db_write_buffer_size=0
+ allow_2pc=false
+ skip_checking_sst_file_sizes_on_db_open=false
+ write_thread_slow_yield_usec=3
+ skip_stats_update_on_db_open=false
+ track_and_verify_wals_in_manifest=false
+ error_if_exists=false
+ manifest_preallocation_size=4194304
+ is_fd_close_on_exec=true
+ max_log_file_size=26214400
+ advise_random_on_open=true
+ use_direct_reads=false
+ write_thread_max_yield_usec=100
+ enable_write_thread_adaptive_yield=true
+ create_missing_column_families=false
+ create_if_missing=true
+ log_file_time_to_roll=0
+ use_direct_io_for_flush_and_compaction=false
+ avoid_unnecessary_blocking_io=false
+ allow_fallocate=true
+ max_manifest_file_size=1073741824
+ enable_thread_tracking=false
+ recycle_log_file_num=0
+ db_host_id=__hostname__
+ allow_mmap_reads=false
+ log_readahead_size=0
+ enable_pipelined_write=false
+ new_table_reader_for_compaction_inputs=false
+ allow_mmap_writes=false
+
+
+[CFOptions "default"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "default"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/processing_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/processing_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/event_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/event_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/6ffccc86-e6b3-4750-90ab-bd4e3a67badc b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/6ffccc86-e6b3-4750-90ab-bd4e3a67badc
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/6ffccc86-e6b3-4750-90ab-bd4e3a67badc differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7181a6d4-8773-43b3-8aea-c12ebb6c2cbf b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7181a6d4-8773-43b3-8aea-c12ebb6c2cbf
new file mode 100644
index 00000000000..4fb93d2e8ac
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7181a6d4-8773-43b3-8aea-c12ebb6c2cbf differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7b06051f-16cc-4671-8148-2299a09ab676 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7b06051f-16cc-4671-8148-2299a09ab676
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7b06051f-16cc-4671-8148-2299a09ab676 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7b69c00e-2dc0-4380-9058-5a8991e91e50 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7b69c00e-2dc0-4380-9058-5a8991e91e50
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7b69c00e-2dc0-4380-9058-5a8991e91e50 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7bce7df8-6286-4cf3-bb0d-bea886feeded b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7bce7df8-6286-4cf3-bb0d-bea886feeded
new file mode 100644
index 00000000000..cacca7574c0
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7bce7df8-6286-4cf3-bb0d-bea886feeded
@@ -0,0 +1 @@
+MANIFEST-000004
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7e0174af-86ac-4f38-8319-9633c0ee51c4 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7e0174af-86ac-4f38-8319-9633c0ee51c4
new file mode 100644
index 00000000000..719c2ab8b97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/7e0174af-86ac-4f38-8319-9633c0ee51c4 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/8502132f-9182-4925-9b1b-8c383fd9c0ad b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/8502132f-9182-4925-9b1b-8c383fd9c0ad
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/8502132f-9182-4925-9b1b-8c383fd9c0ad differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/8c7e6de2-2c02-47e7-b62d-ebcc12c745f8 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/8c7e6de2-2c02-47e7-b62d-ebcc12c745f8
new file mode 100644
index 00000000000..cacca7574c0
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/8c7e6de2-2c02-47e7-b62d-ebcc12c745f8
@@ -0,0 +1 @@
+MANIFEST-000004
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/8dc0f73d-6e81-42a0-a43e-a4c1af043d22 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/8dc0f73d-6e81-42a0-a43e-a4c1af043d22
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/8dc0f73d-6e81-42a0-a43e-a4c1af043d22 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/9174bd29-8a87-4397-9ed9-c983581f797a b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/9174bd29-8a87-4397-9ed9-c983581f797a
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/9174bd29-8a87-4397-9ed9-c983581f797a differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/9356ac80-1be8-451d-8895-e2ec34e4cedb b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/9356ac80-1be8-451d-8895-e2ec34e4cedb
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/9356ac80-1be8-451d-8895-e2ec34e4cedb differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/9e22fc6b-b913-4465-9382-9903720344b0 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/9e22fc6b-b913-4465-9382-9903720344b0
new file mode 100644
index 00000000000..7a17253ff25
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/9e22fc6b-b913-4465-9382-9903720344b0
@@ -0,0 +1,362 @@
+# This is a RocksDB option file.
+#
+# For detailed file format spec, please refer to the example file
+# in examples/rocksdb_option_file_example.ini
+#
+
+[Version]
+ rocksdb_version=6.20.3
+ options_file_version=1.1
+
+[DBOptions]
+ max_background_flushes=-1
+ compaction_readahead_size=0
+ strict_bytes_per_sync=false
+ wal_bytes_per_sync=0
+ max_open_files=-1
+ stats_history_buffer_size=1048576
+ max_total_wal_size=0
+ stats_persist_period_sec=600
+ stats_dump_period_sec=0
+ avoid_flush_during_shutdown=false
+ max_subcompactions=1
+ bytes_per_sync=0
+ delayed_write_rate=16777216
+ max_background_compactions=-1
+ max_background_jobs=2
+ delete_obsolete_files_period_micros=21600000000
+ writable_file_max_buffer_size=1048576
+ base_background_compactions=-1
+ allow_data_in_errors=false
+ max_bgerror_resume_count=2147483647
+ best_efforts_recovery=false
+ write_dbid_to_manifest=false
+ atomic_flush=false
+ manual_wal_flush=false
+ two_write_queues=false
+ preserve_deletes=false
+ avoid_flush_during_recovery=false
+ dump_malloc_stats=false
+ info_log_level=INFO_LEVEL
+ access_hint_on_compaction_start=NORMAL
+ use_adaptive_mutex=false
+ max_write_batch_group_size_bytes=1048576
+ wal_recovery_mode=kPointInTimeRecovery
+ bgerror_resume_retry_interval=1000000
+ paranoid_checks=true
+ WAL_size_limit_MB=0
+ allow_concurrent_memtable_write=true
+ allow_ingest_behind=false
+ fail_if_options_file_error=false
+ persist_stats_to_disk=false
+ WAL_ttl_seconds=0
+ wal_dir=/var/folders/52/5ypclyt917l8h1pfdrt_f8lw0000gp/T/junit3132181552529320749/junit4634197453637198439/minicluster_43556b1fee64a718f2d6ddd8fcde6f81/tm_0/tmp/job_9b7e081d5acd797d353af661fbe575e1_op_CoBroadcastWithKeyedOperator_56a26c4c54bda3adf3700194db4afe93__4_4__uuid_5874d86d-ecc4-4473-9f88-06d35a1fb5d5/db
+ keep_log_file_num=4
+ table_cache_numshardbits=6
+ max_file_opening_threads=16
+ use_fsync=false
+ unordered_write=false
+ random_access_max_buffer_size=1048576
+ db_write_buffer_size=0
+ allow_2pc=false
+ skip_checking_sst_file_sizes_on_db_open=false
+ write_thread_slow_yield_usec=3
+ skip_stats_update_on_db_open=false
+ track_and_verify_wals_in_manifest=false
+ error_if_exists=false
+ manifest_preallocation_size=4194304
+ is_fd_close_on_exec=true
+ max_log_file_size=26214400
+ advise_random_on_open=true
+ use_direct_reads=false
+ write_thread_max_yield_usec=100
+ enable_write_thread_adaptive_yield=true
+ create_missing_column_families=false
+ create_if_missing=true
+ log_file_time_to_roll=0
+ use_direct_io_for_flush_and_compaction=false
+ avoid_unnecessary_blocking_io=false
+ allow_fallocate=true
+ max_manifest_file_size=1073741824
+ enable_thread_tracking=false
+ recycle_log_file_num=0
+ db_host_id=__hostname__
+ allow_mmap_reads=false
+ log_readahead_size=0
+ enable_pipelined_write=false
+ new_table_reader_for_compaction_inputs=false
+ allow_mmap_writes=false
+
+
+[CFOptions "default"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "default"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/processing_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/processing_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/event_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/event_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/_metadata b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/_metadata
new file mode 100644
index 00000000000..a7a097c1a01
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/_metadata differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/ad7138b5-c985-4cb1-a853-c7a7de5886be b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/ad7138b5-c985-4cb1-a853-c7a7de5886be
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/ad7138b5-c985-4cb1-a853-c7a7de5886be differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/b997832d-7bbc-4028-8362-a04e9499aff2 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/b997832d-7bbc-4028-8362-a04e9499aff2
new file mode 100644
index 00000000000..cacca7574c0
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/b997832d-7bbc-4028-8362-a04e9499aff2
@@ -0,0 +1 @@
+MANIFEST-000004
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/c04ea0c0-eb22-477e-9f58-9e6e229ef61e b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/c04ea0c0-eb22-477e-9f58-9e6e229ef61e
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/c04ea0c0-eb22-477e-9f58-9e6e229ef61e differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/c3938f22-a681-4067-891b-df0bd5c9c455 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/c3938f22-a681-4067-891b-df0bd5c9c455
new file mode 100644
index 00000000000..4ae2159cc89
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/c3938f22-a681-4067-891b-df0bd5c9c455
@@ -0,0 +1,362 @@
+# This is a RocksDB option file.
+#
+# For detailed file format spec, please refer to the example file
+# in examples/rocksdb_option_file_example.ini
+#
+
+[Version]
+ rocksdb_version=6.20.3
+ options_file_version=1.1
+
+[DBOptions]
+ max_background_flushes=-1
+ compaction_readahead_size=0
+ strict_bytes_per_sync=false
+ wal_bytes_per_sync=0
+ max_open_files=-1
+ stats_history_buffer_size=1048576
+ max_total_wal_size=0
+ stats_persist_period_sec=600
+ stats_dump_period_sec=0
+ avoid_flush_during_shutdown=false
+ max_subcompactions=1
+ bytes_per_sync=0
+ delayed_write_rate=16777216
+ max_background_compactions=-1
+ max_background_jobs=2
+ delete_obsolete_files_period_micros=21600000000
+ writable_file_max_buffer_size=1048576
+ base_background_compactions=-1
+ allow_data_in_errors=false
+ max_bgerror_resume_count=2147483647
+ best_efforts_recovery=false
+ write_dbid_to_manifest=false
+ atomic_flush=false
+ manual_wal_flush=false
+ two_write_queues=false
+ preserve_deletes=false
+ avoid_flush_during_recovery=false
+ dump_malloc_stats=false
+ info_log_level=INFO_LEVEL
+ access_hint_on_compaction_start=NORMAL
+ use_adaptive_mutex=false
+ max_write_batch_group_size_bytes=1048576
+ wal_recovery_mode=kPointInTimeRecovery
+ bgerror_resume_retry_interval=1000000
+ paranoid_checks=true
+ WAL_size_limit_MB=0
+ allow_concurrent_memtable_write=true
+ allow_ingest_behind=false
+ fail_if_options_file_error=false
+ persist_stats_to_disk=false
+ WAL_ttl_seconds=0
+ wal_dir=/var/folders/52/5ypclyt917l8h1pfdrt_f8lw0000gp/T/junit3132181552529320749/junit4634197453637198439/minicluster_43556b1fee64a718f2d6ddd8fcde6f81/tm_0/tmp/job_9b7e081d5acd797d353af661fbe575e1_op_CoBroadcastWithKeyedOperator_12d7d939fd56473cac7cff0603179a41__3_4__uuid_80fd3708-5823-4fa7-ae1f-5fa5b0301604/db
+ keep_log_file_num=4
+ table_cache_numshardbits=6
+ max_file_opening_threads=16
+ use_fsync=false
+ unordered_write=false
+ random_access_max_buffer_size=1048576
+ db_write_buffer_size=0
+ allow_2pc=false
+ skip_checking_sst_file_sizes_on_db_open=false
+ write_thread_slow_yield_usec=3
+ skip_stats_update_on_db_open=false
+ track_and_verify_wals_in_manifest=false
+ error_if_exists=false
+ manifest_preallocation_size=4194304
+ is_fd_close_on_exec=true
+ max_log_file_size=26214400
+ advise_random_on_open=true
+ use_direct_reads=false
+ write_thread_max_yield_usec=100
+ enable_write_thread_adaptive_yield=true
+ create_missing_column_families=false
+ create_if_missing=true
+ log_file_time_to_roll=0
+ use_direct_io_for_flush_and_compaction=false
+ avoid_unnecessary_blocking_io=false
+ allow_fallocate=true
+ max_manifest_file_size=1073741824
+ enable_thread_tracking=false
+ recycle_log_file_num=0
+ db_host_id=__hostname__
+ allow_mmap_reads=false
+ log_readahead_size=0
+ enable_pipelined_write=false
+ new_table_reader_for_compaction_inputs=false
+ allow_mmap_writes=false
+
+
+[CFOptions "default"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "default"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/processing_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/processing_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/event_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/event_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/c9e344b7-2ada-4088-b401-525e7230c38f b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/c9e344b7-2ada-4088-b401-525e7230c38f
new file mode 100644
index 00000000000..f8899974722
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/c9e344b7-2ada-4088-b401-525e7230c38f
@@ -0,0 +1,362 @@
+# This is a RocksDB option file.
+#
+# For detailed file format spec, please refer to the example file
+# in examples/rocksdb_option_file_example.ini
+#
+
+[Version]
+ rocksdb_version=6.20.3
+ options_file_version=1.1
+
+[DBOptions]
+ max_background_flushes=-1
+ compaction_readahead_size=0
+ strict_bytes_per_sync=false
+ wal_bytes_per_sync=0
+ max_open_files=-1
+ stats_history_buffer_size=1048576
+ max_total_wal_size=0
+ stats_persist_period_sec=600
+ stats_dump_period_sec=0
+ avoid_flush_during_shutdown=false
+ max_subcompactions=1
+ bytes_per_sync=0
+ delayed_write_rate=16777216
+ max_background_compactions=-1
+ max_background_jobs=2
+ delete_obsolete_files_period_micros=21600000000
+ writable_file_max_buffer_size=1048576
+ base_background_compactions=-1
+ allow_data_in_errors=false
+ max_bgerror_resume_count=2147483647
+ best_efforts_recovery=false
+ write_dbid_to_manifest=false
+ atomic_flush=false
+ manual_wal_flush=false
+ two_write_queues=false
+ preserve_deletes=false
+ avoid_flush_during_recovery=false
+ dump_malloc_stats=false
+ info_log_level=INFO_LEVEL
+ access_hint_on_compaction_start=NORMAL
+ use_adaptive_mutex=false
+ max_write_batch_group_size_bytes=1048576
+ wal_recovery_mode=kPointInTimeRecovery
+ bgerror_resume_retry_interval=1000000
+ paranoid_checks=true
+ WAL_size_limit_MB=0
+ allow_concurrent_memtable_write=true
+ allow_ingest_behind=false
+ fail_if_options_file_error=false
+ persist_stats_to_disk=false
+ WAL_ttl_seconds=0
+ wal_dir=/var/folders/52/5ypclyt917l8h1pfdrt_f8lw0000gp/T/junit3132181552529320749/junit4634197453637198439/minicluster_43556b1fee64a718f2d6ddd8fcde6f81/tm_0/tmp/job_9b7e081d5acd797d353af661fbe575e1_op_CoBroadcastWithKeyedOperator_56a26c4c54bda3adf3700194db4afe93__2_4__uuid_48c4ee50-119e-44ef-8266-74323476570c/db
+ keep_log_file_num=4
+ table_cache_numshardbits=6
+ max_file_opening_threads=16
+ use_fsync=false
+ unordered_write=false
+ random_access_max_buffer_size=1048576
+ db_write_buffer_size=0
+ allow_2pc=false
+ skip_checking_sst_file_sizes_on_db_open=false
+ write_thread_slow_yield_usec=3
+ skip_stats_update_on_db_open=false
+ track_and_verify_wals_in_manifest=false
+ error_if_exists=false
+ manifest_preallocation_size=4194304
+ is_fd_close_on_exec=true
+ max_log_file_size=26214400
+ advise_random_on_open=true
+ use_direct_reads=false
+ write_thread_max_yield_usec=100
+ enable_write_thread_adaptive_yield=true
+ create_missing_column_families=false
+ create_if_missing=true
+ log_file_time_to_roll=0
+ use_direct_io_for_flush_and_compaction=false
+ avoid_unnecessary_blocking_io=false
+ allow_fallocate=true
+ max_manifest_file_size=1073741824
+ enable_thread_tracking=false
+ recycle_log_file_num=0
+ db_host_id=__hostname__
+ allow_mmap_reads=false
+ log_readahead_size=0
+ enable_pipelined_write=false
+ new_table_reader_for_compaction_inputs=false
+ allow_mmap_writes=false
+
+
+[CFOptions "default"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "default"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/processing_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/processing_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/event_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/event_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/cb905cef-aadb-4a61-9a73-816fb4c0b4bb b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/cb905cef-aadb-4a61-9a73-816fb4c0b4bb
new file mode 100644
index 00000000000..cacca7574c0
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/cb905cef-aadb-4a61-9a73-816fb4c0b4bb
@@ -0,0 +1 @@
+MANIFEST-000004
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/cc0b8716-f251-4429-bcbe-cae8511a9c54 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/cc0b8716-f251-4429-bcbe-cae8511a9c54
new file mode 100644
index 00000000000..2f020711c6f
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/cc0b8716-f251-4429-bcbe-cae8511a9c54 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/cd4f33b7-6c5d-4681-b7fc-d964b4b42c5f b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/cd4f33b7-6c5d-4681-b7fc-d964b4b42c5f
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/cd4f33b7-6c5d-4681-b7fc-d964b4b42c5f differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/d1b8bd46-68e1-4760-91b7-00cb2ae68fbb b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/d1b8bd46-68e1-4760-91b7-00cb2ae68fbb
new file mode 100644
index 00000000000..0e9f59ee0ec
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/d1b8bd46-68e1-4760-91b7-00cb2ae68fbb
@@ -0,0 +1,362 @@
+# This is a RocksDB option file.
+#
+# For detailed file format spec, please refer to the example file
+# in examples/rocksdb_option_file_example.ini
+#
+
+[Version]
+ rocksdb_version=6.20.3
+ options_file_version=1.1
+
+[DBOptions]
+ max_background_flushes=-1
+ compaction_readahead_size=0
+ strict_bytes_per_sync=false
+ wal_bytes_per_sync=0
+ max_open_files=-1
+ stats_history_buffer_size=1048576
+ max_total_wal_size=0
+ stats_persist_period_sec=600
+ stats_dump_period_sec=0
+ avoid_flush_during_shutdown=false
+ max_subcompactions=1
+ bytes_per_sync=0
+ delayed_write_rate=16777216
+ max_background_compactions=-1
+ max_background_jobs=2
+ delete_obsolete_files_period_micros=21600000000
+ writable_file_max_buffer_size=1048576
+ base_background_compactions=-1
+ allow_data_in_errors=false
+ max_bgerror_resume_count=2147483647
+ best_efforts_recovery=false
+ write_dbid_to_manifest=false
+ atomic_flush=false
+ manual_wal_flush=false
+ two_write_queues=false
+ preserve_deletes=false
+ avoid_flush_during_recovery=false
+ dump_malloc_stats=false
+ info_log_level=INFO_LEVEL
+ access_hint_on_compaction_start=NORMAL
+ use_adaptive_mutex=false
+ max_write_batch_group_size_bytes=1048576
+ wal_recovery_mode=kPointInTimeRecovery
+ bgerror_resume_retry_interval=1000000
+ paranoid_checks=true
+ WAL_size_limit_MB=0
+ allow_concurrent_memtable_write=true
+ allow_ingest_behind=false
+ fail_if_options_file_error=false
+ persist_stats_to_disk=false
+ WAL_ttl_seconds=0
+ wal_dir=/var/folders/52/5ypclyt917l8h1pfdrt_f8lw0000gp/T/junit3132181552529320749/junit4634197453637198439/minicluster_43556b1fee64a718f2d6ddd8fcde6f81/tm_0/tmp/job_9b7e081d5acd797d353af661fbe575e1_op_CoBroadcastWithKeyedOperator_56a26c4c54bda3adf3700194db4afe93__3_4__uuid_28e9c641-3ff1-48dc-9c0a-30fb4522d720/db
+ keep_log_file_num=4
+ table_cache_numshardbits=6
+ max_file_opening_threads=16
+ use_fsync=false
+ unordered_write=false
+ random_access_max_buffer_size=1048576
+ db_write_buffer_size=0
+ allow_2pc=false
+ skip_checking_sst_file_sizes_on_db_open=false
+ write_thread_slow_yield_usec=3
+ skip_stats_update_on_db_open=false
+ track_and_verify_wals_in_manifest=false
+ error_if_exists=false
+ manifest_preallocation_size=4194304
+ is_fd_close_on_exec=true
+ max_log_file_size=26214400
+ advise_random_on_open=true
+ use_direct_reads=false
+ write_thread_max_yield_usec=100
+ enable_write_thread_adaptive_yield=true
+ create_missing_column_families=false
+ create_if_missing=true
+ log_file_time_to_roll=0
+ use_direct_io_for_flush_and_compaction=false
+ avoid_unnecessary_blocking_io=false
+ allow_fallocate=true
+ max_manifest_file_size=1073741824
+ enable_thread_tracking=false
+ recycle_log_file_num=0
+ db_host_id=__hostname__
+ allow_mmap_reads=false
+ log_readahead_size=0
+ enable_pipelined_write=false
+ new_table_reader_for_compaction_inputs=false
+ allow_mmap_writes=false
+
+
+[CFOptions "default"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "default"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/processing_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/processing_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
+
+[CFOptions "_timer_state/event_user-timers"]
+ bottommost_compression=kDisableCompressionOption
+ sample_for_compression=0
+ blob_garbage_collection_age_cutoff=0.250000
+ arena_block_size=8388608
+ enable_blob_garbage_collection=false
+ level0_stop_writes_trigger=36
+ min_blob_size=0
+ compaction_options_universal={allow_trivial_move=false;stop_style=kCompactionStopStyleTotalSize;min_merge_width=2;compression_size_percent=-1;max_size_amplification_percent=200;max_merge_width=4294967295;size_ratio=1;}
+ target_file_size_base=67108864
+ max_bytes_for_level_base=268435456
+ memtable_whole_key_filtering=false
+ soft_pending_compaction_bytes_limit=68719476736
+ blob_compression_type=kNoCompression
+ max_write_buffer_number=2
+ ttl=2592000
+ compaction_options_fifo={allow_compaction=false;max_table_files_size=1073741824;}
+ check_flush_compaction_key_order=true
+ max_successive_merges=0
+ inplace_update_num_locks=10000
+ bottommost_compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ target_file_size_multiplier=1
+ max_bytes_for_level_multiplier_additional=1:{1}:{1}:{1}:{1}:{1}:{1}
+ enable_blob_files=false
+ level0_slowdown_writes_trigger=20
+ compression=kSnappyCompression
+ level0_file_num_compaction_trigger=4
+ blob_file_size=268435456
+ prefix_extractor=nullptr
+ max_bytes_for_level_multiplier=10.000000
+ write_buffer_size=67108864
+ disable_auto_compactions=false
+ max_compaction_bytes=1677721600
+ memtable_huge_page_size=0
+ compression_opts={enabled=false;parallel_threads=1;zstd_max_train_bytes=0;max_dict_bytes=0;strategy=0;max_dict_buffer_bytes=0;level=32767;window_bits=-14;}
+ hard_pending_compaction_bytes_limit=274877906944
+ periodic_compaction_seconds=0
+ paranoid_file_checks=false
+ memtable_prefix_bloom_size_ratio=0.000000
+ max_sequential_skip_in_iterations=8
+ report_bg_io_stats=false
+ compaction_pri=kMinOverlappingRatio
+ compaction_style=kCompactionStyleLevel
+ memtable_factory=SkipListFactory
+ comparator=leveldb.BytewiseComparator
+ bloom_locality=0
+ compaction_filter_factory=nullptr
+ min_write_buffer_number_to_merge=1
+ max_write_buffer_number_to_maintain=0
+ compaction_filter=nullptr
+ merge_operator=StringAppendTESTOperator
+ num_levels=7
+ optimize_filters_for_hits=false
+ force_consistency_checks=true
+ table_factory=BlockBasedTable
+ max_write_buffer_size_to_maintain=0
+ memtable_insert_with_hint_prefix_extractor=nullptr
+ level_compaction_dynamic_level_bytes=false
+ inplace_update_support=false
+
+[TableOptions/BlockBasedTable "_timer_state/event_user-timers"]
+ metadata_cache_options={unpartitioned_pinning=kFallback;partition_pinning=kFallback;top_level_index_pinning=kFallback;}
+ read_amp_bytes_per_bit=0
+ verify_compression=false
+ format_version=5
+ optimize_filters_for_memory=false
+ partition_filters=false
+ max_auto_readahead_size=262144
+ enable_index_compression=true
+ checksum=kCRC32c
+ index_block_restart_interval=1
+ pin_top_level_index_and_filter=true
+ block_align=false
+ block_size=4096
+ index_type=kBinarySearch
+ filter_policy=nullptr
+ metadata_block_size=4096
+ no_block_cache=false
+ whole_key_filtering=true
+ index_shortening=kShortenSeparators
+ block_size_deviation=10
+ data_block_index_type=kDataBlockBinarySearch
+ data_block_hash_table_util_ratio=0.750000
+ cache_index_and_filter_blocks=true
+ block_restart_interval=16
+ pin_l0_filter_and_index_blocks_in_cache=true
+ hash_index_allow_collision=true
+ cache_index_and_filter_blocks_with_high_priority=true
+ flush_block_policy_factory=FlushBlockBySizePolicyFactory
+
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/d245d07c-0a69-4356-abc2-a24e89869ed2 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/d245d07c-0a69-4356-abc2-a24e89869ed2
new file mode 100644
index 00000000000..719c2ab8b97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/d245d07c-0a69-4356-abc2-a24e89869ed2 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/da9b4d7c-ac30-445d-b3b0-ac742b479b24 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/da9b4d7c-ac30-445d-b3b0-ac742b479b24
new file mode 100644
index 00000000000..cacca7574c0
--- /dev/null
+++ b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/da9b4d7c-ac30-445d-b3b0-ac742b479b24
@@ -0,0 +1 @@
+MANIFEST-000004
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/f94ddae2-a9c7-48fd-86c3-ac2284d7a95c b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/f94ddae2-a9c7-48fd-86c3-ac2284d7a95c
new file mode 100644
index 00000000000..4fb93d2e8ac
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/f94ddae2-a9c7-48fd-86c3-ac2284d7a95c differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/fcb275b6-2a30-45da-9030-f9a86b1b3721 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/fcb275b6-2a30-45da-9030-f9a86b1b3721
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint-native/fcb275b6-2a30-45da-9030-f9a86b1b3721 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/053587a5-8707-44bb-80f0-3ee725ed96bc b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/053587a5-8707-44bb-80f0-3ee725ed96bc
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/053587a5-8707-44bb-80f0-3ee725ed96bc differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/09d35912-4a55-4bcd-a6a3-360f77f807c8 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/09d35912-4a55-4bcd-a6a3-360f77f807c8
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/09d35912-4a55-4bcd-a6a3-360f77f807c8 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/2e3778c2-a2ff-4787-9938-2fd05c4ea911 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/2e3778c2-a2ff-4787-9938-2fd05c4ea911
new file mode 100644
index 00000000000..719c2ab8b97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/2e3778c2-a2ff-4787-9938-2fd05c4ea911 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/30b30745-1e31-4c49-b001-6bad93fe2c14 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/30b30745-1e31-4c49-b001-6bad93fe2c14
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/30b30745-1e31-4c49-b001-6bad93fe2c14 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/37e1f016-44ec-45e8-bec4-61c6fe7b8684 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/37e1f016-44ec-45e8-bec4-61c6fe7b8684
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/37e1f016-44ec-45e8-bec4-61c6fe7b8684 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/41404971-06b4-44da-a68a-910dda186d1f b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/41404971-06b4-44da-a68a-910dda186d1f
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/41404971-06b4-44da-a68a-910dda186d1f differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/429c5d52-6b34-4b58-a1de-295fd233e72a b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/429c5d52-6b34-4b58-a1de-295fd233e72a
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/429c5d52-6b34-4b58-a1de-295fd233e72a differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/54dcb3d3-f813-4067-b08b-2bd38cf0f1a9 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/54dcb3d3-f813-4067-b08b-2bd38cf0f1a9
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/54dcb3d3-f813-4067-b08b-2bd38cf0f1a9 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/782450b9-6c45-4ac0-98c6-6da643567ca5 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/782450b9-6c45-4ac0-98c6-6da643567ca5
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/782450b9-6c45-4ac0-98c6-6da643567ca5 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/79c9bfd2-ac45-436f-be0c-cc3556561985 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/79c9bfd2-ac45-436f-be0c-cc3556561985
new file mode 100644
index 00000000000..2f020711c6f
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/79c9bfd2-ac45-436f-be0c-cc3556561985 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/88e50b13-f3af-4840-8554-93086cf7f73b b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/88e50b13-f3af-4840-8554-93086cf7f73b
new file mode 100644
index 00000000000..719c2ab8b97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/88e50b13-f3af-4840-8554-93086cf7f73b differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/8eb80ffc-c7a9-4803-9f62-298cc5358ca9 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/8eb80ffc-c7a9-4803-9f62-298cc5358ca9
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/8eb80ffc-c7a9-4803-9f62-298cc5358ca9 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/9642fb8c-81ee-4b8c-b4c2-2328e171bb14 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/9642fb8c-81ee-4b8c-b4c2-2328e171bb14
new file mode 100644
index 00000000000..ce1ce8c5858
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/9642fb8c-81ee-4b8c-b4c2-2328e171bb14 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/97ff88fa-990b-495f-9bff-179f607c324d b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/97ff88fa-990b-495f-9bff-179f607c324d
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/97ff88fa-990b-495f-9bff-179f607c324d differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/_metadata b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/_metadata
new file mode 100644
index 00000000000..6e86c2f0755
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/_metadata differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/aa86e0bd-7b33-479d-b055-533225923919 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/aa86e0bd-7b33-479d-b055-533225923919
new file mode 100644
index 00000000000..b58db626d83
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/aa86e0bd-7b33-479d-b055-533225923919 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/b4b14e36-a896-4e89-b327-50add7bcbbf2 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/b4b14e36-a896-4e89-b327-50add7bcbbf2
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/b4b14e36-a896-4e89-b327-50add7bcbbf2 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/b60925f2-20bb-4dc0-9b4c-a2114781a058 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/b60925f2-20bb-4dc0-9b4c-a2114781a058
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/b60925f2-20bb-4dc0-9b4c-a2114781a058 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/cdf288bc-0b65-4637-ab11-dada9cfaaef3 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/cdf288bc-0b65-4637-ab11-dada9cfaaef3
new file mode 100644
index 00000000000..2f020711c6f
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/cdf288bc-0b65-4637-ab11-dada9cfaaef3 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/d7084730-48ee-46a6-95b7-74e16521d058 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/d7084730-48ee-46a6-95b7-74e16521d058
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/d7084730-48ee-46a6-95b7-74e16521d058 differ
diff --git a/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/e6be8162-4006-4c4d-93f3-63267244fb50 b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/e6be8162-4006-4c4d-93f3-63267244fb50
new file mode 100644
index 00000000000..a7cffe07e97
Binary files /dev/null and b/flink-tests/src/test/resources/new-stateful-broadcast-udf-migration-itcase-flink1.16-rocksdb-savepoint/e6be8162-4006-4c4d-93f3-63267244fb50 differ