[Bug] [Clickhouse to localfile] export Data rows error，need 1000,000 but actual 2000,000

[zhaohongyan133]

Search before asking

• I had searched in the issues and found no similar issues.

What happened

I want to export 100 or 1000,000 datas,but actual export 200 or 2000,000，it will happens every 10-20 times

SeaTunnel Version

2.3.9

SeaTunnel Config

env {
  parallelism = 4
  job.mode = "BATCH"
  checkpoint.interval = 100000
}

source {
  Clickhouse {
    host = "192.168.0.22:8123"
    database = "default"
    sql = "select * from argus.test limit 100"
    username = "default"
    password = "xxx"
    clickhouse.config = {
      "socket_timeout": "300000"
    }
  }
}

sink {

  LocalFile {
    path = "/home/zhaohy/seatunnel/output/"
    file_format_type = "csv"
    field_delimiter = ","
    row_delimiter = "\n"
  }

}

Running Command

./bin/seatunnel.sh --config config/argus_clickhouse_2_csv_100.conf -m local

Error Exception

no error

Zeta or Flink or Spark Version

zeta

Java or Scala Version

1.8

Screenshots

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[liunaijie]

try to set parallelism to 1