wso2-extensions / siddhi-execution-env Goto Github PK

License: Apache License 2.0

siddhi-execution-env's Introduction

Siddhi Execution Extension - Env

The siddhi-execution-env extension is an extension to Siddhi that provides the capability to read environment properties inside Siddhi stream definitions and use it inside queries. Functions of the env extension are as follows..

Find some useful links below:

Latest API Docs

Latest API Docs is 2.0.0.

How to use

Using the extension in WSO2 Stream Processor

You can use this extension in the latest WSO2 Stream Processor that is a part of WSO2 Analytics offering, with editor, debugger and simulation support.
This extension is shipped by default with WSO2 Stream Processor, if you wish to use an alternative version of this extension you can replace the component jar that can be found in the <STREAM_PROCESSOR_HOME>/lib directory.

Using the extension as a java library

This extension can be added as a maven dependency along with other Siddhi dependencies to your project.

     <dependency>
        <groupId>org.wso2.extension.siddhi.execution.env</groupId>
        <artifactId>siddhi-execution-env</artifactId>
        <version>x.x.x</version>
     </dependency>

Jenkins Build Status

Branch	Build Status
master

Features

getEnvironmentProperty (Function)
This function returns the Java environment property that corresponds with the key provided
getOriginIPFromXForwarded (Function)
This function returns the public origin IP from the given X-Forwarded header.
getSystemProperty (Function)
This function returns the system property referred to via the system property key.
getUserAgentProperty (Function)
This function returns the value that corresponds with a specified property name of a specified user agent
getYAMLProperty (Function)
This function returns the YAML property requested or the default values specified if such avariable is not specified in the 'deployment.yaml'.
resourceIdentifier (Stream Processor)
The resource identifier stream processor is an extension to register a resource name with a reference in a static map and serve a static resources count for a specific resource name.
resourceBatch (Window)
This extension is a resource batch (tumbling) window that holds a number of events based on the resource count inferred from the 'env:resourceIdentifier' extension, and with a specific attribute as the grouping key. The window is updated each time a batch of events arrive with a matching value for the grouping key, and where the number of events is equal to the resource count.

How to Contribute

Please report issues at GitHub Issue Tracker.
Send your contributions as pull requests to master branch.

Contact us

Post your questions with the "Siddhi" tag in Stackoverflow.
Siddhi developers can be contacted via the mailing lists:

Developers List : [email protected]

Architecture List : [email protected]

Support

We are committed to ensuring support for this extension in production. Our unique approach ensures that all support leverages our open development methodology and is provided by the very same engineers who build the technology.
For more details and to take advantage of this unique opportunity contact us via http://wso2.com/support/.

siddhi-execution-env's People

Contributors

Watchers

siddhi-execution-env's Issues

Getting Concurrent Modification Exception

Description:
Can observer following error in wso2-obbi carbon logs.

ERROR {io.siddhi.core.stream.StreamJunction} - Error in 'PaymentValidationResultAnalyzer' after consuming events from Stream 'TRAResultStream', null. Hence, dropping event 'Event{timestamp=1600680042116, data=[24f7ef3c-4a49-4424-b6b4-a5f1e7de78a9, true, Reccurring Transactions, 6dfe2217-664f-49ca-b17d-f8e88b638aef, payment], isExpired=false}' java.util.ConcurrentModificationException at java.util.LinkedHashMap$LinkedHashIterator.nextNode(LinkedHashMap.java:719) at java.util.LinkedHashMap$LinkedEntryIterator.next(LinkedHashMap.java:752) at java.util.LinkedHashMap$LinkedEntryIterator.next(LinkedHashMap.java:750) at org.wso2.extension.siddhi.execution.env.ResourceBatchWindowProcessor.processEventChunk(ResourceBatchWindowProcessor.java:279) at org.wso2.extension.siddhi.execution.env.ResourceBatchWindowProcessor.processEventChunk(ResourceBatchWindowProcessor.java:59) at io.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:132) at io.siddhi.core.query.input.stream.single.EntryValveProcessor.process(EntryValveProcessor.java:51) at io.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:182) at io.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:89) at io.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:127) at io.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:199) at io.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:480) at io.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34) at io.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:45) at io.siddhi.core.stream.input.InputHandler.send(InputHandler.java:78) at io.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35) at io.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:83) at io.siddhi.core.stream.input.source.PassThroughSourceMapper.mapAndProcess(PassThroughSourceMapper.java:66) at io.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:175) at io.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:119) at io.siddhi.core.stream.input.source.InMemorySource$1.onMessage(InMemorySource.java:98) at io.siddhi.core.util.transport.InMemoryBroker$MessageBroker.broadcast(InMemoryBroker.java:110) at io.siddhi.core.util.transport.InMemoryBroker$MessageBroker.publish(InMemoryBroker.java:118) at io.siddhi.core.util.transport.InMemoryBroker.publish(InMemoryBroker.java:41) at io.siddhi.core.stream.output.sink.InMemorySink.publish(InMemorySink.java:109) at io.siddhi.core.stream.output.sink.Sink.publish(Sink.java:182) at io.siddhi.core.stream.output.sink.PassThroughSinkMapper.mapAndSend(PassThroughSinkMapper.java:74) at io.siddhi.core.stream.output.sink.SinkMapper.mapAndSend(SinkMapper.java:180) at io.siddhi.core.stream.output.sink.SinkCallback.receive(SinkCallback.java:55) at io.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:100) at io.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:176) at io.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:471) at io.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56) at io.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:104) at io.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:44) at io.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:97) at org.wso2.extension.siddhi.execution.env.ResourceIdentifierStreamProcessor.process(ResourceIdentifierStreamProcessor.java:113) at io.siddhi.core.query.processor.stream.StreamProcessor.processEventChunk(StreamProcessor.java:41) at io.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:132) at io.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:182) at io.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:89) at io.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:115) at io.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:176) at io.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:471) at io.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56) at io.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:104) at io.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:44) at io.siddhi.core.query.output.ratelimit.OutputRateLimiter.process(OutputRateLimiter.java:131) at io.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:118) at io.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:84) at io.siddhi.core.query.processor.stream.window.LengthWindowProcessor.process(LengthWindowProcessor.java:141) at io.siddhi.core.query.processor.stream.window.LengthWindowProcessor.process(LengthWindowProcessor.java:55) at io.siddhi.core.query.processor.stream.window.SlidingWindowProcessor.processEventChunk(SlidingWindowProcessor.java:74) at io.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:132) at io.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:87) at io.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:182) at io.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:89) at io.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:115) at io.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:176) at io.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:471) at io.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56) at io.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:104) at io.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:44) at io.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:97) at io.siddhi.core.query.processor.filter.FilterProcessor.process(FilterProcessor.java:58) at io.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:182) at io.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:89) at io.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:115) at io.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:176) at io.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:471) at io.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56) at io.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:104) at io.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:44) at io.siddhi.core.query.output.ratelimit.OutputRateLimiter.process(OutputRateLimiter.java:131) at io.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:118) at io.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:99) at io.siddhi.core.query.processor.stream.window.EmptyWindowProcessor.process(EmptyWindowProcessor.java:93) at io.siddhi.core.query.processor.stream.window.EmptyWindowProcessor.process(EmptyWindowProcessor.java:50) at io.siddhi.core.query.processor.stream.window.BatchingWindowProcessor.processEventChunk(BatchingWindowProcessor.java:79) at io.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:132) at io.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:87) at io.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:182) at io.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:89) at io.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:127) at io.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:199) at io.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:480) at io.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34) at io.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:45) at io.siddhi.core.stream.input.InputHandler.send(InputHandler.java:78) at io.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35) at io.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:83) at io.siddhi.core.stream.input.source.PassThroughSourceMapper.mapAndProcess(PassThroughSourceMapper.java:66) at io.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:175) at io.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:119) at io.siddhi.core.stream.input.source.InMemorySource$1.onMessage(InMemorySource.java:98) at io.siddhi.core.util.transport.InMemoryBroker$MessageBroker.broadcast(InMemoryBroker.java:110) at io.siddhi.core.util.transport.InMemoryBroker$MessageBroker.publish(InMemoryBroker.java:118) at io.siddhi.core.util.transport.InMemoryBroker.publish(InMemoryBroker.java:41) at io.siddhi.core.stream.output.sink.InMemorySink.publish(InMemorySink.java:109) at io.siddhi.core.stream.output.sink.Sink.publish(Sink.java:182) at io.siddhi.core.stream.output.sink.PassThroughSinkMapper.mapAndSend(PassThroughSinkMapper.java:74) at io.siddhi.core.stream.output.sink.SinkMapper.mapAndSend(SinkMapper.java:180) at io.siddhi.core.stream.output.sink.SinkCallback.receive(SinkCallback.java:55) at io.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:100) at io.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:176) at io.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:471) at io.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56) at io.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:104) at io.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:44) at io.siddhi.core.query.output.ratelimit.OutputRateLimiter.process(OutputRateLimiter.java:131) at io.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:118) at io.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:99) at io.siddhi.core.query.processor.stream.window.EmptyWindowProcessor.process(EmptyWindowProcessor.java:93) at io.siddhi.core.query.processor.stream.window.EmptyWindowProcessor.process(EmptyWindowProcessor.java:50) at io.siddhi.core.query.processor.stream.window.BatchingWindowProcessor.processEventChunk(BatchingWindowProcessor.java:79) at io.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:132) at io.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:87) at io.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:182) at io.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:89) at io.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:127) at io.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:199) at io.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:480) at io.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34) at io.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:45) at io.siddhi.core.stream.input.InputHandler.send(InputHandler.java:78) at io.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35) at io.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:83) at io.siddhi.extension.map.json.sourcemapper.JsonSourceMapper.mapAndProcess(JsonSourceMapper.java:234) at io.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:175) at io.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:119) at io.siddhi.extension.io.http.source.HttpSyncWorkerThread.run(HttpSyncWorkerThread.java:68) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)

Please find this similar issue which was resolved before.
#23

Getting java.util.ConcurrentModificationException when using the "resourcebatch-window" feature

Description:
I have used "resourcebatch-window" feature in "siddhi-execution-env" to hold set of events with similar grouping key. Following is the siddhi app written.

@App:name("PaymentValidationResultAnalyzer")
@App:description("Description of the plan")

@source(type = 'inMemory', topic = 'traPaymentResult', @map(type = 'passThrough'))
define stream TRAResultStream (MESSAGE_ID string, IS_VALID bool, VALIDATION_ID string, CONSENT_ID string, TYPE string);

@sink(type='http-response', source.id='source', message.id='{{MESSAGE_ID}}', @map(type='json'))
define stream OutputStream(MESSAGE_ID string, IS_VALID bool);

@info(name='sendResponse')
from TRAResultStream#window.env:resourceBatch("tra-payment-validator", MESSAGE_ID, 60000)
-- To get the or aggregation of all fraud rules using A or B = !(!A and !B)
select MESSAGE_ID, not(and(not IS_VALID)) as IS_VALID
insert into OutputStream;

I am getting an java.util.ConcurrentModificationException sometimes and the full stacktrace is below.

[2019-07-17 11:57:38,173] ERROR {org.wso2.siddhi.core.util.Scheduler} - java.util.ConcurrentModificationException
[2019-07-17 11:57:38,173] ERROR {org.wso2.siddhi.core.util.Scheduler} - java.util.ConcurrentModificationException
[2019-07-17 12:00:59,411]  INFO {org.wso2.extension.siddhi.io.mgwfile.task.MGWFileCleanUpTask} - Uploaded API Usage data in the db will be cleaned up to : 2019-07-12 12:00:59.411
[2019-07-17 12:01:57,689] ERROR {org.wso2.siddhi.core.stream.StreamJunction} - Error in 'PaymentValidationResultAnalyzer' after consuming events from Stream 'TRAResultStream', null. Hence, dropping event 'Event{timestamp=1563364917674, data=[6739d3e1-00f8-40d0-aa48-e33a2dcdb2cc, true, LowValueTransaction, 8eeb0bde-d3a8-4abd-926f-86ebd82f9321, payment], isExpired=false}' java.util.ConcurrentModificationException
	at java.util.LinkedHashMap$LinkedHashIterator.nextNode(LinkedHashMap.java:719)
	at java.util.LinkedHashMap$LinkedEntryIterator.next(LinkedHashMap.java:752)
	at java.util.LinkedHashMap$LinkedEntryIterator.next(LinkedHashMap.java:750)
	at org.wso2.extension.siddhi.execution.env.ResourceBatchWindowProcessor.process(ResourceBatchWindowProcessor.java:264)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.single.EntryValveProcessor.process(EntryValveProcessor.java:50)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:132)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:203)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:413)
	at org.wso2.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34)
	at org.wso2.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:44)
	at org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:73)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35)
	at org.wso2.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:80)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceMapper.mapAndProcess(PassThroughSourceMapper.java:66)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:144)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:114)
	at org.wso2.siddhi.core.stream.input.source.InMemorySource$1.onMessage(InMemorySource.java:66)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.broadcast(InMemoryBroker.java:110)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.publish(InMemoryBroker.java:118)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker.publish(InMemoryBroker.java:41)
	at org.wso2.siddhi.core.stream.output.sink.InMemorySink.publish(InMemorySink.java:96)
	at org.wso2.siddhi.core.stream.output.sink.Sink.publish(Sink.java:148)
	at org.wso2.siddhi.core.stream.output.sink.PassThroughSinkMapper.mapAndSend(PassThroughSinkMapper.java:74)
	at org.wso2.siddhi.core.stream.output.sink.SinkMapper.mapAndSend(SinkMapper.java:165)
	at org.wso2.siddhi.core.stream.output.sink.SinkCallback.receive(SinkCallback.java:54)
	at org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:100)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.extension.siddhi.execution.env.ResourceIdentifierStreamProcessor.process(ResourceIdentifierStreamProcessor.java:107)
	at org.wso2.siddhi.core.query.processor.stream.StreamProcessor.processEventChunk(StreamProcessor.java:47)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:121)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:117)
	at org.wso2.siddhi.core.query.processor.stream.window.LengthWindowProcessor.process(LengthWindowProcessor.java:137)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:123)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:121)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:117)
	at org.wso2.siddhi.core.query.processor.stream.window.LengthWindowProcessor.process(LengthWindowProcessor.java:137)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:123)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:121)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.processor.filter.FilterProcessor.process(FilterProcessor.java:65)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:132)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:203)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:413)
	at org.wso2.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34)
	at org.wso2.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:44)
	at org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:73)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35)
	at org.wso2.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:80)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceMapper.mapAndProcess(PassThroughSourceMapper.java:66)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:144)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:114)
	at org.wso2.siddhi.core.stream.input.source.InMemorySource$1.onMessage(InMemorySource.java:66)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.broadcast(InMemoryBroker.java:110)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.publish(InMemoryBroker.java:118)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker.publish(InMemoryBroker.java:41)
	at org.wso2.siddhi.core.stream.output.sink.InMemorySink.publish(InMemorySink.java:96)
	at org.wso2.siddhi.core.stream.output.sink.Sink.publish(Sink.java:148)
	at org.wso2.siddhi.core.stream.output.sink.PassThroughSinkMapper.mapAndSend(PassThroughSinkMapper.java:74)
	at org.wso2.siddhi.core.stream.output.sink.SinkMapper.mapAndSend(SinkMapper.java:165)
	at org.wso2.siddhi.core.stream.output.sink.SinkCallback.receive(SinkCallback.java:54)
	at org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:100)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:117)
	at org.wso2.siddhi.core.query.processor.stream.window.LengthWindowProcessor.process(LengthWindowProcessor.java:137)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:123)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:132)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:203)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:413)
	at org.wso2.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34)
	at org.wso2.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:44)
	at org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:73)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35)
	at org.wso2.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:80)
	at org.wso2.extension.siddhi.map.json.sourcemapper.JsonSourceMapper.mapAndProcess(JsonSourceMapper.java:233)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:144)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:114)
	at org.wso2.extension.siddhi.io.http.source.HttpSyncWorkerThread.run(HttpSyncWorkerThread.java:68)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

[2019-07-17 12:01:57,706] ERROR {org.wso2.siddhi.core.stream.StreamJunction} - Error in 'PaymentValidationResultAnalyzer' after consuming events from Stream 'TRAResultStream', null. Hence, dropping event 'Event{timestamp=1563364917674, data=[efefe515-a4ff-413b-9158-adb8e93cadcd, false, Reccurring Transactions, 1a7e281e-ba12-4db9-bc64-8af866bbba0c, payment], isExpired=false}' java.util.ConcurrentModificationException
	at java.util.LinkedHashMap$LinkedHashIterator.nextNode(LinkedHashMap.java:719)
	at java.util.LinkedHashMap$LinkedEntryIterator.next(LinkedHashMap.java:752)
	at java.util.LinkedHashMap$LinkedEntryIterator.next(LinkedHashMap.java:750)
	at org.wso2.extension.siddhi.execution.env.ResourceBatchWindowProcessor.process(ResourceBatchWindowProcessor.java:264)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.single.EntryValveProcessor.process(EntryValveProcessor.java:50)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:132)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:203)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:413)
	at org.wso2.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34)
	at org.wso2.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:44)
	at org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:73)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35)
	at org.wso2.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:80)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceMapper.mapAndProcess(PassThroughSourceMapper.java:66)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:144)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:114)
	at org.wso2.siddhi.core.stream.input.source.InMemorySource$1.onMessage(InMemorySource.java:66)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.broadcast(InMemoryBroker.java:110)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.publish(InMemoryBroker.java:118)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker.publish(InMemoryBroker.java:41)
	at org.wso2.siddhi.core.stream.output.sink.InMemorySink.publish(InMemorySink.java:96)
	at org.wso2.siddhi.core.stream.output.sink.Sink.publish(Sink.java:148)
	at org.wso2.siddhi.core.stream.output.sink.PassThroughSinkMapper.mapAndSend(PassThroughSinkMapper.java:74)
	at org.wso2.siddhi.core.stream.output.sink.SinkMapper.mapAndSend(SinkMapper.java:165)
	at org.wso2.siddhi.core.stream.output.sink.SinkCallback.receive(SinkCallback.java:54)
	at org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:100)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.extension.siddhi.execution.env.ResourceIdentifierStreamProcessor.process(ResourceIdentifierStreamProcessor.java:107)
	at org.wso2.siddhi.core.query.processor.stream.StreamProcessor.processEventChunk(StreamProcessor.java:47)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:121)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:117)
	at org.wso2.siddhi.core.query.processor.stream.window.TimeWindowProcessor.process(TimeWindowProcessor.java:167)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.single.EntryValveProcessor.process(EntryValveProcessor.java:50)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:121)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:117)
	at org.wso2.siddhi.core.query.processor.stream.window.LengthWindowProcessor.process(LengthWindowProcessor.java:137)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:123)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:121)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:132)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:203)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:413)
	at org.wso2.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34)
	at org.wso2.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:44)
	at org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:73)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35)
	at org.wso2.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:80)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceMapper.mapAndProcess(PassThroughSourceMapper.java:66)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:144)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:114)
	at org.wso2.siddhi.core.stream.input.source.InMemorySource$1.onMessage(InMemorySource.java:66)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.broadcast(InMemoryBroker.java:110)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.publish(InMemoryBroker.java:118)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker.publish(InMemoryBroker.java:41)
	at org.wso2.siddhi.core.stream.output.sink.InMemorySink.publish(InMemorySink.java:96)
	at org.wso2.siddhi.core.stream.output.sink.Sink.publish(Sink.java:148)
	at org.wso2.siddhi.core.stream.output.sink.PassThroughSinkMapper.mapAndSend(PassThroughSinkMapper.java:74)
	at org.wso2.siddhi.core.stream.output.sink.SinkMapper.mapAndSend(SinkMapper.java:165)
	at org.wso2.siddhi.core.stream.output.sink.SinkCallback.receive(SinkCallback.java:54)
	at org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:100)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:117)
	at org.wso2.siddhi.core.query.processor.stream.window.LengthWindowProcessor.process(LengthWindowProcessor.java:137)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:123)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:132)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:203)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:413)
	at org.wso2.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34)
	at org.wso2.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:44)
	at org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:73)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35)
	at org.wso2.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:80)
	at org.wso2.extension.siddhi.map.json.sourcemapper.JsonSourceMapper.mapAndProcess(JsonSourceMapper.java:233)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:144)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:114)
	at org.wso2.extension.siddhi.io.http.source.HttpSyncWorkerThread.run(HttpSyncWorkerThread.java:68)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

[2019-07-17 12:01:57,712] ERROR {org.wso2.siddhi.core.stream.StreamJunction} - Error in 'PaymentValidationResultAnalyzer' after consuming events from Stream 'TRAResultStream', null. Hence, dropping event 'Event{timestamp=1563364917674, data=[efefe515-a4ff-413b-9158-adb8e93cadcd, true, Reccurring Transactions, 1a7e281e-ba12-4db9-bc64-8af866bbba0c, payment], isExpired=false}' java.util.ConcurrentModificationException
	at java.util.LinkedHashMap$LinkedHashIterator.nextNode(LinkedHashMap.java:719)
	at java.util.LinkedHashMap$LinkedEntryIterator.next(LinkedHashMap.java:752)
	at java.util.LinkedHashMap$LinkedEntryIterator.next(LinkedHashMap.java:750)
	at org.wso2.extension.siddhi.execution.env.ResourceBatchWindowProcessor.process(ResourceBatchWindowProcessor.java:264)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.single.EntryValveProcessor.process(EntryValveProcessor.java:50)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:132)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:203)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:413)
	at org.wso2.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34)
	at org.wso2.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:44)
	at org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:73)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35)
	at org.wso2.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:80)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceMapper.mapAndProcess(PassThroughSourceMapper.java:66)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:144)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:114)
	at org.wso2.siddhi.core.stream.input.source.InMemorySource$1.onMessage(InMemorySource.java:66)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.broadcast(InMemoryBroker.java:110)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.publish(InMemoryBroker.java:118)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker.publish(InMemoryBroker.java:41)
	at org.wso2.siddhi.core.stream.output.sink.InMemorySink.publish(InMemorySink.java:96)
	at org.wso2.siddhi.core.stream.output.sink.Sink.publish(Sink.java:148)
	at org.wso2.siddhi.core.stream.output.sink.PassThroughSinkMapper.mapAndSend(PassThroughSinkMapper.java:74)
	at org.wso2.siddhi.core.stream.output.sink.SinkMapper.mapAndSend(SinkMapper.java:165)
	at org.wso2.siddhi.core.stream.output.sink.SinkCallback.receive(SinkCallback.java:54)
	at org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:100)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.extension.siddhi.execution.env.ResourceIdentifierStreamProcessor.process(ResourceIdentifierStreamProcessor.java:107)
	at org.wso2.siddhi.core.query.processor.stream.StreamProcessor.processEventChunk(StreamProcessor.java:47)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:121)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:117)
	at org.wso2.siddhi.core.query.processor.stream.window.TimeWindowProcessor.process(TimeWindowProcessor.java:167)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.single.EntryValveProcessor.process(EntryValveProcessor.java:50)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:121)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:117)
	at org.wso2.siddhi.core.query.processor.stream.window.LengthWindowProcessor.process(LengthWindowProcessor.java:137)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:123)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:121)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:132)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:203)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:413)
	at org.wso2.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34)
	at org.wso2.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:44)
	at org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:73)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35)
	at org.wso2.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:80)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceMapper.mapAndProcess(PassThroughSourceMapper.java:66)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:144)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:114)
	at org.wso2.siddhi.core.stream.input.source.InMemorySource$1.onMessage(InMemorySource.java:66)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.broadcast(InMemoryBroker.java:110)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.publish(InMemoryBroker.java:118)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker.publish(InMemoryBroker.java:41)
	at org.wso2.siddhi.core.stream.output.sink.InMemorySink.publish(InMemorySink.java:96)
	at org.wso2.siddhi.core.stream.output.sink.Sink.publish(Sink.java:148)
	at org.wso2.siddhi.core.stream.output.sink.PassThroughSinkMapper.mapAndSend(PassThroughSinkMapper.java:74)
	at org.wso2.siddhi.core.stream.output.sink.SinkMapper.mapAndSend(SinkMapper.java:165)
	at org.wso2.siddhi.core.stream.output.sink.SinkCallback.receive(SinkCallback.java:54)
	at org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:100)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:117)
	at org.wso2.siddhi.core.query.processor.stream.window.LengthWindowProcessor.process(LengthWindowProcessor.java:137)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:123)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:132)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:203)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:413)
	at org.wso2.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34)
	at org.wso2.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:44)
	at org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:73)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35)
	at org.wso2.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:80)
	at org.wso2.extension.siddhi.map.json.sourcemapper.JsonSourceMapper.mapAndProcess(JsonSourceMapper.java:233)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:144)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:114)
	at org.wso2.extension.siddhi.io.http.source.HttpSyncWorkerThread.run(HttpSyncWorkerThread.java:68)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

[2019-07-17 12:01:57,722] ERROR {org.wso2.siddhi.core.stream.StreamJunction} - Error in 'PaymentValidationResultAnalyzer' after consuming events from Stream 'TRAResultStream', null. Hence, dropping event 'Event{timestamp=1563364917674, data=[efefe515-a4ff-413b-9158-adb8e93cadcd, true, Reccurring Transactions, 1a7e281e-ba12-4db9-bc64-8af866bbba0c, payment], isExpired=false}' java.util.ConcurrentModificationException
	at java.util.LinkedHashMap$LinkedHashIterator.nextNode(LinkedHashMap.java:719)
	at java.util.LinkedHashMap$LinkedEntryIterator.next(LinkedHashMap.java:752)
	at java.util.LinkedHashMap$LinkedEntryIterator.next(LinkedHashMap.java:750)
	at org.wso2.extension.siddhi.execution.env.ResourceBatchWindowProcessor.process(ResourceBatchWindowProcessor.java:264)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.single.EntryValveProcessor.process(EntryValveProcessor.java:50)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:132)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:203)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:413)
	at org.wso2.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34)
	at org.wso2.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:44)
	at org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:73)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35)
	at org.wso2.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:80)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceMapper.mapAndProcess(PassThroughSourceMapper.java:66)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:144)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:114)
	at org.wso2.siddhi.core.stream.input.source.InMemorySource$1.onMessage(InMemorySource.java:66)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.broadcast(InMemoryBroker.java:110)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.publish(InMemoryBroker.java:118)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker.publish(InMemoryBroker.java:41)
	at org.wso2.siddhi.core.stream.output.sink.InMemorySink.publish(InMemorySink.java:96)
	at org.wso2.siddhi.core.stream.output.sink.Sink.publish(Sink.java:148)
	at org.wso2.siddhi.core.stream.output.sink.PassThroughSinkMapper.mapAndSend(PassThroughSinkMapper.java:74)
	at org.wso2.siddhi.core.stream.output.sink.SinkMapper.mapAndSend(SinkMapper.java:165)
	at org.wso2.siddhi.core.stream.output.sink.SinkCallback.receive(SinkCallback.java:54)
	at org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:100)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.extension.siddhi.execution.env.ResourceIdentifierStreamProcessor.process(ResourceIdentifierStreamProcessor.java:107)
	at org.wso2.siddhi.core.query.processor.stream.StreamProcessor.processEventChunk(StreamProcessor.java:47)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:121)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:117)
	at org.wso2.siddhi.core.query.processor.stream.window.TimeWindowProcessor.process(TimeWindowProcessor.java:167)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.single.EntryValveProcessor.process(EntryValveProcessor.java:50)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:121)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:117)
	at org.wso2.siddhi.core.query.processor.stream.window.LengthWindowProcessor.process(LengthWindowProcessor.java:137)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:123)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:121)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:132)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:203)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:413)
	at org.wso2.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34)
	at org.wso2.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:44)
	at org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:73)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35)
	at org.wso2.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:80)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceMapper.mapAndProcess(PassThroughSourceMapper.java:66)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:144)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:114)
	at org.wso2.siddhi.core.stream.input.source.InMemorySource$1.onMessage(InMemorySource.java:66)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.broadcast(InMemoryBroker.java:110)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker$MessageBroker.publish(InMemoryBroker.java:118)
	at org.wso2.siddhi.core.util.transport.InMemoryBroker.publish(InMemoryBroker.java:41)
	at org.wso2.siddhi.core.stream.output.sink.InMemorySink.publish(InMemorySink.java:96)
	at org.wso2.siddhi.core.stream.output.sink.Sink.publish(Sink.java:148)
	at org.wso2.siddhi.core.stream.output.sink.PassThroughSinkMapper.mapAndSend(PassThroughSinkMapper.java:74)
	at org.wso2.siddhi.core.stream.output.sink.SinkMapper.mapAndSend(SinkMapper.java:165)
	at org.wso2.siddhi.core.stream.output.sink.SinkCallback.receive(SinkCallback.java:54)
	at org.wso2.siddhi.core.stream.output.StreamCallback.receive(StreamCallback.java:100)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:180)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:404)
	at org.wso2.siddhi.core.query.output.callback.InsertIntoStreamCallback.send(InsertIntoStreamCallback.java:56)
	at org.wso2.siddhi.core.query.output.ratelimit.OutputRateLimiter.sendToCallBacks(OutputRateLimiter.java:96)
	at org.wso2.siddhi.core.query.output.ratelimit.PassThroughOutputRateLimiter.process(PassThroughOutputRateLimiter.java:46)
	at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:98)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:117)
	at org.wso2.siddhi.core.query.processor.stream.window.LengthWindowProcessor.process(LengthWindowProcessor.java:137)
	at org.wso2.siddhi.core.query.processor.stream.window.WindowProcessor.processEventChunk(WindowProcessor.java:65)
	at org.wso2.siddhi.core.query.processor.stream.AbstractStreamProcessor.process(AbstractStreamProcessor.java:123)
	at org.wso2.siddhi.core.query.input.stream.join.JoinProcessor.process(JoinProcessor.java:123)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.processAndClear(ProcessStreamReceiver.java:186)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.process(ProcessStreamReceiver.java:96)
	at org.wso2.siddhi.core.query.input.ProcessStreamReceiver.receive(ProcessStreamReceiver.java:132)
	at org.wso2.siddhi.core.stream.StreamJunction.sendEvent(StreamJunction.java:203)
	at org.wso2.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:413)
	at org.wso2.siddhi.core.stream.input.InputDistributor.send(InputDistributor.java:34)
	at org.wso2.siddhi.core.stream.input.InputEntryValve.send(InputEntryValve.java:44)
	at org.wso2.siddhi.core.stream.input.InputHandler.send(InputHandler.java:73)
	at org.wso2.siddhi.core.stream.input.source.PassThroughSourceHandler.sendEvent(PassThroughSourceHandler.java:35)
	at org.wso2.siddhi.core.stream.input.source.InputEventHandler.sendEvent(InputEventHandler.java:80)
	at org.wso2.extension.siddhi.map.json.sourcemapper.JsonSourceMapper.mapAndProcess(JsonSourceMapper.java:233)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:144)
	at org.wso2.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:114)
	at org.wso2.extension.siddhi.io.http.source.HttpSyncWorkerThread.run(HttpSyncWorkerThread.java:68)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

Recommend Projects

React

A declarative, efficient, and flexible JavaScript library for building user interfaces.
Vue.js

🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
Typescript

TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
TensorFlow

An Open Source Machine Learning Framework for Everyone
Django

The Web framework for perfectionists with deadlines.
Laravel

A PHP framework for web artisans
D3

Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

javascript

JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
web

Some thing interesting about web. New door for the world.
server

A server is a program made to process requests and deliver data to clients.
Machine learning

Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Visualization

Some thing interesting about visualization, use data art
Game

Some thing interesting about game, make everyone happy.

Recommend Org

Facebook

We are working to build community through open source technology. NB: members must have two-factor auth.
Microsoft

Open source projects and samples from Microsoft.
Google

Google ❤️ Open Source for everyone.
Alibaba

Alibaba Open Source for everyone
D3

Data-Driven Documents codes.
Tencent

China tencent open source team.