Closed Larborator closed 1 month ago
I found when the row reaches the size, the data of cached not write to server immediately. It depends on when checkpoint executed. Is this meet expectations?
2.3.5
{ "env": { "parallelism": 1, "job.mode": "STREAMING", "job.name": "SeaTunnel", "checkpoint.interval": 5000, "execution.checkpoint.mode": "exactly-once" }, "source": [{ "plugin_name": "Kafka", "startup_mode": "LATEST", "commit_on_checkpoint": false, ... }], "sink": [{ "plugin_name": "Doris", "fenodes": "", "username": "", "password": "", "table.identifier": "", "sink.enable-2pc": "false", "sink.label-prefix": "test", "doris.batch.size": 1, "doris.config": { "format": "json", "read_json_by_line": "true" } }] }
bin/start-seatunnel-flink-13-connector-v2.sh
no error exception
No response
Search before asking
What happened
I found when the row reaches the size, the data of cached not write to server immediately. It depends on when checkpoint executed. Is this meet expectations?
SeaTunnel Version
2.3.5
SeaTunnel Config
Running Command
Error Exception
Zeta or Flink or Spark Version
No response
Java or Scala Version
No response
Screenshots
No response
Are you willing to submit PR?
Code of Conduct