You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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.
The text was updated successfully, but these errors were encountered:
Currently, Flink throws a
TableExceptionwhen 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 GroupAggregateProposed Enhancement
Add functionality to the table API to be able to handle update inputs.
The text was updated successfully, but these errors were encountered: