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

ArrayIndexOutOfBoundsException #63

Closed pavan91771 closed 4 years ago

pavan91771 commented 4 years ago

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:295) at org.apache.flink.streaming.siddhi.operator.AbstractSiddhiOperator.(AbstractSiddhiOperator.java:182) at org.apache.flink.streaming.siddhi.operator.SiddhiStreamOperator.(SiddhiStreamOperator.java:42) at org.apache.flink.streaming.siddhi.utils.SiddhiStreamFactory.createDataStream(SiddhiStreamFactory.java:36) at org.apache.flink.streaming.siddhi.SiddhiStream$ExecutionSiddhiStream.returnsInternal(SiddhiStream.java:431) at org.apache.flink.streaming.siddhi.SiddhiStream$ExecutionSiddhiStream.returnsInternal(SiddhiStream.java:417) at org.apache.flink.streaming.siddhi.SiddhiStream$ExecutionSiddhiStream.returnAsRow(SiddhiStream.java:366) at org.apache.flink.streaming.siddhi.SiddhiStream$ExecutionSiddhiStream.returnAsRow(SiddhiStream.java:355)

pavan91771 commented 4 years ago

I am taking the input from kafka

pavan91771 commented 4 years ago

done