This is an automated email from the ASF dual-hosted git repository. dianfu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit bf2c13d7f426e4dd768d2dd37411a9d1bfe10d08 Author: huangxingbo <[email protected]> AuthorDate: Wed Nov 25 19:45:55 2020 +0800 [FLINK-20284][python] Change default DESTROY_DELAY_SECONDS to 0 For PyFlink jobs, the underlying netty server releases resources asynchronously in a separate thread when job finished. As PyFlink classes runs in user classloader which will be closed after job finished. ClassNotFoundError may be thrown and appear in the log. It doesn't affect the correctness, however, is very confusing for users. This commit changes the DESTROY_DELAY_SECONDS to 0 (original is 1) to improve this situation. This closes #14217. --- .../beam/vendor/grpc/v1p26p0/io/grpc/internal/SharedResourceHolder.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-python/src/main/java/org/apache/beam/vendor/grpc/v1p26p0/io/grpc/internal/SharedResourceHolder.java b/flink-python/src/main/java/org/apache/beam/vendor/grpc/v1p26p0/io/grpc/internal/SharedResourceHolder.java index 4f85220..7bdb3be 100644 --- a/flink-python/src/main/java/org/apache/beam/vendor/grpc/v1p26p0/io/grpc/internal/SharedResourceHolder.java +++ b/flink-python/src/main/java/org/apache/beam/vendor/grpc/v1p26p0/io/grpc/internal/SharedResourceHolder.java @@ -40,7 +40,7 @@ import javax.annotation.concurrent.ThreadSafe; */ @ThreadSafe public final class SharedResourceHolder { - static final long DESTROY_DELAY_SECONDS = 1; + static final long DESTROY_DELAY_SECONDS = 0; // The sole holder instance. private static final SharedResourceHolder holder = new SharedResourceHolder(
