chenhu opened a new issue, #1805: URL: https://github.com/apache/incubator-seatunnel/issues/1805
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened Hoodie sink plugin can't create partition path correctly, the partition key field has been confirmed, but the partition path can't create like p=<value> ， it is "p=default" JDBC source, the table key like " select a, b, to_char('someDateTimeColumn',YYYYMMDD) as p from someTable " the hudi sink config the hudi.datasource.write.partition.field = "p" then the hudi basepath partition path will be p=default but where i config the hudi sink config the hudi.datasource.write.partition.field = "P", It will work fine. ### SeaTunnel Version 2.1.1 ### SeaTunnel Config ```conf the hudi sink config below: hudi { hoodie.base.path = "hdfs://hacluster/user/les_task_user/hudi/ods/violation/vio_violation" hoodie.table.name = "vio_violation" save mode = "Overwrite" hoodie.datasource.write.operation = "bulk_insert" hoodie.datasource.write.recordkey.field = "WFBH" hoodie.datasource.write.partitionpath.field = "p" hoodie.datasource.write.precombine.field = "GXSJ" hoodie.datasource.write.hive_style _partitioning = "false" hoodie.datasource.write.hive_sync.enable = "true" hoodie.datasource.write.hive_sync.database = "violation" hoodie.datasource.write.hive_sync.table = "vio violation" hoodie.datasource.write.hive_sync.partition_fields = "p" hoodie.datasource.write.hive_sync.use_jdbc = "false" hoodie.datasource.write.hive_sync.partition_extractor_class = "org.apache.hudi.hive.MultiPartkeysValueExtractor" hoodie.datasource.write.hive_sync.support_timestamp = "true" hoodie.datasource.write.row.writer.enable = "true" hoodie.datasource.write.keygenerator.class = "org.apache.hudi.keygen.ComplexkeyGenerator" } ``` ### Running Command ```shell seatunnel/bin/start-seatunnel-spark.sh --master yarn --deploy-mode client -c st/config/xxxx.conf ``` ### Error Exception ```log nothing ``` ### Flink or Spark Version spark3.1.1 (I have compile a SeaTunnel support spark3.1.1) ### Java or Scala Version java8 ### Screenshots _No response_ ### Are you willing to submit PR? - [X] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
