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 =