search

apache / paimon

Apache Paimon is a lake format that enables building a Realtime Lakehouse Architecture with Flink and Spark for both streaming and batch operations.
https://paimon.apache.org/
Apache License 2.0
2.41k stars 946 forks source link

[Bug] Deletion fails in Flink SQL Client with an UnsupportedOperationException #1788

Closed Begunner closed 1 year ago

Begunner commented 1 year ago

Search before asking

Paimon version

Paimon 0.4.0-incubating

Compute Engine

flink-1.17.0

Minimal reproduce step

Following https://paimon.apache.org/docs/0.4/concepts/file-operations/

  1. Create the catalog and the table in Flink SQL Client and insert some lines into the table.
  2. Set runtime-mode to 'batch'.
  3. Try to delete some of the lines.

What doesn't meet your expectations?

Throwing an exception:

[ERROR] Could not execute SQL statement. Reason:
java.lang.UnsupportedOperationException: Can't perform delete operation of the table paimon.default.T because the corresponding dynamic table sink has not yet implemented org.apache.flink.table.connector.sink.abilities.SupportsRowLevelDelete.

Anything else?

No response

Are you willing to submit a PR?

yuzelin commented 1 year ago

Hi, this is because DELETE/UPDATE syntax is supported in Paimon-0.5 (current master). Please use 0.5 snapshot jar to do the test.