From 902877e6f37e7989b9d9cf0188d9d43ac46eb803 Mon Sep 17 00:00:00 2001 From: waywtdcc Date: Wed, 3 Jan 2024 16:56:02 +0800 Subject: [PATCH] [Flink] Reduce excessively long thread sleep --- .../engine/flink/result/IncrementalResultFetchIterator.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/result/IncrementalResultFetchIterator.scala b/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/result/IncrementalResultFetchIterator.scala index 60c92d9afdf..cf4380cfad3 100644 --- a/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/result/IncrementalResultFetchIterator.scala +++ b/externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/result/IncrementalResultFetchIterator.scala @@ -58,7 +58,7 @@ class IncrementalResultFetchIterator( var hasNext: Boolean = true - val FETCH_INTERVAL_MS: Long = 1000 + val FETCH_INTERVAL_MS: Long = 50 // for Flink 1.16 and below, isQueryResult is not supported val isQueryResult: Boolean =