From df757582bb140a1837ebf45fead0810c4e8b4b4b Mon Sep 17 00:00:00 2001
From: avv <avv@arenadata.io>
Date: Fri, 29 Nov 2024 10:18:57 +0500
Subject: [PATCH] ADH-5240 - refactored page process provider

---
 .../gpfdist/load/process/GpfdistPageProcessorProvider.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/plugin/trino-adb/src/main/java/io/trino/plugin/adb/connector/protocol/gpfdist/load/process/GpfdistPageProcessorProvider.java b/plugin/trino-adb/src/main/java/io/trino/plugin/adb/connector/protocol/gpfdist/load/process/GpfdistPageProcessorProvider.java
index f7edae4453cc..d9081b710460 100644
--- a/plugin/trino-adb/src/main/java/io/trino/plugin/adb/connector/protocol/gpfdist/load/process/GpfdistPageProcessorProvider.java
+++ b/plugin/trino-adb/src/main/java/io/trino/plugin/adb/connector/protocol/gpfdist/load/process/GpfdistPageProcessorProvider.java
@@ -43,7 +43,6 @@ public void add(PageProcessor processor)
         lock.lock();
         try {
             pageProcessors.add(processor);
-            isReadyForProcessing.set(true);
             isReadyForProcessingCondition.signalAll();
         }
         finally {
@@ -71,6 +70,7 @@ public PageProcessor take()
                         throw new RuntimeException(e);
                     }
                 }
+                isReadyForProcessing.set(true);
             }
             PageProcessor pageProcessor = pageProcessors.poll();
             pageProcessors.offer(pageProcessor);