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 index 178fe70515e..7022fc4af40 100644 --- 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,