Hi Gyula, Could you provide the code of your Flink program, the error with stacktrace and the Flink version?
Thanks., Roman On Thu, Mar 5, 2020 at 2:17 PM Gyula Fóra <gyula.f...@gmail.com> wrote: > Hi All! > > Excuse my stupid question, I am pretty new to the Table/SQL API and I am > trying to play around with it implementing and running a few use-cases. > > I have a simple window join + aggregation, grouped on some id that I want > to write to Kafka but I am hitting the following error: > > "AppendStreamTableSink requires that Table has only insert changes." > > If I understand correctly the problem here is that since updates are > possible within a single group, we have a retract stream and the Kafka Sink > cannot handle that. I tried to search for the solution but I haven't found > any satisfying answers. > > How can I simply tell the INSERT logic to ignore previous values and just > always keep sending the latest (like you would see it on the CLI output). > > Thank you! > Gyula >
