hotfix_metorikku_hive_sync_manually: CatalogTable set provider hive (#…

…301)
YotpoLtd · Apr 13, 2020 · c6100fe · c6100fe
1 parent 388fe48
commit c6100fe
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/main/scala/com/yotpo/metorikku/output/writers/file/HudiOutputWriter.scala b/src/main/scala/com/yotpo/metorikku/output/writers/file/HudiOutputWriter.scala
@@ -377,7 +377,7 @@ class HudiOutputWriter(props: Map[String, Object], hudiOutput: Option[Hudi]) ext
         false,
         Map[String, String]())
 
-      val tableDefinition = new CatalogTable(identifier, tableType, storage, df.schema,
+      val tableDefinition = new CatalogTable(identifier, tableType, storage, df.schema, Option("hive"),
         partitionColumnNames = manualHiveSyncPartitions match {
           case Some(partitions) => Seq(partitions.keySet.toSeq: _*)
           case _ => Seq.empty
@@ -408,7 +408,6 @@ class HudiOutputWriter(props: Map[String, Object], hudiOutput: Option[Hudi]) ext
       // alter location if needed
       ss.sharedState.externalCatalog.alterTable(tableDefinition)
 
-
       // Create partitions
       manualHiveSyncPartitions match {
         case Some(partitions) => {