Skip to content

Commit 00fce8e

Browse files
committed
SERDEPROPERTIES are missing when KSHC create table
1 parent ecacba7 commit 00fce8e

1 file changed

Lines changed: 5 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: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -322,6 +322,7 @@ class HiveTableCatalog(sparkSession: SparkSession)
322322
getStorageFormatAndProvider(
323323
maybeProvider,
324324
location,
325+
tableProperties,
325326
toOptions(tableProperties))
326327
val isExternal = properties.containsKey(TableCatalog.PROP_EXTERNAL)
327328
val tableType =
@@ -583,15 +584,16 @@ private object HiveTableCatalog extends Logging {
583584
private def getStorageFormatAndProvider(
584585
provider: Option[String],
585586
location: Option[String],
586-
options: Map[String, String]): (CatalogStorageFormat, String) = {
587+
options: Map[String, String],
588+
serdeProperties: Map[String, String]): (CatalogStorageFormat, String) = {
587589
val nonHiveStorageFormat = CatalogStorageFormat.empty.copy(
588590
locationUri = location.map(CatalogUtils.stringToURI),
589-
properties = options)
591+
properties = serdeProperties)
590592

591593
val conf = SQLConf.get
592594
val defaultHiveStorage = HiveSerDe.getDefaultStorage(conf).copy(
593595
locationUri = location.map(CatalogUtils.stringToURI),
594-
properties = options)
596+
properties = serdeProperties)
595597

596598
if (provider.isDefined) {
597599
(nonHiveStorageFormat, provider.get)

0 commit comments

Comments
 (0)