Re: Ingesting a table from a retraction stream !!

Hi Hequn Actually we are building a offer management system or real time contextual marketing platform. I am creating a poc as of now over initial design is some thing like this. e.g --- 1) 2 Sources are registered as as Streaming Table Source. a) Assume *A *with Table Name --*TestA *(a

Re: Ingesting a table from a retraction stream !!

Hi Puneet, OK, thanks for your information. *"a) Assume agg1 run on table TestA ;"* If there is only one group by between source and sink, you can ingest the output agg result with append mode then followed with a group by to translate it into update mode(group by uid and do LAST_VALUE agg). If

Flink Yarn session

I've set up a Hadoop HA cluster and I want to run Flink applications on YARN. The elaborated problem is in StackOverflow: Here is the question Please help!