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 c874338 [FLINK-23233][runtime] Ensure checkpoints confirmed after all the failed events processed for OepratorCoordinator new 5d3ca59 [FLINK-21368] Remove RpcService#getExecutor new e2d36ba [hotfix] Replace AskTimeException usages in tests new ae85de7 [hotfix] Remove akka dependency in MetricUtilsTest new b8ee568 [hotfix] Allow @Internal annotation on fields new 9cf4c48 [hotfix] Extract logging parent-first patterns into constant new 548d70a [FLINK-18783] RpcSystem extends AutoCloseable new ad2f2bc [FLINK-18783] RpcSystem#load accepts Configuration new 1aa7d16 [FLINK-18783] Add ComponentClassLoader new e341e47 [FLINK-18783] Load Akka with separate classloader The 9 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../resource-providers/standalone/kubernetes.md | 4 +- .../resource-providers/standalone/kubernetes.md | 4 +- .../shortcodes/generated/core_configuration.html | 2 +- .../generated/expert_class_loading_section.html | 2 +- .../java/org/apache/flink/annotation/Internal.java | 2 +- flink-clients/pom.xml | 6 +- flink-connectors/flink-connector-base/pom.xml | 2 +- flink-connectors/flink-connector-cassandra/pom.xml | 2 +- .../flink-connector-elasticsearch-base/pom.xml | 2 +- .../flink-connector-elasticsearch5/pom.xml | 2 +- .../flink-connector-elasticsearch6/pom.xml | 2 +- .../flink-connector-elasticsearch7/pom.xml | 2 +- flink-connectors/flink-connector-files/pom.xml | 2 +- .../flink-connector-gcp-pubsub/pom.xml | 2 +- flink-connectors/flink-connector-hbase-1.4/pom.xml | 2 +- flink-connectors/flink-connector-hive/pom.xml | 2 +- flink-connectors/flink-connector-jdbc/pom.xml | 2 +- flink-connectors/flink-connector-kafka/pom.xml | 6 +- flink-connectors/flink-connector-kinesis/pom.xml | 4 +- flink-connectors/flink-connector-rabbitmq/pom.xml | 4 +- flink-container/pom.xml | 2 +- .../apache/flink/configuration/CoreOptions.java | 15 +- .../core/classloading/ComponentClassLoader.java | 266 ++++++++++++++ .../core/classloading/SubmoduleClassLoader.java | 45 +++ .../org/apache/flink/core/plugin/PluginLoader.java | 96 +----- .../apache/flink/util/concurrent/FutureUtils.java | 26 +- .../classloading/ComponentClassLoaderTest.java | 268 +++++++++++++++ flink-dist/pom.xml | 17 +- flink-dist/src/main/assemblies/opt.xml | 4 +- flink-dist/src/main/assemblies/plugins.xml | 6 +- .../src/main/flink-bin/conf/log4j-cli.properties | 2 +- .../main/flink-bin/conf/log4j-console.properties | 2 +- .../main/flink-bin/conf/log4j-session.properties | 2 +- .../src/main/flink-bin/conf/log4j.properties | 2 +- .../src/main/flink-bin/conf/logback-console.xml | 2 +- flink-dist/src/main/flink-bin/conf/logback.xml | 2 +- flink-dist/src/main/resources/META-INF/NOTICE | 12 - flink-docs/pom.xml | 8 +- .../pom.xml | 2 +- .../flink-end-to-end-tests-common/pom.xml | 2 +- .../flink-metrics-availability-test/pom.xml | 2 +- .../flink-metrics-reporter-prometheus-test/pom.xml | 2 +- flink-end-to-end-tests/test-scripts/common.sh | 4 +- flink-examples/flink-examples-streaming/pom.xml | 2 +- flink-examples/flink-examples-table/pom.xml | 2 +- flink-formats/flink-avro/pom.xml | 2 +- flink-formats/flink-compress/pom.xml | 2 +- flink-formats/flink-csv/pom.xml | 2 +- flink-formats/flink-hadoop-bulk/pom.xml | 2 +- flink-formats/flink-json/pom.xml | 2 +- flink-formats/flink-orc/pom.xml | 2 +- flink-formats/flink-parquet/pom.xml | 2 +- flink-formats/flink-sequence-file/pom.xml | 2 +- flink-fs-tests/pom.xml | 4 +- flink-kubernetes/pom.xml | 6 +- flink-libraries/flink-cep/pom.xml | 4 +- flink-libraries/flink-gelly/pom.xml | 2 +- flink-libraries/flink-state-processing-api/pom.xml | 4 +- flink-metrics/flink-metrics-dropwizard/pom.xml | 4 +- flink-metrics/flink-metrics-influxdb/pom.xml | 6 +- flink-metrics/flink-metrics-jmx/pom.xml | 8 +- flink-metrics/flink-metrics-prometheus/pom.xml | 6 +- flink-metrics/flink-metrics-slf4j/pom.xml | 4 +- flink-metrics/flink-metrics-statsd/pom.xml | 4 +- flink-optimizer/pom.xml | 6 +- flink-python/pom.xml | 2 +- .../flink-queryable-state-runtime/pom.xml | 8 +- flink-rpc/flink-rpc-akka-loader/pom.xml | 127 +++++++ .../runtime/rpc/akka/AkkaRpcSystemLoader.java | 78 +++++ .../runtime/rpc/akka/CleanupOnCloseRpcSystem.java | 100 ++++++ .../org.apache.flink.runtime.rpc.RpcSystemLoader | 16 + flink-rpc/flink-rpc-akka/pom.xml | 176 ++++++---- .../akka/ActorSystemScheduledExecutorAdapter.java | 22 +- .../runtime/concurrent/akka/ClassLoadingUtils.java | 119 +++++++ .../runtime/rpc/akka/AkkaInvocationHandler.java | 12 +- .../flink/runtime/rpc/akka/AkkaRpcActor.java | 51 ++- .../flink/runtime/rpc/akka/AkkaRpcService.java | 116 ++++--- .../runtime/rpc/akka/AkkaRpcServiceUtils.java | 64 ++-- .../rpc/akka/FencedAkkaInvocationHandler.java | 6 +- .../flink/runtime/rpc/akka/FencedAkkaRpcActor.java | 5 +- .../src/main/resources/META-INF/NOTICE | 31 +- .../apache/flink/runtime/rpc/akka/AkkaUtils.scala | 16 +- .../runtime/rpc/akka/CustomSSLEngineProvider.scala | 3 +- .../concurrent/akka/ClassLoadingUtilsTest.java | 105 ++++++ .../flink/runtime/rpc/akka/AkkaRpcActorTest.java | 2 +- .../rpc/akka/ContextClassLoadingSettingTest.java | 381 +++++++++++++++++++++ .../flink/runtime/rpc/akka/AkkaUtilsTest.scala | 12 +- .../org/apache/flink/runtime/rpc/RpcService.java | 16 +- .../org/apache/flink/runtime/rpc/RpcSystem.java | 19 +- .../apache/flink/runtime/rpc/RpcSystemLoader.java | 25 ++ flink-rpc/pom.xml | 1 + flink-runtime-web/pom.xml | 6 +- flink-runtime/pom.xml | 40 ++- .../runtime/entrypoint/ClusterEntrypoint.java | 9 +- .../flink/runtime/minicluster/MiniCluster.java | 11 +- .../runtime/registration/RetryingRegistration.java | 8 +- .../taskexecutor/DefaultJobLeaderService.java | 2 +- .../flink/runtime/taskexecutor/TaskExecutor.java | 6 +- .../runtime/taskexecutor/TaskManagerRunner.java | 9 +- .../runtime/metrics/util/MetricUtilsTest.java | 12 +- .../registration/RegisteredRpcConnectionTest.java | 10 +- .../registration/RetryingRegistrationTest.java | 8 +- .../slotmanager/DeclarativeSlotManagerTest.java | 3 +- .../slotmanager/DefaultSlotStatusSyncerTest.java | 6 +- .../flink/runtime/rpc/FencedRpcEndpointTest.java | 2 +- .../TaskSubmissionTestEnvironment.java | 4 +- .../flink-statebackend-changelog/pom.xml | 6 +- .../flink-statebackend-heap-spillable/pom.xml | 6 +- .../flink-statebackend-rocksdb/pom.xml | 2 +- flink-streaming-java/pom.xml | 4 +- flink-streaming-scala/pom.xml | 4 +- flink-table/flink-sql-client/pom.xml | 4 +- flink-table/flink-table-api-java-bridge/pom.xml | 2 +- flink-table/flink-table-planner/pom.xml | 2 +- flink-test-utils-parent/flink-test-utils/pom.xml | 4 +- flink-tests/pom.xml | 10 +- .../OperatorEventSendingCheckpointITCase.java | 6 - flink-yarn-tests/pom.xml | 2 +- flink-yarn/pom.xml | 4 +- pom.xml | 58 ---- .../tools/ci/suffixcheck/ScalaSuffixChecker.java | 13 +- 121 files changed, 2134 insertions(+), 565 deletions(-) create mode 100644 flink-core/src/main/java/org/apache/flink/core/classloading/ComponentClassLoader.java create mode 100644 flink-core/src/main/java/org/apache/flink/core/classloading/SubmoduleClassLoader.java create mode 100644 flink-core/src/test/java/org/apache/flink/core/classloading/ComponentClassLoaderTest.java create mode 100644 flink-rpc/flink-rpc-akka-loader/pom.xml create mode 100644 flink-rpc/flink-rpc-akka-loader/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcSystemLoader.java create mode 100644 flink-rpc/flink-rpc-akka-loader/src/main/java/org/apache/flink/runtime/rpc/akka/CleanupOnCloseRpcSystem.java create mode 100644 flink-rpc/flink-rpc-akka-loader/src/main/resources/META-INF/services/org.apache.flink.runtime.rpc.RpcSystemLoader create mode 100644 flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/concurrent/akka/ClassLoadingUtils.java create mode 100644 flink-rpc/flink-rpc-akka/src/test/java/org/apache/flink/runtime/concurrent/akka/ClassLoadingUtilsTest.java create mode 100644 flink-rpc/flink-rpc-akka/src/test/java/org/apache/flink/runtime/rpc/akka/ContextClassLoadingSettingTest.java create mode 100644 flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/RpcSystemLoader.java