diff --git a/testing/trino-testing/src/main/java/io/trino/testing/AbstractDistributedEngineOnlyQueries.java b/testing/trino-testing/src/main/java/io/trino/testing/AbstractDistributedEngineOnlyQueries.java index ae417103b393..bc36757a7840 100644 --- a/testing/trino-testing/src/main/java/io/trino/testing/AbstractDistributedEngineOnlyQueries.java +++ b/testing/trino-testing/src/main/java/io/trino/testing/AbstractDistributedEngineOnlyQueries.java @@ -54,7 +54,10 @@ public void setUp() @AfterClass(alwaysRun = true) public void shutdown() { - executorService.shutdownNow(); + if (executorService != null) { + executorService.shutdownNow(); + executorService = null; + } } /**