From 5b2d08fa08c0fa8f9aad3a5f201d825c6d478755 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Osipiuk?= Date: Tue, 14 Nov 2023 13:37:27 +0100 Subject: [PATCH] Do not require all sinks to be finished in FileSystemExchange It is not enforced by engine that each created sink will be finished. Some tasks may be abandoned as not required for computing query result and siks for those tasks will not be finished. --- .../io/trino/plugin/exchange/filesystem/FileSystemExchange.java | 1 - 1 file changed, 1 deletion(-) diff --git a/plugin/trino-exchange-filesystem/src/main/java/io/trino/plugin/exchange/filesystem/FileSystemExchange.java b/plugin/trino-exchange-filesystem/src/main/java/io/trino/plugin/exchange/filesystem/FileSystemExchange.java index 77eeeb251d64..f5c386fafab3 100644 --- a/plugin/trino-exchange-filesystem/src/main/java/io/trino/plugin/exchange/filesystem/FileSystemExchange.java +++ b/plugin/trino-exchange-filesystem/src/main/java/io/trino/plugin/exchange/filesystem/FileSystemExchange.java @@ -183,7 +183,6 @@ public void allRequiredSinksFinished() return; } verify(noMoreSinks, "noMoreSinks is expected to be set"); - verify(finishedSinks.keySet().containsAll(allSinks), "all sinks are expected to be finished"); // input is ready, create exchange source handles exchangeSourceHandlesCreationStarted = true; exchangeSourceHandlesCreationFuture = stats.getCreateExchangeSourceHandles().record(this::createExchangeSourceHandles);