Skip to content

[Bug] [Module Name] Doris custom_sql can't work #7367

@RaymondFishWang

Description

@RaymondFishWang

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.config

Error 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

Metadata

Metadata

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions