flink-cdc
flink-cdc copied to clipboard
[FLINK-35090][cdc][doris] Add database auto-creating support for Doris sink pipeline connector
Currently, Doris sink supports auto-creating table only. When specified database does not exist, connector will panic with a Doris internal error. By ensuring database exists before creating any table should fix this problem.
@lvyanquan PTAL
LGTM.
Thanks for @lvyanquan's review, rebased to latest master branch. cc @PatrickRen
Closing this for now since it has been implemented in https://github.com/apache/doris-flink-connector/pull/408.