You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by az...@apache.org on 2020/07/22 12:08:45 UTC

[flink] branch release-1.10 updated (c1f8763 -> bfe6c2e)

This is an automated email from the ASF dual-hosted git repository.

azagrebin pushed a change to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from c1f8763  [FLINK-18644][doc][hive] Remove obsolete hive connector docs
     add 1442300  [FLINK-15962][network] Reduce the default chunk size to 4M in netty stack
     add bfe6c2e  [FLINK-16225] Implement user class loading exception handler

No new revisions were added by this update.

Summary of changes:
 docs/_includes/generated/core_configuration.html   |  6 +++
 .../generated/expert_class_loading_section.html    |  6 +++
 .../java/org/apache/flink/client/ClientUtils.java  |  3 +-
 .../apache/flink/configuration/CoreOptions.java    |  8 +++
 .../apache/flink/util/ChildFirstClassLoader.java   | 21 +++++---
 .../flink/util/FlinkUserCodeClassLoader.java       | 63 ++++++++++++++++++++++
 .../plugin/TemporaryClassLoaderContextTest.java    |  4 +-
 .../flink/util/FlinkUserCodeClassLoaderTest.java   | 62 +++++++++++++++++++++
 .../formats/avro/AvroKryoClassloadingTest.java     |  4 +-
 .../flink/runtime/dispatcher/Dispatcher.java       |  3 +-
 .../librarycache/BlobLibraryCacheManager.java      | 43 +++++++++++++--
 .../librarycache/FlinkUserCodeClassLoaders.java    | 42 +++++++++------
 .../runtime/io/network/netty/NettyBufferPool.java  | 14 ++---
 .../jobmaster/JobManagerSharedServices.java        | 10 ++--
 .../flink/runtime/taskexecutor/TaskExecutor.java   |  7 ++-
 .../runtime/classloading/ClassLoaderTest.java      | 13 ++---
 .../state/RocksDbMultiClassLoaderTest.java         |  5 +-
 .../client/gateway/local/ExecutionContext.java     |  4 +-
 .../client/gateway/local/ExecutionContextTest.java | 18 +++++--
 19 files changed, 281 insertions(+), 55 deletions(-)
 create mode 100644 flink-core/src/main/java/org/apache/flink/util/FlinkUserCodeClassLoader.java
 create mode 100644 flink-core/src/test/java/org/apache/flink/util/FlinkUserCodeClassLoaderTest.java