From fdcbccd35ab3fc01029cac4faff06f6602f9fcf0 Mon Sep 17 00:00:00 2001
From: Piotr Findeisen <piotr.findeisen@gmail.com>
Date: Wed, 10 Aug 2022 11:13:56 +0200
Subject: [PATCH] Fix ignored Future in TestDeltaLakePageSink

It's to be future-proof and also suppress an error-prone warning.
Currently, the returned future is always already completed.
---
 .../java/io/trino/plugin/deltalake/TestDeltaLakePageSink.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakePageSink.java b/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakePageSink.java
index b1b31be42b97..845967fd2638 100644
--- a/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakePageSink.java
+++ b/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/TestDeltaLakePageSink.java
@@ -43,6 +43,7 @@
 import java.util.Collection;
 import java.util.List;
 import java.util.Optional;
+import java.util.concurrent.TimeUnit;
 
 import static com.google.common.collect.ImmutableList.toImmutableList;
 import static com.google.common.io.MoreFiles.deleteRecursively;
@@ -99,7 +100,7 @@ public void testPageSinkStats()
                 }
             }
             Page page = pageBuilder.build();
-            pageSink.appendPage(page);
+            pageSink.appendPage(page).get(10, TimeUnit.SECONDS);
 
             JsonCodec<DataFileInfo> dataFileInfoCodec = new JsonCodecFactory().jsonCodec(DataFileInfo.class);
             Collection<Slice> fragments = getFutureValue(pageSink.finish());