From 72d739b61106c00f2e3dbaa83fd736c8d206e205 Mon Sep 17 00:00:00 2001 From: Tglman Date: Tue, 19 Sep 2023 12:15:22 +0100 Subject: [PATCH] fix: correct distributed metadata query --- .../core/sql/executor/FetchFromDistributedMetadataStep.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/java/com/orientechnologies/orient/core/sql/executor/FetchFromDistributedMetadataStep.java b/core/src/main/java/com/orientechnologies/orient/core/sql/executor/FetchFromDistributedMetadataStep.java index 58a659fa1d0..79b19609e88 100644 --- a/core/src/main/java/com/orientechnologies/orient/core/sql/executor/FetchFromDistributedMetadataStep.java +++ b/core/src/main/java/com/orientechnologies/orient/core/sql/executor/FetchFromDistributedMetadataStep.java @@ -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); }