[flink] branch master updated (81d1cb4 -> 2199533)
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(-)
[flink] branch master updated (81d1cb4 -> 2199533)
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(-)
