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/06/09 17:37:24 UTC
[flink] branch master updated (9a7dbfc -> bac55c1)

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

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


    from 9a7dbfc  [FLINK-18057][tests] Fix unstable test SingleInputGateTest#testConcurrentReadStateAndProcessAndClose
     add bac55c1  [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 ++++++++++++++++++++++
 .../flink/util/FlinkUserCodeClassLoaderTest.java   | 62 +++++++++++++++++++++
 .../util/TemporaryClassLoaderContextTest.java      |  4 +-
 .../formats/avro/AvroKryoClassloadingTest.java     |  4 +-
 .../flink/runtime/dispatcher/Dispatcher.java       |  3 +-
 .../librarycache/BlobLibraryCacheManager.java      | 37 +++++++++++--
 .../librarycache/FlinkUserCodeClassLoaders.java    | 42 +++++++++------
 .../jobmaster/JobManagerSharedServices.java        |  8 ++-
 .../runtime/taskexecutor/TaskManagerRunner.java    |  3 +-
 .../runtime/taskexecutor/TaskManagerServices.java  | 11 +++-
 .../librarycache/BlobLibraryCacheManagerTest.java  |  6 ++-
 .../BlobLibraryCacheRecoveryITCase.java            |  3 +-
 .../FlinkUserCodeClassLoadersTest.java             | 36 +++++++++----
 .../TaskExecutorLocalStateStoresManagerTest.java   |  3 +-
 .../state/RocksDbMultiClassLoaderTest.java         |  5 +-
 .../client/gateway/local/ExecutionContextTest.java | 18 +++++--
 21 files changed, 295 insertions(+), 57 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