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

Bug: ArrayOutofBoundsException thrown when using a Siddhi event stream of type DataStream<Map<String,Object>>> #33

Open aagupta1 opened 5 years ago

aagupta1 commented 5 years ago

Stack trace -

Exception in thread "main" java.lang.ArrayIndexOutOfBoundsException: 1 at org.apache.flink.streaming.siddhi.schema.SiddhiStreamSchema.getStreamDefinition(SiddhiStreamSchema.java:49) at org.apache.flink.streaming.siddhi.schema.SiddhiStreamSchema.getStreamDefinitionExpression(SiddhiStreamSchema.java:64) at org.apache.flink.streaming.siddhi.operator.SiddhiOperatorContext.getAllEnrichedExecutionPlan(SiddhiOperatorContext.java:113) at org.apache.flink.streaming.siddhi.operator.AbstractSiddhiOperator.validate(AbstractSiddhiOperator.java:291) at org.apache.flink.streaming.siddhi.operator.AbstractSiddhiOperator.(AbstractSiddhiOperator.java:178) at org.apache.flink.streaming.siddhi.operator.SiddhiStreamOperator.(SiddhiStreamOperator.java:41) at org.apache.flink.streaming.siddhi.utils.SiddhiStreamFactory.createDataStream(SiddhiStreamFactory.java:31) at org.apache.flink.streaming.siddhi.SiddhiStream$ExecutionSiddhiStream.returnsInternal(SiddhiStream.java:331) at org.apache.flink.streaming.siddhi.SiddhiStream$ExecutionSiddhiStream.returnsInternal(SiddhiStream.java:327) at org.apache.flink.streaming.siddhi.SiddhiStream$ExecutionSiddhiStream.returnAsMap(SiddhiStream.java:287)

haoch commented 5 years ago

@aagupta1 Could you please share the test code?