[hotfix][coordination][tests] Remove error message assertions

shunanli-snl · Dec 17, 2020 · 8393700 · 8393700
1 parent 4b87866
commit 8393700
Showing 1 changed file with 0 additions and 12 deletions.
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/minicluster/MiniClusterITCase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/minicluster/MiniClusterITCase.java
@@ -113,12 +113,6 @@ public void testHandleStreamingJobsWhenNotEnoughSlot() throws Exception {
 		} catch (JobExecutionException e) {
 			assertTrue(findThrowableWithMessage(e, "Job execution failed.").isPresent());
 			assertTrue(findThrowable(e, NoResourceAvailableException.class).isPresent());
-
-			//TODO: remove the legacy scheduler message check once legacy scheduler is removed
-			final String legacySchedulerErrorMessage = "Slots required: 2, slots allocated: 1";
-			final String ngSchedulerErrorMessage = "Could not allocate the required slot within slot request timeout";
-			assertTrue(findThrowableWithMessage(e, legacySchedulerErrorMessage).isPresent() ||
-				findThrowableWithMessage(e, ngSchedulerErrorMessage).isPresent());
 		}
 	}
 
@@ -130,12 +124,6 @@ public void testHandleBatchJobsWhenNotEnoughSlot() throws Exception {
 		} catch (JobExecutionException e) {
 			assertTrue(findThrowableWithMessage(e, "Job execution failed.").isPresent());
 			assertTrue(findThrowable(e, NoResourceAvailableException.class).isPresent());
-
-			//TODO: remove the legacy scheduler message check once legacy scheduler is removed
-			final String legacySchedulerErrorMessage = "Could not allocate enough slots";
-			final String ngSchedulerErrorMessage = "Could not allocate the required slot within slot request timeout";
-			assertTrue(findThrowableWithMessage(e, legacySchedulerErrorMessage).isPresent() ||
-				findThrowableWithMessage(e, ngSchedulerErrorMessage).isPresent());
 		}
 	}