aihai commented on pull request #7210:
URL: https://github.com/apache/incubator-doris/pull/7210#issuecomment-990707046
Thank you very much, it works. It is what I wanted.
Another question, how about the flink sink only supports `json` format?
The `Doris Sink` and `DorisDynamicOutputFormat` could be more unified and
not puzzled, eg:
`DataStream`
now
```
properties.setProperty("format", "json");
properties.setProperty("strip_outer_array", "true/false");
properties.setProperty("columns", "id, name, __DORIS_DELETE_SIGN__");
```
after
```
properties.setProperty("strip_outer_array", "true/false");
properties.setProperty("columns", "id, name, __DORIS_DELETE_SIGN__");
```
`Table(SQL)`
now
The table data is `Rowdata` and the doris-flink writes it to doris.
The `format` is defined or not, it is all ok. What is the different?
If all of that is ok , I am willing to finish it.
The `streamload` is very powerful, and the `setStreamLoadProp()` is also
very powerful :)
Thank you very much again.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
