Free the chunks in case of failure

deephaven · Jun 4, 2024 · f94d46c · f94d46c
1 parent 0c87091
commit f94d46c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/remote/ConstructSnapshot.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/remote/ConstructSnapshot.java
@@ -1555,6 +1555,8 @@ private static boolean serializeAllTable(
                 if (!(err instanceof SnapshotUnsuccessfulException)) {
                     throw new SnapshotUnsuccessfulException("Snapshot failed", err);
                 }
+                // Free any resources that may have been allocated
+                snapshot.close();
                 return false;
             }
         } catch (final InterruptedException e) {
@@ -1581,7 +1583,7 @@ private static boolean serializeAllTable(
 
 
     /**
-     * Check if all the required columns are {@link InMemoryColumnSource}.
+     * Check if all the required column sources are {@link InMemoryColumnSource}.
      */
     private static boolean allColumnSourcesInMemory(
             @NotNull final Table table,