Feature Request: Support for Consuming Update Changes in Table Sink #142
Description
Currently, Flink throws a TableException when attempting to consume update changes from an aggregation operation in the query (like LISTAGG). The specific error occurs when trying to create a table with aggregated and grouped data.
This is the gist of the error:
Caused by: org.apache.flink.table.api.TableException: Table sink 'dwh.rapid.client_avoid_colors_sink' doesn't support consuming update changes which is produced by node GroupAggregate
Proposed Enhancement
Add functionality to the table API to be able to handle update inputs.