Error when using function "json:toObject()" parallel in two siddhi applications.

[Methma]

Description:

The Following issue can be observed when the same function is used by the two Siddhi applications parallel.

ERROR {io.siddhi.core.stream.StreamJunction} - Error in 'chunkAPP' after consuming events from Stream 'SweetProductionStream', null. Exception on class 'io.siddhi.extension.execution.json.function.ToJSONObjectFunctionExtension'. Hence, dropping event 'StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=StateEvent{streamEvents=[null, null], timestamp=-1, type=CURRENT, outputData=[["Asia","Asia Pacific"], ["CO2","Refined products","Petroleum","Middle distillates","Diesel fuel"], a], next=null}}}}}}}}}}}}}}}}}}' io.siddhi.core.exception.SiddhiAppRuntimeException: null. Exception on class 'io.siddhi.extension.execution.json.function.ToJSONObjectFunctionExtension' at io.siddhi.core.executor.function.FunctionExecutor.execute(FunctionExecutor.java:105) at io.siddhi.core.query.selector.attribute.processor.AttributeProcessor.process(AttributeProcessor.java:41) at io.siddhi.core.query.selector.QuerySelector.processNoGroupBy(QuerySelector.java:172) at io.siddhi.core.query.selector.QuerySelector.process(QuerySelector.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:179) at io.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:496) 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:98) 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:86) 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:202) at io.siddhi.core.stream.StreamJunction$Publisher.send(StreamJunction.java:505) 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:82) at io.siddhi.extension.map.json.sourcemapper.JsonSourceMapper.mapAndProcess(JsonSourceMapper.java:255) at io.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:200) at io.siddhi.core.stream.input.source.SourceMapper.onEvent(SourceMapper.java:144) at io.siddhi.extension.io.http.source.HttpWorkerThread.run(HttpWorkerThread.java:62) 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)Caused by: java.lang.NullPointerException at io.siddhi.extension.execution.json.function.ToJSONObjectFunctionExtension.execute(ToJSONObjectFunctionExtension.java:131) at io.siddhi.core.executor.function.FunctionExecutor.execute(FunctionExecutor.java:93) ... 36 more

It was observed this was happening due to the static object "jsonParser"[1]. After making this object non-static this issue was not observed.

[1].

siddhi-execution-json/component/src/main/java/io/siddhi/extension/execution/json/function/ToJSONObjectFunctionExtension.java

Line 67 in 8f085d5

private static final JSONParser jsonParser = new JSONParser(JSONParser.DEFAULT_PERMISSIVE_MODE);

Affected Product Version:
WSO2 SI 1.1.0