This is an automated email from the ASF dual-hosted git repository.
MartijnVisser pushed a change to branch release-2.2
in repository https://gitbox.apache.org/repos/asf/flink.git
from 1c7d62e404d [FLINK-40082][table] Watermark generated method
`extractTimestamp` might invoke code throwing exceptions
new 60e6aed8452 [FLINK-39387][Test] Fix flaky scheduler benchmark tests
caused by thread assertion failure in async TDD creation
new 6e69f0684f0 [FLINK-39914][runtime] Fix flaky
TaskDeploymentDescriptorFactoryTest#testHybridVertexFinish caused by async TDD
creation (#28398)
new 17d3f2717fa [FLINK-39922][runtime/test] Fix the flaky test case
AbstractAsyncRunnableStreamOperatorTest#testCheckpointDrain (#28425)
new 09377371e95 [FLINK-39921][runtime/tests] Fix the flaky test case
ExecutionVertexCancelTest.testSendCancelAndReceiveFail (#28449)
new 82c1e4eb6d1 [FLINK-39929][runtime/tests] Fix the flaky test case
ExecutionTimeBasedSlowTaskDetectorTest due to unexepected
ComponentMainThreadExecutor setting. (#28434)
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../AbstractAsyncRunnableStreamOperatorTest.java | 3 ++
...MainThreadCheckComponentMainThreadExecutor.java | 40 ++++++++--------
.../TaskDeploymentDescriptorFactoryTest.java | 20 ++++++--
.../executiongraph/ExecutionVertexCancelTest.java | 9 ++--
.../coordination/EventReceivingTasks.java | 53 +---------------------
.../benchmark/SchedulerBenchmarkUtils.java | 4 +-
.../ExecutionTimeBasedSlowTaskDetectorTest.java | 14 ++++--
7 files changed, 60 insertions(+), 83 deletions(-)
copy
flink-core/src/main/java/org/apache/flink/util/concurrent/ScheduledExecutorServiceAdapter.java
=>
flink-runtime/src/test/java/org/apache/flink/runtime/concurrent/NoMainThreadCheckComponentMainThreadExecutor.java
(56%)
