This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from df4fa8a [FLINK-22865][python] Optimize state serialize/deserialize in
PyFlink
add 70d3f84 Revert "[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 | 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 | 3 +-
.../core/classloading/SubmoduleClassLoader.java | 45 ---
.../apache/flink/util/concurrent/FutureUtils.java | 26 +-
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 | 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 +-
.../apache/flink/runtime/rpc/RpcSystemLoader.java | 25 --
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 +-
99 files changed, 392 insertions(+), 1513 deletions(-)
delete mode 100644
flink-core/src/main/java/org/apache/flink/core/classloading/SubmoduleClassLoader.java
delete mode 100644 flink-rpc/flink-rpc-akka-loader/pom.xml
delete mode 100644
flink-rpc/flink-rpc-akka-loader/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcSystemLoader.java
delete mode 100644
flink-rpc/flink-rpc-akka-loader/src/main/java/org/apache/flink/runtime/rpc/akka/CleanupOnCloseRpcSystem.java
delete mode 100644
flink-rpc/flink-rpc-akka-loader/src/main/resources/META-INF/services/org.apache.flink.runtime.rpc.RpcSystemLoader
delete mode 100644
flink-rpc/flink-rpc-akka/src/main/java/org/apache/flink/runtime/concurrent/akka/ClassLoadingUtils.java
delete mode 100644
flink-rpc/flink-rpc-akka/src/test/java/org/apache/flink/runtime/concurrent/akka/ClassLoadingUtilsTest.java
delete mode 100644
flink-rpc/flink-rpc-akka/src/test/java/org/apache/flink/runtime/rpc/akka/ContextClassLoadingSettingTest.java
delete mode 100644
flink-rpc/flink-rpc-core/src/main/java/org/apache/flink/runtime/rpc/RpcSystemLoader.java
