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 2021/04/15 00:20:07 UTC
[flink] 01/02: [hotfix][tests] Remove unnecessary component
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 5bbaa9b47de446383a160bd28ff8c97a80e02939
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Wed Apr 14 11:13:33 2021 +0200
[hotfix][tests] Remove unnecessary component
---
.../runtime/resourcemanager/slotmanager/DeclarativeSlotManagerTest.java | 2 --
1 file changed, 2 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManagerTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManagerTest.java
index e2e6028..7c9d24a 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManagerTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/resourcemanager/slotmanager/DeclarativeSlotManagerTest.java
@@ -1376,7 +1376,6 @@ public class DeclarativeSlotManagerTest extends TestLogger {
@Test
public void testReclaimInactiveSlotsOnEmptyRequirements() throws Exception {
- final SlotTracker slotTracker = new DefaultSlotTracker();
final CompletableFuture<JobID> freeInactiveSlotsJobIdFuture = new CompletableFuture<>();
@@ -1387,7 +1386,6 @@ public class DeclarativeSlotManagerTest extends TestLogger {
try (final DeclarativeSlotManager slotManager =
createDeclarativeSlotManagerBuilder()
- .setSlotTracker(slotTracker)
.buildAndStart(
ResourceManagerId.generate(),
ComponentMainThreadExecutorServiceAdapter.forMainThread(),