From 01752f91c0937a42395d26b2b52020521aadc51f Mon Sep 17 00:00:00 2001
From: zhousipei <zsp233@qq.com>
Date: Fri, 12 Aug 2022 15:25:28 +0800
Subject: [PATCH] fix close bug in OmniMergingPageOutput

---
 .../olk/operator/filterandproject/OmniMergingPageOutput.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/omnioperator/omniop-openlookeng-extension/src/main/java/nova/hetu/olk/operator/filterandproject/OmniMergingPageOutput.java b/omnioperator/omniop-openlookeng-extension/src/main/java/nova/hetu/olk/operator/filterandproject/OmniMergingPageOutput.java
index 2927ea0b9..28ce75ccb 100644
--- a/omnioperator/omniop-openlookeng-extension/src/main/java/nova/hetu/olk/operator/filterandproject/OmniMergingPageOutput.java
+++ b/omnioperator/omniop-openlookeng-extension/src/main/java/nova/hetu/olk/operator/filterandproject/OmniMergingPageOutput.java
@@ -267,8 +267,8 @@ public class OmniMergingPageOutput
     public void close()
     {
         // free input page due to it may not be handled
-        while (currentInput != null) {
-            if (currentInput.hasNext()) {
+        if (currentInput != null) {
+            while (currentInput.hasNext()) {
                 Optional<Page> page = currentInput.next();
                 if (page.isPresent()) {
                     BlockUtils.freePage(page.get());
-- 
Gitee