You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fa...@apache.org on 2024/02/20 14:21:34 UTC
(flink) branch release-1.19 updated (a9bec20cdef -> c91029b0456)
This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a change to branch release-1.19
in repository https://gitbox.apache.org/repos/asf/flink.git
from a9bec20cdef [hotfix][docs] Update the versions of mongodb supported by mongodb-connector (#24342)
new b7ea090082d [hotfix][tests] Disables cool down phase for faster test execution
new c91029b0456 [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes
The 2 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:
.../org/apache/flink/test/checkpointing/AutoRescalingITCase.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
(flink) 01/02: [hotfix][tests] Disables cool down phase for faster test execution
Posted by fa...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a commit to branch release-1.19
in repository https://gitbox.apache.org/repos/asf/flink.git
commit b7ea090082d374e4788192dc75eabfa0bbca2777
Author: Rui Fan <19...@gmail.com>
AuthorDate: Thu Feb 1 21:09:34 2024 +0800
[hotfix][tests] Disables cool down phase for faster test execution
---
.../java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java
index eab82b1c727..9b95c8aa41c 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java
@@ -163,6 +163,8 @@ public class AutoRescalingITCase extends TestLogger {
NettyShuffleEnvironmentOptions.NETWORK_BUFFERS_PER_CHANNEL, buffersPerChannel);
config.set(JobManagerOptions.SCHEDULER, JobManagerOptions.SchedulerType.Adaptive);
+ // Disable the scaling cooldown to speed up the test
+ config.set(JobManagerOptions.SCHEDULER_SCALING_INTERVAL_MIN, Duration.ofMillis(0));
// speed the test suite up
// - lower refresh interval -> controls how fast we invalidate ExecutionGraphCache
(flink) 02/02: [FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes
Posted by fa...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a commit to branch release-1.19
in repository https://gitbox.apache.org/repos/asf/flink.git
commit c91029b0456ddd7635fe0f04ad9ecb4813c5d5a3
Author: Rui Fan <19...@gmail.com>
AuthorDate: Fri Feb 2 13:08:01 2024 +0800
[FLINK-34336][test] Fix the bug that AutoRescalingITCase may hang sometimes
---
.../org/apache/flink/test/checkpointing/AutoRescalingITCase.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java
index 9b95c8aa41c..98df5533fd2 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/AutoRescalingITCase.java
@@ -343,7 +343,7 @@ public class AutoRescalingITCase extends TestLogger {
restClusterClient.updateJobResourceRequirements(jobID, builder.build()).join();
- waitForRunningTasks(restClusterClient, jobID, parallelism2);
+ waitForRunningTasks(restClusterClient, jobID, 2 * parallelism2);
waitForAvailableSlots(restClusterClient, totalSlots - parallelism2);
StateSourceBase.canFinishLatch.countDown();
@@ -433,7 +433,8 @@ public class AutoRescalingITCase extends TestLogger {
restClusterClient.updateJobResourceRequirements(jobID, builder.build()).join();
- waitForRunningTasks(restClusterClient, jobID, parallelism2);
+ // Source is parallelism, the flatMapper & Sink is parallelism2
+ waitForRunningTasks(restClusterClient, jobID, parallelism + parallelism2);
waitForAvailableSlots(restClusterClient, totalSlots - parallelism2);
SubtaskIndexSource.SOURCE_LATCH.trigger();