From c5e17a323c0515e6cbc2a64bbc546ff7cd6f93b7 Mon Sep 17 00:00:00 2001
From: Parag Badani <pbadani@confluent.io>
Date: Tue, 18 Mar 2025 21:56:54 +0530
Subject: [PATCH] Test

---
 .../java/io/confluent/ksql/test/rest/RestTestExecutor.java | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/ksqldb-functional-tests/src/test/java/io/confluent/ksql/test/rest/RestTestExecutor.java b/ksqldb-functional-tests/src/test/java/io/confluent/ksql/test/rest/RestTestExecutor.java
index e77883617bdd..f9421e9f477f 100644
--- a/ksqldb-functional-tests/src/test/java/io/confluent/ksql/test/rest/RestTestExecutor.java
+++ b/ksqldb-functional-tests/src/test/java/io/confluent/ksql/test/rest/RestTestExecutor.java
@@ -200,7 +200,12 @@ void buildAndExecuteQuery(final RestTestCase testCase) {
         IntegrationTestUtil.waitForPersistentQueriesToProcessInputs(kafkaCluster, engine);
       }
 
-      final List<RqttResponse> queryResults = sendQueryStatements(testCase, statements.queries,
+        try {
+          Thread.sleep(100);
+        } catch (InterruptedException e) {
+          throw new RuntimeException(e);
+        }
+        final List<RqttResponse> queryResults = sendQueryStatements(testCase, statements.queries,
           postInputConditionRunnable);
 
       if (!queryResults.isEmpty()) {