Update externals/kyuubi-flink-sql-engine/src/test/scala/org/apache/ky…

…uubi/engine/flink/operation/FlinkOperationSuite.scala Co-authored-by: Cheng Pan <pan3793@gmail.com>
apache · Oct 30, 2023 · ce7fd79 · ce7fd79
1 parent dc3a4b9
commit ce7fd79
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...-engine/src/test/scala/org/apache/kyuubi/engine/flink/operation/FlinkOperationSuite.scala b/...-engine/src/test/scala/org/apache/kyuubi/engine/flink/operation/FlinkOperationSuite.scala
@@ -637,7 +637,8 @@ abstract class FlinkOperationSuite extends HiveJDBCTestHelper with WithFlinkTest
 
   test("execute statement - show/stop jobs") {
     if (FLINK_RUNTIME_VERSION >= "1.17") {
-      // we need set the conf's value to make sure it will not cancel stream query before stop job
+      // use a bigger value to ensure all tasks of the streaming query run until
+      // we explicitly stop the job.
       withSessionConf()(Map(ENGINE_FLINK_MAX_ROWS.key -> "10000"))(Map.empty) {
         withMultipleConnectionJdbcStatement()({ statement =>
           statement.executeQuery(