From cbd4c0c3d6bfd9508812b88092d7c40443122af2 Mon Sep 17 00:00:00 2001 From: davidyuan Date: Thu, 26 Oct 2023 19:43:24 +0800 Subject: [PATCH] fix flink on yarn test bug --- .../kyuubi/engine/flink/operation/FlinkOperationSuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/externals/kyuubi-flink-sql-engine/src/test/scala/org/apache/kyuubi/engine/flink/operation/FlinkOperationSuite.scala b/externals/kyuubi-flink-sql-engine/src/test/scala/org/apache/kyuubi/engine/flink/operation/FlinkOperationSuite.scala index 8e7c35a95a4..cac9d107505 100644 --- a/externals/kyuubi-flink-sql-engine/src/test/scala/org/apache/kyuubi/engine/flink/operation/FlinkOperationSuite.scala +++ b/externals/kyuubi-flink-sql-engine/src/test/scala/org/apache/kyuubi/engine/flink/operation/FlinkOperationSuite.scala @@ -648,7 +648,7 @@ abstract class FlinkOperationSuite extends HiveJDBCTestHelper with WithFlinkTest assert(insertResult1.next()) val jobId1 = insertResult1.getString(1) - Thread.sleep(5000) + Thread.sleep(3000) val showResult = statement.executeQuery("show jobs") val metadata = showResult.getMetaData