search

haoch / flink-siddhi

A CEP library to run Siddhi within Apache Flink™ Streaming Application (Not maintained)
Apache License 2.0
243 stars 96 forks source link

Sample json of the ControlEvent #68

Open ccbeloy opened 4 years ago

ccbeloy commented 4 years ago

Hi,

Can someone provide the sample ControlEvent json that can be push to like Kafka topic please? I'm not able to make sense the MetadataControlEvent.builder.

Thanks, Calvin

ccbeloy commented 4 years ago

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

Deserialized thru ControlEventSchema

ERROR: org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonMappingException: No suitable constructor found for type [simple type, class org.apache.flink.streaming.siddhi.control.ControlMessage]: can not instantiate from JSON object (missing default constructor or creator, or perhaps need to add/enable type information?

SMART2016 commented 3 years ago

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

Deserialized thru ControlEventSchema

ERROR: org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonMappingException: No suitable constructor found for type [simple type, class org.apache.flink.streaming.siddhi.control.ControlMessage]: can not instantiate from JSON object (missing default constructor or creator, or perhaps need to add/enable type information?

Any breakthrough on this ... I am also not clear on the control stream input message ...