flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ti...@apache.org
Subject [flink] branch master updated (09f2f43 -> bf5235e)
Date Fri, 01 Nov 2019 06:51:43 GMT
This is an automated email from the ASF dual-hosted git repository.

tison pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 09f2f43  [FLINK-14154][ml] Add the class for multivariate Gaussian Distribution.
     add bf5235e  [FLINK-14496][client] Exclude detach flag from ClusterClient

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/flink/client/ClientUtils.java  | 63 +++++++++++++--
 .../org/apache/flink/client/RemoteExecutor.java    |  2 +-
 .../org/apache/flink/client/cli/CliFrontend.java   | 14 ++--
 .../apache/flink/client/program/ClusterClient.java | 27 -------
 .../flink/client/program/ContextEnvironment.java   | 12 ++-
 .../flink/client/program/MiniClusterClient.java    | 38 ---------
 .../client/program/rest/RestClusterClient.java     | 40 ----------
 .../flink/client/cli/CliFrontendRunTest.java       |  4 +-
 .../apache/flink/client/program/ClientTest.java    | 20 ++---
 .../client/program/rest/RestClusterClientTest.java | 14 ++--
 .../connectors/kafka/KafkaConsumerTestBase.java    | 90 ++++++++--------------
 .../flink/state/api/SavepointReaderITTestBase.java |  6 +-
 .../state/api/SavepointReaderKeyedStateITCase.java |  5 +-
 .../flink/state/api/SavepointWriterITCase.java     |  5 +-
 .../jobmanager/JMXJobManagerMetricTest.java        |  4 +-
 .../itcases/AbstractQueryableStateTestBase.java    | 42 ++++------
 .../runtime/webmonitor/WebFrontendITCase.java      |  7 +-
 .../api/environment/StreamContextEnvironment.java  |  9 ++-
 .../RemoteStreamExecutionEnvironmentTest.java      | 33 ++++++--
 .../client/gateway/local/ProgramDeployer.java      | 10 +--
 .../jobmaster/JobMasterStopWithSavepointIT.java    |  4 +-
 .../jobmaster/JobMasterTriggerSavepointITCase.java |  4 +-
 .../test/accumulators/AccumulatorLiveITCase.java   |  3 +-
 .../flink/test/cancelling/CancelingTestBase.java   |  5 +-
 .../test/checkpointing/RegionFailoverITCase.java   |  6 +-
 .../flink/test/checkpointing/RescalingITCase.java  | 25 +++---
 .../ResumeCheckpointManuallyITCase.java            |  4 +-
 .../flink/test/checkpointing/SavepointITCase.java  | 25 +++---
 .../StreamFaultToleranceTestBase.java              |  6 +-
 .../ZooKeeperHighAvailabilityITCase.java           |  4 +-
 .../utils/SavepointMigrationTestBase.java          |  7 +-
 .../test/example/client/JobRetrievalITCase.java    |  4 +-
 .../example/failing/JobSubmissionFailsITCase.java  | 11 ++-
 .../test/runtime/NetworkStackThroughputITCase.java |  5 +-
 .../restore/AbstractOperatorRestoreTestBase.java   | 15 ++--
 .../runtime/BigUserProgramJobSubmitITCase.java     |  4 +-
 .../apache/flink/yarn/util/FakeClusterClient.java  |  5 --
 37 files changed, 247 insertions(+), 335 deletions(-)


Mime
View raw message