Skip to content

Commit

Permalink
fix: correct distributed metadata query
Browse files Browse the repository at this point in the history
  • Loading branch information
tglman committed Sep 19, 2023
1 parent ca4067a commit 72d739b
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ public FetchFromDistributedMetadataStep(OCommandContext ctx, boolean profilingEn

@Override
public OResultSet syncPull(OCommandContext ctx, int nRecords) throws OTimeoutException {
if (resultSet != null) {
if (resultSet == null) {
getPrev().ifPresent(x -> x.syncPull(ctx, nRecords));
resultSet = new OProduceOneResult(() -> produce(ctx), true);
}
Expand Down

0 comments on commit 72d739b

Please sign in to comment.