[flink] branch master updated (81d1cb4 -> 2199533)

[tr...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

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


    from 81d1cb4  [FLINK-14272][python][table-planner-blink] Support Blink planner for Python UDF(Scalar Function)
     add fc16bcb  [FLINK-14366][tests] Enable TaskFailureITCase to pass with NG scheduler
     add d04f1b0  [FLINK-14366][tests] Enable AccumulatorErrorITCase to pass with NG scheduler
     add 54952b2  [FLINK-14366][tests] Enable CustomSerializationITCase to pass with NG scheduler
     add 5b590dd  [FLINK-14366][tests] Enable MiscellaneousIssuesITCase to pass with NG scheduler
     add 76c28d8  [FLINK-14366][tests] Enable SuccessAfterNetworkBuffersFailureITCase to pass with NG scheduler
     add e242cbd  [FLINK-14366][tests] Enable TextOutputFormatITCase and CsvOutputFormatITCase to pass with NG scheduler
     add 2199533  [FLINK-14366][tests] Annotate MiniCluster tests in flink-tests with AlsoRunWithSchedulerNG

No new revisions were added by this update.

Summary of changes:
 .../streaming/scala/api/CsvOutputFormatITCase.java |  7 ++++---
 .../scala/api/TextOutputFormatITCase.java          |  3 ++-
 .../apache/flink/test/util/AbstractTestBase.java   |  3 +++
 .../runtime/metrics/JobManagerMetricsITCase.java   |  3 +++
 .../metrics/SystemResourcesMetricsITCase.java      |  3 +++
 .../test/accumulators/AccumulatorErrorITCase.java  | 12 +++++------
 .../test/accumulators/AccumulatorLiveITCase.java   |  3 +++
 .../flink/test/cancelling/CancelingTestBase.java   |  3 +++
 .../EventTimeAllWindowCheckpointingITCase.java     |  3 +++
 .../flink/test/checkpointing/RescalingITCase.java  |  3 +++
 .../ResumeCheckpointManuallyITCase.java            |  3 +++
 .../flink/test/checkpointing/SavepointITCase.java  |  3 +++
 .../StreamFaultToleranceTestBase.java              |  3 +++
 .../utils/SavepointMigrationTestBase.java          |  3 +++
 .../test/example/client/JobRetrievalITCase.java    |  3 +++
 .../example/failing/JobSubmissionFailsITCase.java  |  3 +++
 .../test/example/failing/TaskFailureITCase.java    |  8 ++++++--
 .../manual/StreamingScalabilityAndLatency.java     |  4 ++++
 .../flink/test/misc/CustomSerializationITCase.java | 23 +++++++++++++---------
 .../flink/test/misc/MiscellaneousIssuesITCase.java |  8 +++++---
 .../SuccessAfterNetworkBuffersFailureITCase.java   |  6 +++++-
 .../test/operators/CustomDistributionITCase.java   |  3 +++
 .../test/operators/RemoteEnvironmentITCase.java    |  3 +++
 .../SimpleRecoveryFailureRateStrategyITBase.java   |  3 +++
 ...pleRecoveryFixedDelayRestartStrategyITBase.java |  3 +++
 .../flink/test/runtime/FileBufferReaderITCase.java |  3 +++
 .../flink/test/runtime/IPv6HostnamesITCase.java    |  3 +++
 .../flink/test/runtime/NettyEpollITCase.java       |  3 +++
 .../test/runtime/NetworkStackThroughputITCase.java |  3 +++
 .../flink/test/runtime/SchedulingITCase.java       |  3 +++
 .../ZooKeeperLeaderElectionITCase.java             |  3 +++
 .../restore/AbstractOperatorRestoreTestBase.java   |  3 +++
 .../test/streaming/runtime/BackPressureITCase.java |  3 +++
 .../runtime/BigUserProgramJobSubmitITCase.java     |  3 +++
 .../test/streaming/runtime/TimestampITCase.java    |  3 +++
 35 files changed, 127 insertions(+), 25 deletions(-)