Re: [Discuss] Retraction for Flink Streaming

2017-03-16 Thread Shaoxuan Wang
The doc gets lots of attention. I appreciate everyone for the valuable comments. Hi Fabian, Thanks for your comments. I agree with you that we should ensure that all operators are running in the same mode (either turning on retraction globally or not). From my point of view, I did not see any pro

Re: [Discuss] Retraction for Flink Streaming

2017-03-15 Thread Fabian Hueske
Hi Shaoxuan, thanks a lot for this proposal! Support for retractions is a super nice and important feature and will enable many more use cases for the Table API / SQL. I'm really excited to see this happening. I made a first pass over your proposal and added a few comments. I'll do another pass so

[Discuss] Retraction for Flink Streaming

2017-03-14 Thread Shaoxuan Wang
Hello everyone, Flink is widely used in Alibaba Group, especially in our Search and Recommendation Infra. Retraction is one of the most important features that we needed. We have spent lots of efforts to try to solve this problem, and gladly at the end we develop an approach which can address most