update

apache · Dec 29, 2023 · 768e1e9 · 768e1e9
1 parent e12528c
commit 768e1e9
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 8 deletions.
diff --git a/...bi-chat-engine/src/main/scala/org/apache/kyuubi/engine/chat/operation/ChatOperation.scala b/...bi-chat-engine/src/main/scala/org/apache/kyuubi/engine/chat/operation/ChatOperation.scala
@@ -31,8 +31,8 @@ abstract class ChatOperation(session: Session) extends AbstractOperation(session
 
   protected lazy val conf: KyuubiConf = session.sessionManager.getConf
 
-  protected val isGenerateTRowSetInParallel: Boolean =
-    session.conf(KyuubiConf.OPERATION_TROWSET_GENERATION_IN_PARALLEL.key).toBoolean
+  protected val isGenerateTRowSetInParallel: Boolean = session.conf
+    .getOrElse(KyuubiConf.OPERATION_TROWSET_GENERATION_IN_PARALLEL.key, "false").toBoolean
 
   override def getNextRowSetInternal(
       order: FetchOrientation,

diff --git a/...k-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/operation/FlinkOperation.scala b/...k-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/operation/FlinkOperation.scala
@@ -56,8 +56,8 @@ abstract class FlinkOperation(session: Session) extends AbstractOperation(sessio
 
   protected var resultSet: ResultSet = _
 
-  protected val isGenerateTRowSetInParallel: Boolean =
-    session.conf(KyuubiConf.OPERATION_TROWSET_GENERATION_IN_PARALLEL.key).toBoolean
+  protected val isGenerateTRowSetInParallel: Boolean = session.conf
+    .getOrElse(KyuubiConf.OPERATION_TROWSET_GENERATION_IN_PARALLEL.key, "false").toBoolean
 
   override protected def beforeRun(): Unit = {
     setHasResultSet(true)

diff --git a/...bi-jdbc-engine/src/main/scala/org/apache/kyuubi/engine/jdbc/operation/JdbcOperation.scala b/...bi-jdbc-engine/src/main/scala/org/apache/kyuubi/engine/jdbc/operation/JdbcOperation.scala
@@ -35,8 +35,8 @@ abstract class JdbcOperation(session: Session) extends AbstractOperation(session
 
   protected lazy val dialect: JdbcDialect = JdbcDialects.get(conf)
 
-  protected val isGenerateTRowSetInParallel: Boolean =
-    session.conf(KyuubiConf.OPERATION_TROWSET_GENERATION_IN_PARALLEL.key).toBoolean
+  protected val isGenerateTRowSetInParallel: Boolean = session.conf
+    .getOrElse(KyuubiConf.OPERATION_TROWSET_GENERATION_IN_PARALLEL.key, "false").toBoolean
 
   def validateFetchOrientation(order: FetchOrientation): Unit =
     validateDefaultFetchOrientation(order)

diff --git a/...trino-engine/src/main/scala/org/apache/kyuubi/engine/trino/operation/TrinoOperation.scala b/...trino-engine/src/main/scala/org/apache/kyuubi/engine/trino/operation/TrinoOperation.scala
@@ -46,8 +46,8 @@ abstract class TrinoOperation(session: Session) extends AbstractOperation(sessio
 
   protected var iter: FetchIterator[List[Any]] = _
 
-  protected val isGenerateTRowSetInParallel: Boolean =
-    session.conf(KyuubiConf.OPERATION_TROWSET_GENERATION_IN_PARALLEL.key).toBoolean
+  protected val isGenerateTRowSetInParallel: Boolean = session.conf
+    .getOrElse(KyuubiConf.OPERATION_TROWSET_GENERATION_IN_PARALLEL.key, "false").toBoolean
 
   override def getResultSetMetadata: TGetResultSetMetadataResp = {
     val tTableSchema = SchemaHelper.toTTableSchema(schema)