Fix NPE in ExchangeSink

trinodb · Feb 24, 2022 · 1882032 · 1882032
1 parent d18f8b0
commit 1882032
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/plugin/trino-exchange/src/main/java/io/trino/plugin/exchange/FileSystemExchangeSink.java b/plugin/trino-exchange/src/main/java/io/trino/plugin/exchange/FileSystemExchangeSink.java
@@ -259,7 +259,7 @@ private void writeInternal(Slice slice)
         private void flushIfNeeded(boolean finished)
         {
             SliceOutput buffer = currentBuffer;
-            if (!buffer.isWritable() || finished) {
+            if (buffer != null && (!buffer.isWritable() || finished)) {
                 if (!buffer.isWritable()) {
                     currentBuffer = null;
                 }