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 00d90a4 [FLINK-12788][container] Add support for Python jobs in build
script
new d14117f [hotfix][dist] Rename FLINK_ROOT*_DIR to FLINK_HOME
new 9871f25 [hotfix][dist] Export variables in only one place (config.sh)
new 6ed28c8 [hotfix][runtime] Deduplicate and simplify environment
variables handling in FlinkDistributionOverlay
new a98a7ee [hotfix][core] Deduplicate code and unify method names in
GlobalConfiguration
new b5dc213 [FLINK-12143] Distribute FLINK_PLUGINS_DIR the same way as
FLINK_LIB_DIR is distributed
new 186a2dd [FLINK-12143][dist] Ship plugins in the cluster the same way
as lib jars
new 7020f62 [hotfix][dist] Use proper flink-python jar match pattern in
pyflink.bat for Windows (FLINK-12409)
new 33b182c [FLINK-12143] PluginLoader: use system level always parents
first patterns in class loading
new 0075361 [FLINK-12143][e2e] Introduce plugins helper function and test
cleanup
new 9e6ff81 [FLINK-12143][e2e] Change end-to-end tests with file system
to use plugins mechanism
The 10 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:
.../org/apache/flink/client/cli/CliFrontend.java | 4 +-
flink-container/docker/Dockerfile | 1 +
.../flink/configuration/ConfigConstants.java | 3 +
.../apache/flink/configuration/CoreOptions.java | 8 +--
.../flink/configuration/GlobalConfiguration.java | 49 +++++++++++-----
.../org/apache/flink/core/plugin/PluginConfig.java | 68 ++++++++++++++++++++++
.../org/apache/flink/core/plugin/PluginLoader.java | 5 +-
.../apache/flink/core/plugin/PluginManager.java | 14 +++--
.../org/apache/flink/core/plugin/PluginUtils.java | 23 ++++----
.../{IterableIterator.java => ArrayUtils.java} | 21 +++++--
.../configuration/GlobalConfigurationTest.java | 2 +-
.../java/org/apache/flink/util/ArrayUtilsTest.java | 53 +++++++++++++++++
flink-dist/src/main/flink-bin/bin/config.sh | 30 +++++-----
flink-dist/src/main/flink-bin/bin/flink | 3 -
flink-dist/src/main/flink-bin/bin/flink.bat | 5 +-
.../main/flink-bin/bin/pyflink-gateway-server.sh | 4 +-
.../src/main/flink-bin/bin/pyflink-stream.sh | 2 +-
flink-dist/src/main/flink-bin/bin/pyflink.bat | 4 +-
flink-dist/src/main/flink-bin/bin/pyflink.sh | 2 +-
.../src/main/flink-bin/bin/start-cluster.bat | 9 +--
.../flink-bin/mesos-bin/mesos-appmaster-job.sh | 4 --
.../main/flink-bin/mesos-bin/mesos-appmaster.sh | 4 --
.../main/flink-bin/mesos-bin/mesos-taskmanager.sh | 4 --
.../src/main/flink-bin/yarn-bin/yarn-session.sh | 2 -
flink-end-to-end-tests/test-scripts/common.sh | 15 +++++
...test_sql_client_kafka.sh => common_dummy_fs.sh} | 7 ++-
flink-end-to-end-tests/test-scripts/common_s3.sh | 2 +-
.../test-scripts/test_azure_fs.sh | 2 +-
.../test-scripts/test_batch_wordcount.sh | 3 +-
.../test-scripts/test_docker_embedded_job.sh | 3 +-
.../test-scripts/test_yarn_kerberos_docker.sh | 3 +-
.../mesos/entrypoint/MesosEntrypointUtils.java | 2 +-
.../mesos/entrypoint/MesosTaskExecutorRunner.java | 4 +-
.../runtime/webmonitor/history/HistoryServer.java | 4 +-
.../overlays/FlinkDistributionOverlay.java | 44 ++++++--------
.../runtime/entrypoint/ClusterEntrypoint.java | 4 +-
.../runtime/taskexecutor/TaskManagerRunner.java | 4 +-
.../overlays/FlinkDistributionOverlayTest.java | 25 ++++++--
flink-table/flink-sql-client/bin/sql-client.sh | 3 -
.../table/client/gateway/local/LocalExecutor.java | 4 +-
.../apache/flink/test/plugin/PluginLoaderTest.java | 6 +-
.../flink/test/plugin/PluginManagerTest.java | 2 +-
.../flink/yarn/AbstractYarnClusterDescriptor.java | 34 +++++++----
.../apache/flink/yarn/YarnTaskExecutorRunner.java | 4 +-
.../flink/yarn/YarnClusterDescriptorTest.java | 22 ++++---
45 files changed, 347 insertions(+), 174 deletions(-)
create mode 100644
flink-core/src/main/java/org/apache/flink/core/plugin/PluginConfig.java
copy flink-core/src/main/java/org/apache/flink/util/{IterableIterator.java =>
ArrayUtils.java} (66%)
create mode 100644
flink-core/src/test/java/org/apache/flink/util/ArrayUtilsTest.java
copy flink-end-to-end-tests/test-scripts/{test_sql_client_kafka.sh =>
common_dummy_fs.sh} (84%)
mode change 100755 => 100644
