Hi, Belos is the use case.
Have a stream of transaction events, success/failure of a transaction can be determined by those events. Partitioning stream by transaction id and applying CEP to determine the success/failure of a transaction. Each transaction keyed stream is valid only until the final status is found. Which can end up having large inactive keyed streams in the system. Know that using keygroup flink distributes the keyedstream to tasks based on it, but still there will be a large set of inactive keys. Does this have any side effects? If so what has to be done to overcome humongous keyed streams? -- A.Narasimha Swamy
