flink-http-connector icon indicating copy to clipboard operation
flink-http-connector copied to clipboard

Published 20 hours ago • verified publisher icon getindata

Feature Request: Support for Consuming Update Changes in Table Sink

Open nchen07 opened this issue 10 months ago • 2 comments

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.

nchen07 avatar Jan 23 '25 08:01 nchen07