Hi all, I am happy to announce that FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records [1] has been accepted. The FLIP was voted in this thread [2].
There are 3 binding votes and 1 non-binding vote: - Qingsheng Ren (binding) - Leonard Xu (binding) - Dong Lin (binding) - Hang Ruan (non-binding) There was no vote against it. Cheers, Dong [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-208 %3A+Add+RecordEvaluator+to+dynamically+stop+source+based+on+de-serialized+records [2] https://lists.apache.org/thread/p51bjoyssm2ccx8sfyvtoll8oym15sy9
