Skip to content

Commit 11fc7b1

Browse files
committed
SERDEPROPERTIES are missing when KSHC create table
1 parent 490009d commit 11fc7b1

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

  • extensions/spark/kyuubi-spark-connector-hive/src/main/scala/org/apache/kyuubi/spark/connector/hive

extensions/spark/kyuubi-spark-connector-hive/src/main/scala/org/apache/kyuubi/spark/connector/hive/HiveTableCatalog.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -437,17 +437,17 @@ class HiveTableCatalog(sparkSession: SparkSession)
437437
/**
438438
* Splits properties into optionsProps and serdeProps based on the `options.` prefix.
439439
*
440-
* - optionsProps: keys with "options." prefix whose stripped key does NOT exist in properties,
440+
* - optionsProps: keys with "options." prefix whose stripped key ALREADY exist in properties,
441441
* indicating they were originally specified via OPTIONS clause.
442-
* - serdeProps: keys with "options." prefix whose stripped key ALREADY exists in properties,
442+
* - serdeProps: keys with "options." prefix whose stripped key does NOT exists in properties,
443443
* indicating they were originally specified via SERDEPROPERTIES clause
444444
*
445445
* @param properties the full properties map
446446
* @return a tuple of (optionsProps, serdeProps), both with the "options." prefix stripped
447447
*/
448448
private def toOptionsAndSerdeProps(
449449
properties: Map[String, String]): (Map[String, String], Map[String, String]) = {
450-
val (serdeProps, optionsProps) = properties
450+
val (optionsProps, serdeProps) = properties
451451
.filterKeys(_.startsWith(TableCatalog.OPTION_PREFIX))
452452
.map { case (key, value) => key.drop(TableCatalog.OPTION_PREFIX.length) -> value }
453453
.toMap

0 commit comments

Comments
 (0)