[flink] branch master updated (5ed614c -> b43075b)

[rm...@apache.org]

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

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


    from 5ed614c  [hotfix][docs] Fix broken link in datastream_api.md and datastream_api.zh.md
     add 328c901  [FLINK-17554] Allow to register release hooks for the classloader
     add b43075b  [hotfix] Add missing log4j2-test.properties files

No new revisions were added by this update.

Summary of changes:
 .../src/test/resources/log4j2-test.properties      |  1 +
 .../flink/api/common/functions/RuntimeContext.java | 12 ++++
 .../functions/util/AbstractRuntimeUDFContext.java  | 12 +++-
 .../common/functions/util/RuntimeUDFContext.java   |  3 +-
 .../flink/util/SimpleUserCodeClassLoader.java      | 25 ++++---
 .../QuadFunction.java => UserCodeClassLoader.java} | 36 +++++-----
 .../flink/cep/operator/CepRuntimeContext.java      |  5 ++
 .../state/api/runtime/SavepointEnvironment.java    | 32 ++++++++-
 .../state/api/runtime/SavepointRuntimeContext.java |  5 ++
 .../flink/runtime/execution/Environment.java       |  3 +-
 .../librarycache/BlobLibraryCacheManager.java      | 39 +++++++++--
 .../librarycache/LibraryCacheManager.java          |  3 +-
 .../iterative/task/AbstractIterativeTask.java      |  5 +-
 .../task/IterationSynchronizationSinkTask.java     |  2 +-
 .../runtime/jobgraph/tasks/AbstractInvokable.java  |  2 +-
 .../runtime/jobmaster/JobManagerRunnerImpl.java    |  2 +-
 .../apache/flink/runtime/operators/BatchTask.java  | 26 ++++----
 .../flink/runtime/operators/DataSinkTask.java      |  2 +-
 .../flink/runtime/operators/DataSourceTask.java    |  7 +-
 .../runtime/operators/chaining/ChainedDriver.java  |  5 +-
 .../util/DistributedRuntimeUDFContext.java         | 26 ++++----
 .../runtime/state/filesystem/FsStateBackend.java   |  4 +-
 .../runtime/state/memory/MemoryStateBackend.java   |  4 +-
 .../runtime/taskmanager/RuntimeEnvironment.java    |  7 +-
 .../org/apache/flink/runtime/taskmanager/Task.java | 15 +++--
 .../librarycache/BlobLibraryCacheManagerTest.java  | 61 +++++++++++++----
 .../librarycache/TestingClassLoaderLease.java      | 13 ++--
 .../jobmaster/JobManagerRunnerImplTest.java        |  4 +-
 .../operators/testutils/DummyEnvironment.java      | 10 +--
 .../operators/testutils/MockEnvironment.java       |  7 +-
 .../testutils/MockEnvironmentBuilder.java          |  8 ++-
 .../runtime/state/OperatorStateBackendTest.java    | 10 +--
 .../runtime/state/ttl/mock/MockStateBackend.java   |  2 +-
 .../taskexecutor/TaskExecutorSlotLifetimeTest.java |  2 +-
 .../runtime/taskmanager/TaskAsyncCallTest.java     |  5 +-
 .../runtime/util/TestingUserCodeClassLoader.java   | 76 ++++++++++++++++++++++
 .../streaming/state/RocksDBStateBackend.java       |  4 +-
 .../api/functions/async/RichAsyncFunction.java     |  5 ++
 .../operators/StreamTaskStateInitializerImpl.java  |  2 +-
 .../api/operators/StreamingRuntimeContext.java     |  2 +-
 .../streaming/runtime/tasks/OperatorChain.java     |  6 +-
 .../flink/streaming/runtime/tasks/StreamTask.java  |  4 +-
 .../runtime/tasks/StreamMockEnvironment.java       |  8 ++-
 .../tasks/TaskCheckpointingBehaviourTest.java      |  4 +-
 .../src/test/resources/log4j2-test.properties      |  0
 .../NotifyCheckpointAbortedITCase.java             |  2 +-
 46 files changed, 376 insertions(+), 142 deletions(-)
 copy flink-connectors/{flink-connector-cassandra => flink-connector-kinesis}/src/test/resources/log4j2-test.properties (99%)
 copy flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/NoOpJobGraphWriter.java => flink-core/src/main/java/org/apache/flink/util/SimpleUserCodeClassLoader.java (55%)
 copy flink-core/src/main/java/org/apache/flink/util/{function/QuadFunction.java => UserCodeClassLoader.java} (54%)
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingUserCodeClassLoader.java
 copy {flink-yarn => flink-table/flink-table-api-java-bridge}/src/test/resources/log4j2-test.properties (100%)