ocean-zhc opened a new issue, #4727: URL: https://github.com/apache/incubator-seatunnel/issues/4727
### 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 json Example：`{"name":"zhc","age":15}` hive DDL： ``` CREATE TABLE `default.user1`( `name` string, `age` int) row format delimited fields terminated by '\n' stored as orc tblproperties ("orc.compress"="NONE"); ``` SeaTunnel conf: ``` env { execution.parallelism = 1 job.mode = "STREAMING" execution.planner = blink job.name = "kafka_console_test" execution.checkpoint.interval = 60000 } source { Kafka { result_table_name = "kafka_table" schema = { fields { name = "string" age = "int" } } topic = "DZFP_DZDZ.DZDZ_FPXX_JDCFP" bootstrap.servers = "local:19092" kafka.config = { client.id = client_1 max.poll.records = 500 auto.offset.reset = "earliest" enable.auto.commit = "false" } } } transform { } sink { Hive { table_name = "default.user1" metastore_uri = "thrift://centos4:9083" } } ``` ### SeaTunnel Version 2.3.1 ### SeaTunnel Config ```conf env { execution.parallelism = 1 job.mode = "STREAMING" execution.planner = blink job.name = "kafka_console_test" execution.checkpoint.interval = 60000 } source { Kafka { result_table_name = "kafka_table" schema = { fields { name = "string" age = "int" } } topic = "DZFP_DZDZ.DZDZ_FPXX_JDCFP" bootstrap.servers = "local:19092" kafka.config = { client.id = client_1 max.poll.records = 500 auto.offset.reset = "earliest" enable.auto.commit = "false" } } } transform { } sink { Hive { table_name = "default.user1" metastore_uri = "thrift://centos4:9083" } } ``` ``` ### Running Command ```shell ./start-seatunnel-spark-3-connector-v2.sh --master spark://centos4:7077 --deploy-mode client --config /home/app/py/tmp/jdcfp.conf ``` ### Error Exception ```log No Error, but data cannot be written~ ``` ### Flink or Spark Version Spark 3.2.2 ### Java or Scala Version Java：1.8.0_172 Scala：2.12 ### Screenshots _No response_ ### Are you willing to submit PR? - [ ] 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]
