This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c51b19c [FLINK-13405][docs-zh] Translate "Basic API Concepts" page
into Chinese
add c30e84f [FLINK-13794][client] Remove unused logic of
printStatusDuringExecution
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/client/RemoteExecutor.java | 1 -
.../org/apache/flink/client/cli/CliFrontend.java | 1 -
.../apache/flink/client/cli/ProgramOptions.java | 8 ----
.../apache/flink/client/program/ClusterClient.java | 20 ----------
.../flink/client/cli/CliFrontendRunTest.java | 26 +++++--------
.../program/ExecutionPlanAfterExecutionTest.java | 2 -
.../streaming/connectors/kafka/Kafka010ITCase.java | 6 +--
.../streaming/connectors/kafka/Kafka011ITCase.java | 6 +--
.../streaming/connectors/kafka/Kafka08ITCase.java | 4 +-
.../streaming/connectors/kafka/Kafka09ITCase.java | 2 -
.../connectors/kafka/KafkaConsumerTestBase.java | 44 +++++-----------------
.../connectors/kafka/KafkaProducerTestBase.java | 3 --
.../kafka/KafkaShortRetentionTestBase.java | 2 -
.../connectors/kafka/testutils/DataGenerators.java | 3 +-
.../streaming/connectors/kafka/KafkaITCase.java | 6 +--
.../apache/flink/api/common/ExecutionConfig.java | 24 ++++--------
.../org/apache/flink/api/common/PlanExecutor.java | 27 -------------
.../flink/api/common/ExecutionConfigTest.java | 9 +----
.../registry/test/TestAvroConsumerConfluent.java | 1 -
.../streaming/tests/Elasticsearch2SinkExample.java | 3 +-
.../streaming/tests/Elasticsearch5SinkExample.java | 3 +-
.../streaming/tests/Elasticsearch6SinkExample.java | 3 +-
.../HighParallelismIterationsTestProgram.java | 1 -
.../test/Elasticsearch5SinkExample.java | 3 +-
.../kafka/test/base/KafkaExampleUtil.java | 3 +-
.../apache/flink/api/java/LocalEnvironment.java | 1 -
.../apache/flink/api/java/RemoteEnvironment.java | 1 -
.../operations/DegreesWithExceptionITCase.java | 5 ---
.../ReduceOnEdgesWithExceptionITCase.java | 2 -
.../ReduceOnNeighborsWithExceptionITCase.java | 4 --
.../pyflink/common/tests/test_execution_config.py | 10 -----
.../api/java/ScalaShellRemoteEnvironment.java | 2 -
.../api/environment/RemoteStreamEnvironment.java | 2 -
.../test/accumulators/AccumulatorErrorITCase.java | 4 --
.../EventTimeAllWindowCheckpointingITCase.java | 5 ---
.../EventTimeWindowCheckpointingITCase.java | 15 +++-----
.../KeyedStateCheckpointingITCase.java | 3 +-
.../test/checkpointing/RegionFailoverITCase.java | 1 -
.../flink/test/checkpointing/SavepointITCase.java | 1 -
.../StreamFaultToleranceTestBase.java | 3 +-
.../checkpointing/WindowCheckpointingITCase.java | 10 ++---
.../jar/CheckpointedStreamingProgram.java | 3 +-
.../jar/CheckpointingCustomKvStateProgram.java | 3 +-
.../classloading/jar/CustomInputSplitProgram.java | 1 -
.../classloading/jar/CustomKvStateProgram.java | 3 +-
.../flink/test/classloading/jar/KMeansForTest.java | 1 -
.../jar/StreamingCustomInputSplitProgram.java | 2 -
.../test/classloading/jar/StreamingProgram.java | 1 -
.../flink/test/classloading/jar/UserCodeType.java | 1 -
.../test/example/client/LocalExecutorITCase.java | 1 -
.../apache/flink/test/manual/OverwriteObjects.java | 1 -
.../flink/test/misc/CustomSerializationITCase.java | 4 --
.../flink/test/misc/MiscellaneousIssuesITCase.java | 3 --
.../SuccessAfterNetworkBuffersFailureITCase.java | 2 -
.../test/operators/ExecutionEnvironmentITCase.java | 1 -
.../test/operators/RemoteEnvironmentITCase.java | 1 -
.../flink/test/operators/TypeHintITCase.java | 9 -----
.../flink/test/recovery/FastFailuresITCase.java | 3 +-
.../JobManagerHAProcessFailureRecoveryITCase.java | 1 -
.../recovery/ProcessFailureCancelingITCase.java | 1 -
.../test/recovery/SimpleRecoveryITCaseBase.java | 4 --
...skManagerProcessFailureBatchRecoveryITCase.java | 1 -
...nagerProcessFailureStreamingRecoveryITCase.java | 3 +-
.../flink/test/runtime/IPv6HostnamesITCase.java | 1 -
.../flink/test/runtime/NettyEpollITCase.java | 1 -
.../test/runtime/NetworkStackThroughputITCase.java | 1 -
.../test/streaming/runtime/TimestampITCase.java | 18 ++-------
.../flink/yarn/CliFrontendRunWithYarnTest.java | 4 +-
68 files changed, 60 insertions(+), 295 deletions(-)
