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/12/03 08:51:51 UTC

[flink] branch master updated (4239dd1 -> 2d67ee0)

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 4239dd1  [hotfix][network] Rename fields in CachedBufferStorage
     add 41176ba  [FLINK-14947] Introduce LocalExecutor and make LocalEnvironment use it
     add ef0f56a  [FLINK-14947] Make LocalStreamEnvironment use LocalExecutor
     add 2d67ee0  [FLINK-14947] Remove unused LocalExecutor that extends PlanExecutor

No new revisions were added by this update.

Summary of changes:
 .../{ => deployment/executors}/LocalExecutor.java  | 118 +++++++++++----------
 ...cutorFactory.java => LocalExecutorFactory.java} |  17 ++-
 .../flink/client/program/MiniClusterClient.java    |   5 +-
 ...org.apache.flink.core.execution.ExecutorFactory |   3 +-
 .../org/apache/flink/api/common/PlanExecutor.java  |  35 ++----
 .../apache/flink/api/java/LocalEnvironment.java    |  31 ++----
 .../api/environment/LocalStreamEnvironment.java    |  24 +++--
 .../test/example/client/LocalExecutorITCase.java   |   9 +-
 8 files changed, 113 insertions(+), 129 deletions(-)
 rename flink-clients/src/main/java/org/apache/flink/client/{ => deployment/executors}/LocalExecutor.java (54%)
 copy flink-clients/src/main/java/org/apache/flink/client/deployment/executors/{StandaloneSessionClusterExecutorFactory.java => LocalExecutorFactory.java} (69%)