[FLINK] Fix fetch timeout in session conf doesn't support ISO-8601

apache · Dec 1, 2023 · 99a4964 · 99a4964
1 parent f4a739e
commit 99a4964
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...ne/src/main/scala/org/apache/kyuubi/engine/flink/operation/FlinkSQLOperationManager.scala b/...ne/src/main/scala/org/apache/kyuubi/engine/flink/operation/FlinkSQLOperationManager.scala
@@ -73,7 +73,10 @@ class FlinkSQLOperationManager extends OperationManager("FlinkSQLOperationManage
         resultMaxRowsDefault.toString).toInt
 
     val resultFetchTimeout =
-      flinkSession.normalizedConf.get(ENGINE_FLINK_FETCH_TIMEOUT.key).map(_.toLong milliseconds)
+      flinkSession.normalizedConf
+        .get(ENGINE_FLINK_FETCH_TIMEOUT.key)
+        .map(ENGINE_FLINK_FETCH_TIMEOUT.valueConverter)
+        .map(_.get milliseconds)
         .getOrElse(resultFetchTimeoutDefault)
 
     val op = mode match {