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

Posted to commits@flink.apache.org by ch...@apache.org on 2020/03/31 09:37:44 UTC

[flink] branch master updated (1444fd6 -> a982488)

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

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


    from 1444fd6  [FLINK-16767][hive] Failed to read Hive table with RegexSerDe
     add 979d005  [hotfix][runtime][tests] Rename/move ClassLoaderTest
     add b0dff77a [FLINK-16245][runtime] Decouple user from context classloader
     add 5f2f661  [FLINK-16245][table] Close user classloader
     add a982488  [FLINK-16245][tests] Adjust BatchFineGrainedRecoveryITCase

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/flink/client/ClientUtils.java  |  3 +-
 .../apache/flink/util/ChildFirstClassLoader.java   |  5 +-
 .../flink/util/FlinkUserCodeClassLoader.java       | 28 ++++-----
 .../librarycache/FlinkUserCodeClassLoaders.java    | 73 +++++++++++++++++++++-
 .../FlinkUserCodeClassLoadersTest.java}            | 42 ++++++++++---
 .../client/gateway/local/ExecutionContext.java     | 12 +++-
 .../table/client/gateway/local/LocalExecutor.java  |  7 ++-
 .../recovery/BatchFineGrainedRecoveryITCase.java   | 19 +++---
 8 files changed, 149 insertions(+), 40 deletions(-)
 copy flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/UdfStreamOperatorFactory.java => flink-core/src/main/java/org/apache/flink/util/FlinkUserCodeClassLoader.java (65%)
 rename flink-runtime/src/test/java/org/apache/flink/runtime/{classloading/ClassLoaderTest.java => execution/librarycache/FlinkUserCodeClassLoadersTest.java} (84%)