k8slight opened a new issue, #5058: URL: https://github.com/apache/seatunnel/issues/5058
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened read data from csv file by HdfsFile/LocalFile plugin, then write the data to mysql. the number of csv file lines is 357147, but the number of database data rows exceeded 357147     ### SeaTunnel Version 2.3.2 ### SeaTunnel Config ```conf env { execution.parallelism = 1 job.mode = "BATCH" } # 在source所属的块中配置数据源 source { HdfsFile { schema { fields { user_id = int item_id = int category_id = int action = string timestamp = bigint } } path = "/data/source/UserBehavior01.csv" file_format_type = "csv" fs.defaultFS = "hdfs://mycluster" hdfs_site_path = "/opt/hadoop-2.10.2/etc/hadoop/hdfs-site.xml" } } # 在transform的块中声明转换插件 transform { } # 在sink块中声明要输出到哪 sink { jdbc { url = "jdbc:mysql://node5:3306/bigdata_ods?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&serverTimezone=GMT%2B8&useSSL=false" driver = "com.mysql.cj.jdbc.Driver" user = "****" password = "****" query = "insert into USER_BEHAVIOR values(?,?,?,?,?)" } } ``` ### Running Command ```shell seatunnel.sh --config test.config --deploy-mode cluster ``` ### Error Exception ```log no error ``` ### Flink or Spark Version _No response_ ### Java or Scala Version java version "1.8.0_361" ### 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]
