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 2021/07/21 15:33:36 UTC
[flink] branch master updated (f9286a5 -> b34ef1e)
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%)