Relative Content

Tag Archive for hadoopapache-flinkflink-streamingapache-iceberg

Flink upsert iceberg row by highest version

I have a flink application that has kafka source and iceberg table sink (on hadoop).
It looks something like: