1996fanrui opened a new pull request, #29776: URL: https://github.com/apache/flink/pull/29776
## What is the purpose of the change Backport of #29599 to release-2.2. ## Verifying this change - `python -m pytest pyflink/fn_execution/tests/test_state_impl.py -v` in `flink-python` (Python 3.11, apache-beam 2.61.0): `3 passed, 2 subtests passed` - Same test with the `state_impl.py` change reverted: `3 failed, 2 passed` (`test_contains_distinguishes_missing_keys_from_none_values` both subtests, `test_contains_after_clear_and_put`), so the tests cover the bug on this branch. - `flake8 --config=tox.ini pyflink/fn_execution/state_impl.py pyflink/fn_execution/tests/test_state_impl.py` (flake8 7.2.0): no findings ## Difference from the original | Original commit | Conflict | Byte-identical | Changes | | --- | --- | --- | --- | | 43f0b465d50 (release-1.20) | No | Yes | None | ## Notes - Cherry-picked from the release-1.20 commit instead of the master commit 379201f50d9: release-2.2 lacks `pyflink/fn_execution/tests/test_state_impl.py` (added on master by FLINK-34625), and the release-1.20 commit creates that file. - The change is Python only, so no Maven build was run. ##### Was generative AI tooling used to co-author this PR? - [X] Yes (please specify the tool below) Generated-by: Claude Code 2.1.318 (Claude Opus 5.5) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
