databendcloud / flink-connector-databend

Flink SQL connector for Databend.
Apache License 2.0
4 stars 1 forks source link

[bug] Can't handle `delete` when using MongoDB flink connector #14

Closed hantmac closed 11 months ago

hantmac commented 11 months ago

Because MongoDB using _id as primary key, it it String type and will get error in databend.

Now: DELETE from target_table where _id=xxxxx. Expected: DELETE from target_table where id='xxxxx'