Skip to content

[Bug] [connector-doris] 包含%的数据导入报错 #4242

@feng-kui

Description

@feng-kui

Search before asking

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

What happened

varchar类型字段的值中,包含%,stream load导入报错(但老版本2.1.3没有问题),如下:

{"timestamp":"2023-03-01T02:44:08.106+00:00","status":500,"error":"Internal Server Error","path":"/api/example_db/table20/_stream_load"}

SeaTunnel Version

2.3.0

SeaTunnel Config

source {
  Hive {
    table_name = "dw.test"
    metastore_uri = "thrift://x.x.x.x:9083"
    result_table_name = "tmp_table"
  }

}

transform {

  sql {
    sql = "select '1' id,'a%' name from tmp_table"
  }
}

sink {
  Doris {
    nodeUrls=["header-01:8031"]
    database="test"
    table="test"
    username="root"
    password="123"
    batch_max_rows=1000
    max_retries=0
    labelPrefix="fix_test_"
    sink.properties.format="JSON"
    sink.properties.strip_outer_array = "true"
}
}


### Running Command

```shell
start-seatunnel-spark-connector-v2.sh -m yarn -e client -c test.conf

Error Exception

{"timestamp":"2023-03-01T02:44:08.106+00:00","status":500,"error":"Internal Server Error","path":"/api/example_db/test/_stream_load"}


### 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

- [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions