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 f9286a5 [FLINK-23429][state-processor-api] Use Path instead of Path.getPath() to preserve FileSystem info add b34ef1e [FLINK-18783] Load Akka with separate classloader No new revisions were added by this update. Summary of changes: .../resource-providers/standalone/kubernetes.md | 4 +- .../resource-providers/standalone/kubernetes.md | 4 +- 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 | 4 +- 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 | 3 +- .../core/classloading/SubmoduleClassLoader.java | 45 +++ .../apache/flink/util/concurrent/FutureUtils.java | 26 +- flink-dist/pom.xml | 11 +- flink-dist/src/main/assemblies/opt.xml | 4 +- .../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 | 4 +- .../pom.xml | 2 +- .../flink-end-to-end-tests-common/pom.xml | 2 +- .../flink-metrics-availability-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-influxdb/pom.xml | 2 +- flink-metrics/flink-metrics-jmx/pom.xml | 2 +- flink-metrics/flink-metrics-prometheus/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} | 61 +++- .../org.apache.flink.runtime.rpc.RpcSystemLoader | 2 +- 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 | 100 ++++-- .../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 ++++++ .../rpc/akka/ContextClassLoadingSettingTest.java | 381 +++++++++++++++++++++ .../flink/runtime/rpc/akka/AkkaUtilsTest.scala | 12 +- .../org/apache/flink/runtime/rpc/RpcSystem.java | 3 +- ...AddressResolution.java => RpcSystemLoader.java} | 9 +- flink-rpc/pom.xml | 1 + flink-runtime-web/pom.xml | 6 +- flink-runtime/pom.xml | 40 ++- .../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 +- flink-yarn-tests/pom.xml | 2 +- flink-yarn/pom.xml | 4 +- pom.xml | 58 ---- .../tools/ci/suffixcheck/ScalaSuffixChecker.java | 13 +- 94 files changed, 1403 insertions(+), 389 deletions(-) create mode 100644 flink-core/src/main/java/org/apache/flink/core/classloading/SubmoduleClassLoader.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 copy flink-rpc/{flink-rpc-akka/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcSystem.java => flink-rpc-akka-loader/src/main/java/org/apache/flink/runtime/rpc/akka/CleanupOnCloseRpcSystem.java} (52%) copy flink-filesystems/flink-mapr-fs/src/main/resources/META-INF/services/org.apache.flink.core.fs.FileSystemFactory => flink-rpc/flink-rpc-akka-loader/src/main/resources/META-INF/services/org.apache.flink.runtime.rpc.RpcSystemLoader (93%) 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 copy flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/{AddressResolution.java => RpcSystemLoader.java} (82%)