search

doubledutch / StroomData

Stroom Data is a simple and approachable framework for processing streams of data.
Apache License 2.0
8 stars 4 forks source link

Partitioned aggregate kills service if partition key missing #38

Closed nbclark closed 8 years ago

nbclark commented 8 years ago

2016-08-02 20:51:47,194 [Aggregate] INFO cards_manager restarting at 17 org.json.JSONException: JSONObject["UserID"] not found. at org.json.JSONObject.get(JSONObject.java:473) at me.doubledutch.stroom.Utility.pickValue(Utility.java:29) at me.doubledutch.stroom.aggregates.PartitionedAggregateService.getPartitionKey(PartitionedAggregateService.java:137) at me.doubledutch.stroom.aggregates.PartitionedAggregateService.run(PartitionedAggregateService.java:242) at java.lang.Thread.run(Thread.java:745)

kasperjj commented 8 years ago

Fixed, will be included in v0.1.7