[Bug] [CheckPoint] checkpoint ineffective

[15767714253]

Search before asking

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

What happened

SeaTunnel Version

2.3.5

SeaTunnel Config

env {
  execution.parallelism = 2
  job.mode = "BATCH"
  checkpoint.interval = 2000
  read_limit.rows_per_second=1
  job.name = cell-Job
}

source {

    InfluxDB {
        result_table_name = "test"
        url = "http://localhost:8086"
        sql = "select number from test1"
        database = "mydb"
        username = "admin"
        password = "123456"
        upper_bound = 10
        lower_bound = 1
        partition_num = 10
        split_column = "number"
        query_timeout_sec = 60
        connect_timeout_ms = 150000
        chunk_size = 1
        chunk_read = true
        schema {
                fields {
                         number = INT
                }
        }
    }

}


sink {
  Console {
          source_table_name = "test"
        }

}

Running Command

./start-seatunnel-flink-15-connector-v2.sh --config ../jobs/job.txt

Error Exception

**BATCH    checkpoint ineffective**

Zeta or Flink or Spark Version

No response

Java or Scala Version

No response

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]

using streaming mode

[15767714253]

using streaming mode
this source support batch mode only