This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 6de32b74bc1 [HUDI-6365] Set hive sync tool only if syncs list is empty
(#8943)
6de32b74bc1 is described below
commit 6de32b74bc1e7a14696c00b7cac27d19d2ea6a45
Author: Nicolas Paris <[email protected]>
AuthorDate: Thu Jun 15 05:00:42 2023 +0200
[HUDI-6365] Set hive sync tool only if syncs list is empty (#8943)
---
.../src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git
a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala
b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala
index 4eb0bdad37e..c18a6c96d87 100644
---
a/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala
+++
b/hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala
@@ -894,10 +894,8 @@ object HoodieSparkSqlWriter {
hoodieConfig.getString(META_SYNC_CLIENT_TOOL_CLASS_NAME).split(",").foreach(syncClass
=> syncClientToolClassSet += syncClass)
// for backward compatibility
- if (hiveSyncEnabled) {
- metaSyncEnabled = true
- syncClientToolClassSet += classOf[HiveSyncTool].getName
- }
+ if (hiveSyncEnabled) metaSyncEnabled = true
+
if (metaSyncEnabled) {
val fs = basePath.getFileSystem(spark.sessionState.newHadoopConf())
