diff --git a/src/main/java/io/deephaven/benchmark/connect/BarrageConnector.java b/src/main/java/io/deephaven/benchmark/connect/BarrageConnector.java index f551719d..763c9727 100644 --- a/src/main/java/io/deephaven/benchmark/connect/BarrageConnector.java +++ b/src/main/java/io/deephaven/benchmark/connect/BarrageConnector.java @@ -115,11 +115,11 @@ public Future fetchSnapshotData(String table, Consumer tab try { BarrageSubscriptionOptions options = BarrageSubscriptionOptions.builder().build(); TableHandleManager snapshotManager = session.session().batch(); - + TableCreationLogic logic = findTable(table).ticket().ticketId().table().logic(); TableHandle handle = snapshotManager.executeLogic(logic); BarrageSubscription subscription = session.subscribe(handle, options); - + BarrageTable snapTable = subscription.snapshotEntireTable(); tableHandler.accept(CachedResultTable.create(snapTable)); return new Subscription(handle, subscription);