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(-)
