SMART2016

> @haoch > I'm getting exception with below sample control event json: > {"addedExecutionPlanMap": {"id14": "from inputStream [ticker == "AAPL"] insert into outputStream"}} > > Deserialized thru ControlEventSchema > >...

Have you tried using siddhi partitions in anyway... because siddhi has the concept of partitions and may be that can be applied here. https://siddhi.io/en/v5.1/docs/query-guide/#partition Or Flink based data partitioning which...