Caused by: org.apache.doris.flink.exception.DorisException: Load status is Label Already Exists and load job finished, change you label prefix or restore from latest savepoint!

[ai-smalleryu]

Search before asking

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

Java Version

1.8

Scala Version

2.12.x

StreamPark Version

2.1

Flink Version

1.16.0

deploy mode

None

What happened

When I use flink-doris-connector, there will be an exception that the label is already occupied. In this way, I must declare the parameter sink.label-prefix every time I use sql. If this parameter is not configured, the first execution will be successful. Then re-execute the task again and report an error

Error Exception

Caused by: org.apache.doris.flink.exception.DorisException: Load status is Label Already Exists and load job finished, change you label prefix or restore from latest savepoint!

Screenshots

Are you willing to submit PR?

• [ ] Yes I am willing to submit a PR!(您是否要贡献这个PR?)

Code of Conduct

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

[ai-smalleryu]

The test case is a normal insertion test The first run is successful when the parameter sink.label-prefix is ​​not carried, and the error is reported again after cancel，If you add parameters, you don't need to worry about this problem

CREATE TABLE flink_doris_sink (
    event_id STRING,
    guid INT,
    propJson STRING
    ) 
    WITH (
      'connector' = 'doris',
      'fenodes' = 'localhost:8030',
      'table.identifier' = 'gaotest.mall_app_events_detail1',
      'username' = 'root',
      'password' = 'root'
);