You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kk...@apache.org on 2019/11/14 14:20:54 UTC
[flink] branch master updated (84c96b3 -> f074d1f)
This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 84c96b3 [FLINK-14642] Add support for copying null values to the TupleSerializer and CaseClassSerializer
add f074d1f [FLINK-14758] Add Executor-related interfaces + wire their discovery to environments.
No new revisions were added by this update.
Summary of changes:
.../execution/DefaultExecutorServiceLoader.java | 25 ++++---
.../org/apache/flink/core/execution/Executor.java | 21 +++---
.../flink/core/execution/ExecutorFactory.java | 24 +++---
.../core/execution/ExecutorServiceLoader.java | 21 +++---
.../flink/api/java/ExecutionEnvironment.java | 53 ++++++++++++-
.../flink/api/java/ExecutorDiscoveryTest.java | 85 +++++++++++++++++++++
...org.apache.flink.core.execution.ExecutorFactory | 2 +-
.../api/environment/LocalStreamEnvironment.java | 4 -
.../environment/StreamExecutionEnvironment.java | 54 +++++++++++++-
.../environment/ExecutorDiscoveryTest.java | 86 ++++++++++++++++++++++
...org.apache.flink.core.execution.ExecutorFactory | 2 +-
11 files changed, 325 insertions(+), 52 deletions(-)
copy flink-clients/src/main/java/org/apache/flink/client/deployment/DefaultClusterClientServiceLoader.java => flink-core/src/main/java/org/apache/flink/core/execution/DefaultExecutorServiceLoader.java (63%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/JobExecutor.java => flink-core/src/main/java/org/apache/flink/core/execution/Executor.java (58%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/JobGraphRetriever.java => flink-core/src/main/java/org/apache/flink/core/execution/ExecutorFactory.java (61%)
copy flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/JobGraphRetriever.java => flink-core/src/main/java/org/apache/flink/core/execution/ExecutorServiceLoader.java (54%)
create mode 100644 flink-java/src/test/java/org/apache/flink/api/java/ExecutorDiscoveryTest.java
copy flink-connectors/flink-connector-kafka-0.9/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory => flink-java/src/test/resources/META-INF/services/org.apache.flink.core.execution.ExecutorFactory (91%)
create mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/environment/ExecutorDiscoveryTest.java
copy flink-connectors/flink-connector-kafka-0.11/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory => flink-streaming-java/src/test/resources/META-INF/services/org.apache.flink.core.execution.ExecutorFactory (89%)