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/07 15:17:29 UTC
[flink] branch master updated (be967fa -> 9356c99)

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 be967fa  [FLINK-14346] [serialization] faster implementation of StringValue writeString and readString (#10358)
     add 5a24e83  [hotfix][scala-shell] Minor license refactoring
     add 58e0cf8  [hotfix] Uniformize Executor names
     add 8f10e50d [hotfix] Factor out YarnClusterDescriptor.setClusterEntrypointInfoToConfig() method
     add 219903e  [hotfix] FlinkILoop: reset ContextEnvFactories also for StreamEnvironments
     add dea4226  [FLINK-15120] YarnSessionCli.isActive & getApplicationId account conf APPLICATION_ID
     add 585f5d4  [FLINK-15118] Make flink-scala-shell use Executors
     add 4d33f4f  [FLINK-15119] Remove unused Plan/RemoteExecutor
     add 81bd77d  [minor] Refactor getJarFiles() out of ScalaShellEnvironments
     add 9356c99  [hotfix] Remove Mockito from RemoteStreamExecutionEnvironmentTest

No new revisions were added by this update.

Summary of changes:
 .../org/apache/flink/client/RemoteExecutor.java    | 133 ----------
 .../client/deployment/executors/LocalExecutor.java |   2 +
 .../deployment/executors/LocalExecutorFactory.java |   4 +-
 .../deployment/executors/RemoteExecutor.java       |   2 +-
 .../StandaloneSessionClusterExecutor.java          |   2 +-
 .../RemoteExecutorHostnameResolutionTest.java      |  99 --------
 .../org/apache/flink/api/common/PlanExecutor.java  | 126 ----------
 .../main/java/org/apache/flink/util/JarUtils.java  |  23 ++
 .../flink/api/java/ExecutionEnvironment.java       |  12 +-
 .../apache/flink/api/java/RemoteEnvironment.java   |   2 +-
 .../flink/api/java/ScalaShellEnvironment.java      | 100 ++++++++
 .../api/java/ScalaShellRemoteEnvironment.java      | 139 -----------
 .../java/ScalaShellRemoteStreamEnvironment.java    | 178 -------------
 .../api/java/ScalaShellStreamEnvironment.java      | 103 ++++++++
 .../org/apache/flink/api/scala/FlinkILoop.scala    |  52 ++--
 .../org/apache/flink/api/scala/FlinkShell.scala    | 275 ++++++++++++---------
 .../org/apache/flink/api/java/FlinkILoopTest.java  | 125 +---------
 .../apache/flink/api/scala/ScalaShellITCase.scala  |  18 +-
 .../flink/api/scala/ExecutionEnvironment.scala     |   4 +-
 .../api/environment/RemoteStreamEnvironment.java   |   2 +-
 .../RemoteStreamExecutionEnvironmentTest.java      | 212 +++++++++++-----
 .../apache/flink/yarn/YarnClusterDescriptor.java   |  39 +--
 .../apache/flink/yarn/cli/FlinkYarnSessionCli.java |  18 +-
 .../yarn/executors/YarnJobClusterExecutor.java     |   2 +-
 .../yarn/executors/YarnSessionClusterExecutor.java |   2 +-
 25 files changed, 631 insertions(+), 1043 deletions(-)
 delete mode 100644 flink-clients/src/main/java/org/apache/flink/client/RemoteExecutor.java
 delete mode 100644 flink-clients/src/test/java/org/apache/flink/client/RemoteExecutorHostnameResolutionTest.java
 delete mode 100644 flink-core/src/main/java/org/apache/flink/api/common/PlanExecutor.java
 create mode 100644 flink-scala-shell/src/main/java/org/apache/flink/api/java/ScalaShellEnvironment.java
 delete mode 100644 flink-scala-shell/src/main/java/org/apache/flink/api/java/ScalaShellRemoteEnvironment.java
 delete mode 100644 flink-scala-shell/src/main/java/org/apache/flink/api/java/ScalaShellRemoteStreamEnvironment.java
 create mode 100644 flink-scala-shell/src/main/java/org/apache/flink/api/java/ScalaShellStreamEnvironment.java