Production-readyness of Flink SQL

2018-03-12 Thread Philip Limbeck
Hi! I am quite sure this was asked before. But why is Flink SQL is declared to be in in Beta as given by the header in https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/table/ ? Are there specific functions in SQL which are not production ready or is it meant for the whole Flink SQL

Flink CEP State Change Pattern

2017-10-14 Thread Philip Limbeck
Hi! I am quite new to Flink CEP and try to define a state change pattern with it. This means that only discrete changes in the event stream should be detected i.e. a a b b - triggers a single change from a to b Considering b the "bad" state, I would like to additionally recognize the state chang