You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2020/06/11 13:04:42 UTC
[flink] 03/03: [FLINK-18058][mesos][tests] Increase heartbeat
interval/timeout
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
commit f889a31d314e7435a4fbbb3b56c1e5b69906039e
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Wed Jun 10 15:40:49 2020 +0200
[FLINK-18058][mesos][tests] Increase heartbeat interval/timeout
---
.../flink/mesos/runtime/clusterframework/MesosResourceManagerTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerTest.java b/flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerTest.java
index b9c6ac3..6d31364 100644
--- a/flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerTest.java
+++ b/flink-mesos/src/test/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerTest.java
@@ -338,7 +338,7 @@ public class MesosResourceManagerTest extends TestLogger {
highAvailabilityServices = new TestingHighAvailabilityServices();
rmLeaderElectionService = new TestingLeaderElectionService();
highAvailabilityServices.setResourceManagerLeaderElectionService(rmLeaderElectionService);
- heartbeatServices = new HeartbeatServices(5L, 5L);
+ heartbeatServices = new HeartbeatServices(Integer.MAX_VALUE, Integer.MAX_VALUE);
slotManager = mock(SlotManager.class);
slotManagerStarted = new CompletableFuture<>();
jobLeaderIdService = new JobLeaderIdService(