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
