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 <[email protected]> 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(
