[rules-users] NPE in Drools JPA Persistence with rules that use Flow
Mauricio Salatino
salaboy at gmail.com
Thu May 26 11:40:11 EDT 2011
Are you using the JPAKnowledgeService?
2011/5/26 Shannon Hastings <shannon.hastings at inventrio.com>
> It is actually null. I dont pass any config in when constructing the
> session.
>
>
> On May 26, 2011, at 11:13 AM, Mauricio Salatino wrote:
>
> Can you share the ksession configuration?
>
>
> 2011/5/26 Shannon Hastings <shannon.hastings at inventrio.com>
>
>> My session is persistent, i can query the sessioninfo in the DB and see
>> the data. My beans are searializable and I can see that the fact has been
>> deserialized.
>>
>>
>> On May 26, 2011, at 11:05 AM, Mauricio Salatino wrote:
>>
>> Ok, assuming that your session is persistent, are your POJOs
>> serializables?
>> Cheers
>>
>> 2011/5/26 Shannon Hastings <shannon.hastings at inventrio.com>
>>
>>> Nope, no change, i am pulling the same drl from guvnor every time. It
>>> only has three rules as show below in the thread. I can restore the session
>>> without error so long as the session does not have any facts in it. Once I
>>> drop a fact in and store, then i cannot restore.
>>>
>>>
>>> On May 26, 2011, at 10:55 AM, Mauricio Salatino wrote:
>>>
>>> Ok, so did you check that you didn't change anything from the moment you
>>> store the ksession and the moment when you restore it?
>>> I usually find this problem when you change a rule and try to restore the
>>> session using the new version of the rule or when you change a business
>>> process definition or the session state from different threads. Can you
>>> check that please?
>>> You will find this unmarshalling problems and it will be very difficult
>>> to debug at that level, when the problem is being caused by some
>>> modification on your code. Greetings
>>>
>>> 2011/5/26 Shannon Hastings <shannon.hastings at inventrio.com>
>>>
>>>> I have debugged into this and found this issue. The NPE comes when the
>>>> session unmarsheller runs into a node that does not have a sink or the sink
>>>> is null. In the debugger i can see the fact and the fact looks right, has
>>>> all the data from the pojo i sent in. However, it does not have a sink, but
>>>> it does have a node id. This looks like a bug that was reportedly fixed
>>>> before in 5.1. I dont know enough about the storing of the facts in the
>>>> working memory or the model that is being used under the hood, however, all
>>>> i have to do to create the problem is create a session, send an object to
>>>> it, and then try to restore it. And the objects i am sending to it are
>>>> simple pojo's and in the debugger I can see that it was able to read them
>>>> back out just fine. Below is an exerpt from the "InputMarshaller" class.
>>>> In the debugger The readlefttuples operation shows the nodeId = 12 and the
>>>> sink = null and the facthandleId = 1. he it calls readLeftTuple() and the
>>>> obvious NPE will be thrown because the ParentLeftTuple has a null sink and
>>>> when you call "sink.getType()" you get the NPE. Is this a known bug.
>>>>
>>>> public static void readLeftTuples(MarshallerReaderContext context)
>>>> throws IOException,
>>>>
>>>> ClassNotFoundException {
>>>> ObjectInputStream stream = context.stream;
>>>>
>>>> while ( stream.readShort() == PersisterEnums.LEFT_TUPLE ) {
>>>> int nodeId = stream.readInt();
>>>> LeftTupleSink sink = (LeftTupleSink) context.sinks.get(
>>>> nodeId );
>>>> int factHandleId = stream.readInt();
>>>> LeftTuple leftTuple = new LeftTuple( context.handles.get(
>>>> factHandleId ),
>>>> sink,
>>>> true );
>>>> readLeftTuple( leftTuple,
>>>> context );
>>>> }
>>>> }
>>>>
>>>> public static void readLeftTuple(LeftTuple parentLeftTuple,
>>>> MarshallerReaderContext context)
>>>> throws IOException,
>>>>
>>>> ClassNotFoundException {
>>>> ObjectInputStream stream = context.stream;
>>>> Map<Integer, BaseNode> sinks = context.sinks;
>>>>
>>>> LeftTupleSink sink = parentLeftTuple.getLeftTupleSink();
>>>>
>>>> switch ( sink.getType() ) {
>>>>
>>>>
>>>> On May 24, 2011, at 9:06 AM, Edson Tirelli wrote:
>>>>
>>>>
>>>> Shannon,
>>>>
>>>> What is the following method doing?
>>>>
>>>> engine.process(reading);
>>>>
>>>> Can you please open a JIRA and attach your test case or point me to
>>>> the jira reporting this problem if it exists already?
>>>>
>>>> Thanks,
>>>> Edson
>>>>
>>>>
>>>> 2011/5/23 Shannon Hastings <shannon.hastings at inventrio.com>
>>>>
>>>>> I am using drools 5.2.0.M2 and I still get this error:
>>>>>
>>>>> Caused by: java.lang.NullPointerException
>>>>> at
>>>>> org.drools.marshalling.impl.InputMarshaller.readLeftTuple(InputMarshaller.java:469)
>>>>>
>>>>> Which was reported on drools 5.1.0 JIRA and claimed to be fixed. I see
>>>>> the error when trying to load a session that was persisted that had objects
>>>>> inserted that are time depended and cause rules to fire that use terms from
>>>>> flow such as "after". I only see this error if create a new session, submit
>>>>> some facts to it, close it, and then try to reload. If i do not submit any
>>>>> facts to it I do not get the error. I.E. If all i do is create the KB with
>>>>> my rules I can reload a session from the DB no problem, but if i submit some
>>>>> facts and persist the session, then i cannot reload it. This seems to be an
>>>>> issue with the JPA loading of the session that has facts in it that use Flow
>>>>> (JBPM). Any help would be greatly appreciated. Below are my simple rules
>>>>> followed by the test code used to submit the facts:
>>>>>
>>>>> package com.inventrio.rules.readings
>>>>>
>>>>> import com.inventrio.healthmonitoring.model.*;
>>>>>
>>>>> declare Reading
>>>>> @role(event)
>>>>> @timestamp(readingTime)
>>>>> end
>>>>>
>>>>> rule "High Blood Pressure"
>>>>> when
>>>>> $eventA : Reading(readingType.name == "BPMETER")
>>>>> $systolic : Value( this.valueType.name == "SYSTOLIC" ) from$eventA.values
>>>>> $diastolic : Value( this.valueType.name == "DIASTOLIC" ) from$eventA.values
>>>>> eval( $systolic.getLongValue() > 180 && $diastolic.getLongValue() >
>>>>> 120 )
>>>>> then
>>>>> System.out.println("HIGH BLOOD PRESSURE" );
>>>>> end
>>>>>
>>>>> rule "Weight Trending Up"
>>>>> when
>>>>> $eventC : Reading(readingType.name == "WEIGHT" )
>>>>> $eventB : Reading( readingType.name == "WEIGHT" , this after[5s, 1m]
>>>>> $eventC )
>>>>> $eventA : Reading( readingType.name == "WEIGHT" , this after[5s, 1m]
>>>>> $eventB )
>>>>> $weight3 : Value( this.valueType.name == "WEIGHT" ) from$eventC.values
>>>>> $weight2 : Value( this.valueType.name == "WEIGHT" ) from$eventB.values
>>>>> $weight1 : Value( this.valueType.name == "WEIGHT" ) from$eventA.values
>>>>> eval( $weight3.getDoubleValue().doubleValue() <
>>>>> $weight2.getDoubleValue().doubleValue() + 1.0 &&
>>>>> $weight2.getDoubleValue().doubleValue() <
>>>>> $weight1.getDoubleValue().doubleValue() + 1.0 )
>>>>> then
>>>>> System.out.println("WEIGHT IS GOING UP" );
>>>>> end
>>>>>
>>>>> rule "Weight Trending Down"
>>>>> when
>>>>> $eventC : Reading(readingType.name == "WEIGHT" )
>>>>> $eventB : Reading( readingType.name == "WEIGHT" , this after[5s, 1m]
>>>>> $eventC )
>>>>> $eventA : Reading( readingType.name == "WEIGHT" , this after[5s, 1m]
>>>>> $eventB )
>>>>> $weight3 : Value( this.valueType.name == "WEIGHT" ) from$eventC.values
>>>>> $weight2 : Value( this.valueType.name == "WEIGHT" ) from$eventB.values
>>>>> $weight1 : Value( this.valueType.name == "WEIGHT" ) from$eventA.values
>>>>> eval( $weight3.getDoubleValue().doubleValue() >
>>>>> $weight2.getDoubleValue().doubleValue() + 1.0 &&
>>>>> $weight2.getDoubleValue().doubleValue() >
>>>>> $weight1.getDoubleValue().doubleValue() + 1.0 )
>>>>> then
>>>>> System.out.println("WEIGHT IS GOING DOWN" );
>>>>> end
>>>>>
>>>>>
>>>>>
>>>>> And next is my object i insert before closeing and then trying to
>>>>> reload the session.
>>>>>
>>>>> public void testWeightRules() {
>>>>> try {
>>>>>
>>>>> Reading reading = new Reading();
>>>>> reading.setReadingTime(new Date(System.currentTimeMillis()));
>>>>> ReadingType type = new ReadingType();
>>>>> type.setName("WEIGHT");
>>>>> type.setDescription("");
>>>>> reading.setReadingType(type);
>>>>> Value value = new Value();
>>>>> value.setDoubleValue(140.0);
>>>>> ValueType valueType = new ValueType();
>>>>> valueType.setName("WEIGHT");
>>>>> valueType.setDataType(ValueDataType.DOUBLE);
>>>>> value.setValueType(valueType);
>>>>> reading.getValues().add(value);
>>>>> reading.setReadingType(type);
>>>>> engine.process(reading);
>>>>>
>>>>> Thread.sleep(7000);
>>>>>
>>>>> reading = new Reading();
>>>>> reading.setReadingTime(new Date(System.currentTimeMillis()));
>>>>> type = new ReadingType();
>>>>> type.setName("WEIGHT");
>>>>> type.setDescription("");
>>>>> reading.setReadingType(type);
>>>>> value = new Value();
>>>>> value.setDoubleValue(142.0);
>>>>> valueType = new ValueType();
>>>>> valueType.setName("WEIGHT");
>>>>> valueType.setDataType(ValueDataType.DOUBLE);
>>>>> value.setValueType(valueType);
>>>>> reading.getValues().add(value);
>>>>> reading.setReadingType(type);
>>>>> engine.process(reading);
>>>>>
>>>>> Thread.sleep(7000);
>>>>>
>>>>> reading = new Reading();
>>>>> reading.setReadingTime(new Date(System.currentTimeMillis()));
>>>>> type = new ReadingType();
>>>>> type.setName("WEIGHT");
>>>>> type.setDescription("");
>>>>> reading.setReadingType(type);
>>>>> value = new Value();
>>>>> value.setDoubleValue(144.0);
>>>>> valueType = new ValueType();
>>>>> valueType.setName("WEIGHT");
>>>>> valueType.setDataType(ValueDataType.DOUBLE);
>>>>> value.setValueType(valueType);
>>>>> reading.getValues().add(value);
>>>>> reading.setReadingType(type);
>>>>> engine.process(reading);
>>>>>
>>>>> } catch (Throwable t) {
>>>>> t.printStackTrace();
>>>>> }
>>>>> }
>>>>>
>>>>> Shannon Hastings
>>>>>
>>>>> Inventrio
>>>>> 545 Metro Place South, Suite 475
>>>>> Dublin, OH 43017
>>>>> *Phone*: (614) 389-2795 x101
>>>>> *Fax:* (614) 522-6249
>>>>> *Email:* shannon.hastings at inventrio.com
>>>>> http://www.inventrio.com
>>>>>
>>>>>
>>>>> _______________________________________________
>>>>> rules-users mailing list
>>>>> rules-users at lists.jboss.org
>>>>> https://lists.jboss.org/mailman/listinfo/rules-users
>>>>>
>>>>>
>>>>
>>>>
>>>> --
>>>> Edson Tirelli
>>>> JBoss Drools Core Development
>>>> JBoss by Red Hat @ www.jboss.com
>>>> _______________________________________________
>>>> rules-users mailing list
>>>> rules-users at lists.jboss.org
>>>> https://lists.jboss.org/mailman/listinfo/rules-users
>>>>
>>>>
>>>> Shannon Hastings
>>>>
>>>> Inventrio
>>>> 545 Metro Place South, Suite 475
>>>> Dublin, OH 43017
>>>> *Phone*: (614) 389-2795 x101
>>>> *Fax:* (614) 522-6249
>>>> *Email:* shannon.hastings at inventrio.com
>>>> http://www.inventrio.com
>>>>
>>>>
>>>> _______________________________________________
>>>> rules-users mailing list
>>>> rules-users at lists.jboss.org
>>>> https://lists.jboss.org/mailman/listinfo/rules-users
>>>>
>>>>
>>>
>>>
>>> --
>>> - CTO @ http://www.plugtree.com
>>> - MyJourney @ http://salaboy.wordpress.com
>>> - Co-Founder @ http://www.jbug.com.ar
>>>
>>> - Salatino "Salaboy" Mauricio -
>>> _______________________________________________
>>> rules-users mailing list
>>> rules-users at lists.jboss.org
>>> https://lists.jboss.org/mailman/listinfo/rules-users
>>>
>>>
>>> Shannon Hastings
>>>
>>> Inventrio
>>> 545 Metro Place South, Suite 475
>>> Dublin, OH 43017
>>> *Phone*: (614) 389-2795 x101
>>> *Fax:* (614) 522-6249
>>> *Email:* shannon.hastings at inventrio.com
>>> http://www.inventrio.com
>>>
>>>
>>> _______________________________________________
>>> rules-users mailing list
>>> rules-users at lists.jboss.org
>>> https://lists.jboss.org/mailman/listinfo/rules-users
>>>
>>>
>>
>>
>> --
>> - CTO @ http://www.plugtree.com
>> - MyJourney @ http://salaboy.wordpress.com
>> - Co-Founder @ http://www.jbug.com.ar
>>
>> - Salatino "Salaboy" Mauricio -
>> _______________________________________________
>> rules-users mailing list
>> rules-users at lists.jboss.org
>> https://lists.jboss.org/mailman/listinfo/rules-users
>>
>>
>> Shannon Hastings
>>
>> Inventrio
>> 545 Metro Place South, Suite 475
>> Dublin, OH 43017
>> *Phone*: (614) 389-2795 x101
>> *Fax:* (614) 522-6249
>> *Email:* shannon.hastings at inventrio.com
>> http://www.inventrio.com
>>
>>
>> _______________________________________________
>> rules-users mailing list
>> rules-users at lists.jboss.org
>> https://lists.jboss.org/mailman/listinfo/rules-users
>>
>>
>
>
> --
> - CTO @ http://www.plugtree.com
> - MyJourney @ http://salaboy.wordpress.com
> - Co-Founder @ http://www.jbug.com.ar
>
> - Salatino "Salaboy" Mauricio -
> _______________________________________________
> rules-users mailing list
> rules-users at lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/rules-users
>
>
> Shannon Hastings
>
> Inventrio
> 545 Metro Place South, Suite 475
> Dublin, OH 43017
> *Phone*: (614) 389-2795 x101
> *Fax:* (614) 522-6249
> *Email:* shannon.hastings at inventrio.com
> http://www.inventrio.com
>
>
> _______________________________________________
> rules-users mailing list
> rules-users at lists.jboss.org
> https://lists.jboss.org/mailman/listinfo/rules-users
>
>
--
- CTO @ http://www.plugtree.com
- MyJourney @ http://salaboy.wordpress.com
- Co-Founder @ http://www.jbug.com.ar
- Salatino "Salaboy" Mauricio -
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.jboss.org/pipermail/rules-users/attachments/20110526/91fd4939/attachment.html
More information about the rules-users
mailing list