bowenli86 opened a new pull request, #29155: URL: https://github.com/apache/flink/pull/29155
## What is the purpose of the change Fix [FLINK-40628](https://issues.apache.org/jira/browse/FLINK-40628). Initializing TTL-enabled state in a Python thread-mode operator can request a Py4J gateway while constructing the default RocksDB cleanup strategy. Starting that subprocess from a multithreaded TaskManager can leave the task stuck in INITIALIZING. ## Brief change log - Defer the default 30-day `Duration` until the public accessor is called. The embedded converter continues to use Java's existing default. - Preserve explicit durations and existing falsey-argument behavior. - Add Python regression tests for gateway-free construction, pickle/protobuf round trips, and accessor compatibility, plus a RocksDB thread-mode regression that guards gateway access inside the worker and checks state updates across four cleanup policies. ## Verifying this change - New Python regression suite: **5 tests and 11 subtests passed**. Running it against the original source reproduces the gateway failures. - Flake8 on all changed Python files, Python syntax checks, and `git diff --check`: passed. - JVM/Pemja/RocksDB runtime regression: validation in progress. - Repository-wide `./mvnw clean verify`: in progress with Java 17 and Maven 3.9.16. Full verification is not yet complete; this PR is a draft. ## Does this pull request potentially affect one of the following parts: - Dependencies: no - Public API: no signature or annotation changes - Serializers: no format changes - Runtime per-record code paths: no - Deployment or recovery: Python operator state initialization; no checkpoint/savepoint format or behavior changes - S3 file system connector: no ## Documentation - Does this pull request introduce a new feature? no - If yes, how is the feature documented? not applicable --- ##### Was generative AI tooling used to co-author this PR? - [X] Yes Generated-by: Codex (GPT-6) -- 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]
