-
Notifications
You must be signed in to change notification settings - Fork 2.1k
Closed
Labels
Description
Search before asking
- I had searched in the issues and found no similar issues.
What happened
I have tested 2.3.5 and 2.3.6 version with
data_save_mode=CUSTOM_PROCESSING
custom_sql="delete from table;
system can't work. I also tested the same function with starocks. It is ok.
SeaTunnel Version
2.3.5
2.3.6
SeaTunnel Config
sink {
Doris {
fenodes = "ip***:8030"
query-port=9030
password=""
username=""
database = "test"
table = "***"
batch_max_rows=10240
data_save_mode=CUSTOM_PROCESSING
custom_sql="delete from table;"
doris.config = {
format = "json"
read_json_by_line = "true"
}
}
}
Running Command
/seatunnel-2.3.6/bin/seatunnel.sh --config aa.configError Exception
have no error. all the data have been inserted into the database . System can't delete the data from db.
Zeta or Flink or Spark Version
zeta
Java or Scala Version
java 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