diff --git a/core/trino-main/src/test/java/io/trino/operator/TestDriver.java b/core/trino-main/src/test/java/io/trino/operator/TestDriver.java index 9880887c871b..ffbd3786233e 100644 --- a/core/trino-main/src/test/java/io/trino/operator/TestDriver.java +++ b/core/trino-main/src/test/java/io/trino/operator/TestDriver.java @@ -206,7 +206,6 @@ public void testBrokenOperatorCloseWhileProcessing() driver.close(); assertTrue(driver.isFinished()); - assertFalse(driver.getDestroyedFuture().isDone()); assertThatThrownBy(() -> driverProcessFor.get(1, TimeUnit.SECONDS)) .isInstanceOf(ExecutionException.class) @@ -321,7 +320,6 @@ public void testBrokenOperatorAddSource() driver.close(); assertTrue(driver.isFinished()); - assertFalse(driver.getDestroyedFuture().isDone()); assertThatThrownBy(() -> driverProcessFor.get(1, TimeUnit.SECONDS)) .isInstanceOf(ExecutionException.class)