-
Notifications
You must be signed in to change notification settings - Fork 2.2k
Closed
Description
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)