Aarti Gupta

Dynamically creating Siddhi Streams

1

Hi Haoch, We are using Flink and Siddhi to build an alerting framework for the security domain. One thing that we'd like to be able to do is create ad-hoc...

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

1

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)

Support Siddhi QueryCallback

9

Hi @haoch, Siddhi supports both StreamCallback and QueryCallback. The flink-siddhi library only has support for StreamCallback as far as I can tell. I'd like to be able to register a...

Returning Query Id in Output

1

When multiple QueryHandlers sharing the same Output Stream are registered with Siddhi, is there a way to tell which Query triggered the output results ? Based on the query that...

OperationControlEvent enableQuery disables the query instead of enabling it.

3

From OperationControlEvent.java public static OperationControlEvent enableQuery(String queryId) { return new OperationControlEvent(Action.DISABLE_QUERY, queryId); } public static OperationControlEvent disableQuery(String queryId) { return new OperationControlEvent(Action.ENABLE_QUERY, queryId); }