zhanggougou opened a new issue, #5910:
URL: https://github.com/apache/seatunnel/issues/5910

   this is my config:
   
   ```shell
   env {
       spark.app.name = "hive_to_ck_file"
       spark.executor.instances = 4
       spark.executor.cores = 1
       spark.sql.catalogImplementation = "hive"
       spark.executor.extraJavaOptions = "-Dfile.encoding=UTF-8"
       spark.driver.extraJavaOptions = "-Dfile.encoding=UTF-8"
       spark.hadoop.hive.exec.dynamic.partition = "true"
       spark.hadoop.hive.exec.dynamic.partition.mode = "nonstrict"
       spark.debug.maxToStringFields = 100000
   }
   source {
       Hive {
           table_name = "st.zgg_ch_test"
           metastore_uri = "*****"
           result_table_name = "tmp_zgg_table"
           parallelism = 4
       }
   }
   sink{
       ClickhouseFile {
         host = "****"
         database = "test"
         table = "zgg_ch_test"
         source_table_name = "tmp_zgg_table"
         username = "****"
         password = "*****"
         clickhouse_local_path = "/usr/bin/clickhouse local"
         node_pass = [{
           node_address = "****"
           username="root"
           password = "****"
         },{
           node_address = "****"
           username="root"
           password = "****"
         }]
       }
   }
   ``` 
   
   
   and the run sh is
   `./bin/start-seatunnel-spark-2-connector-v2.sh --master yarn --deploy-mode 
cluster --config `
   
   when run in spark,it tell me can't find field id,but i am sure the table has 
id field,both hive table and clickhouse table is correct! can any people help 
me,much thanks!
   
![2](https://github.com/apache/seatunnel/assets/25924003/e769e8dd-e173-4169-8d1e-cb4ce1f02c1c)
   
   


-- 
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]

Reply via email to