HuangXingBo opened a new pull request #14217:
URL: https://github.com/apache/flink/pull/14217
## What is the purpose of the change
*This pull request will Port Grpc `SharedResourceHolder` class to
`flink-python` module and change the `DESTROY_DELAY_SECONDS` to `0`. Setting
`DESTROY_DELAY_SECONDS` to 0 does not solve the problem of asynchronous release
of `EventLoopGroup` resources from the root cause, but as only the
`EventLoopGroup` resources of `ProvisionService` that need to be released, this
can avoid the generation of ClassNotFoundError to the greatest extent. Of
course, the best way is that Grpc's NettyServer can provide a more complete
synchronous `shutdown` interface. This is a very involved issue, so from the
perspective of `Pyflink`, we will temporarily adopt the way of setting
`DESTROY_DELAY_SECONDS` to `0`. *
## Brief change log
- *Port Grpc `SharedResourceHolder` class to flink-python module*
- *Change `DESTROY_DELAY_SECONDS` to `0`*
## Verifying this change
This change added tests and can be verified as follows:
- *Submit a python udf job in standalone cluster and see the TaskManger
log*
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): (no)
- The public API, i.e., is any changed class annotated with
`@Public(Evolving)`: (no)
- The serializers: (no)
- The runtime per-record code paths (performance sensitive): (no)
- Anything that affects deployment or recovery: JobManager (and its
components), Checkpointing, Kubernetes/Yarn/Mesos, ZooKeeper: (no)
- The S3 file system connector: (no)
## Documentation
- Does this pull request introduce a new feature? (no)
- If yes, how is the feature documented? (not applicable)
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
