NPE running indexer with HIVE on testdfc2

[michael-conway]

Add AVU to collection in testdfc2 using hive

(Thread.java:745)[:1.7.0_65]
10:56:16,176 | INFO  | sumer[metaQueue] | IndexerWrapper                   | 193 - org.irods.jargon.hive-metadata-indexer - 1.0.0.SNAPSHOT | messages:databook.persistence.rule.rdf.ruleset.Messages@3d6f2002[messages=[databook.persistence.rule.rdf.ruleset.Message@4a9e82d0[operation=union,hasPart=[databook.persistence.rule.rdf.ruleset.Collection@6c9e4bf5[additionalProperties={},id=<null>,type=<null>,description=<null>,title=<null>,created=<null>,submitted=<null>,related=[],hasPart=[],partOf=[],accessHistory=<null>,accessPermission=[],metadata=[],discussion=[],owner=<null>,contributor=[],likedBy=[],dislikedBy=[],tempInputStream=<null>,storageLocationRequest=[],storageLocation=[],additionalProperties={},uri=/dfc2/home/test1/test-hive2@1407962421,typeUri=<null>,label=<null>,additionalProperties={}], databook.persistence.rule.rdf.ruleset.Collection@c8cf989[additionalProperties={partOfUri=[], metadataObject=[{unit=iRODSUserTagging:HIVE:VocabularyTerm, value=vocabulary=mesh|preferredLabel=Archaea|comment=, attribute=http://www.nlm.nih.gov/mesh/D001105#concept}]},id=<null>,type=databook.persistence.rule.rdf.ruleset.Collection,description=<null>,title=<null>,created=<null>,submitted=<null>,related=[],hasPart=[],partOf=<null>,accessHistory=<null>,accessPermission=[],metadata=<null>,discussion=[],owner=<null>,contributor=[],likedBy=[],dislikedBy=[],tempInputStream=<null>,storageLocationRequest=[],storageLocation=[],additionalProperties={},uri=<null>,typeUri=<null>,label=<null>,additionalProperties={}]],additionalProperties={}]],additionalProperties={},id=<null>,type=<null>,description=<null>,title=<null>,created=<null>,submitted=<null>,related=[],hasPart=[],partOf=[],accessHistory=<null>,accessPermission=[],metadata=[],discussion=[],owner=<null>,contributor=[],likedBy=[],dislikedBy=[],tempInputStream=<null>,storageLocationRequest=[],storageLocation=[],additionalProperties={},uri=<null>,typeUri=<null>,label=<null>,additionalProperties={}]
10:56:16,181 | INFO  | sumer[metaQueue] | IndexerWrapper                   | 193 - org.irods.jargon.hive-metadata-indexer - 1.0.0.SNAPSHOT | onMessage:databook.persistence.rule.rdf.ruleset.Message@4a9e82d0[operation=union,hasPart=[databook.persistence.rule.rdf.ruleset.Collection@6c9e4bf5[additionalProperties={},id=<null>,type=<null>,description=<null>,title=<null>,created=<null>,submitted=<null>,related=[],hasPart=[],partOf=[],accessHistory=<null>,accessPermission=[],metadata=[],discussion=[],owner=<null>,contributor=[],likedBy=[],dislikedBy=[],tempInputStream=<null>,storageLocationRequest=[],storageLocation=[],additionalProperties={},uri=/dfc2/home/test1/test-hive2@1407962421,typeUri=<null>,label=<null>,additionalProperties={}], databook.persistence.rule.rdf.ruleset.Collection@c8cf989[additionalProperties={partOfUri=[], metadataObject=[{unit=iRODSUserTagging:HIVE:VocabularyTerm, value=vocabulary=mesh|preferredLabel=Archaea|comment=, attribute=http://www.nlm.nih.gov/mesh/D001105#concept}]},id=<null>,type=databook.persistence.rule.rdf.ruleset.Collection,description=<null>,title=<null>,created=<null>,submitted=<null>,related=[],hasPart=[],partOf=<null>,accessHistory=<null>,accessPermission=[],metadata=<null>,discussion=[],owner=<null>,contributor=[],likedBy=[],dislikedBy=[],tempInputStream=<null>,storageLocationRequest=[],storageLocation=[],additionalProperties={},uri=<null>,typeUri=<null>,label=<null>,additionalProperties={}]],additionalProperties={}]
10:56:16,183 | INFO  | sumer[metaQueue] | IndexerWrapper                   | 193 - org.irods.jargon.hive-metadata-indexer - 1.0.0.SNAPSHOT | check message operation:union
10:56:16,184 | INFO  | sumer[metaQueue] | IndexerWrapper                   | 193 - org.irods.jargon.hive-metadata-indexer - 1.0.0.SNAPSHOT | process as a union
10:56:16,185 | 

INFO  | sumer[metaQueue] | IndexerWrapper                   | 193 - org.irods.jargon.hive-metadata-indexer - 1.0.0.SNAPSHOT | processUnionOperation()
10:56:16,186 | 
ERROR | sumer[metaQueue] | IndexerWrapper                   | 193 - org.irods.jargon.hive-metadata-indexer - 1.0.0.SNAPSHOT | error
java.lang.NullPointerException
    at org.irods.jargon.indexing.wrapper.IndexerWrapper.processUnionOperation(IndexerWrapper.java:107)
    at org.irods.jargon.indexing.wrapper.IndexerWrapper.onMessage(IndexerWrapper.java:90)
    at org.irods.jargon.indexing.wrapper.IndexerWrapper.messages(IndexerWrapper.java:57)
    at databook.listener.ModelUpdater.update(ModelUpdater.java:70)
    at databook.listener.ModelUpdater.handle(ModelUpdater.java:83)
    at Proxyc88d0d31_efd3_4c66_9489_8988e9fda60b.handle(Unknown Source)
    at camelrouter.MessagingServiceBean.consume(MessagingServiceBean.java:16)[183:databook.camel-router:0.0.1.SNAPSHOT]
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)[:1.7.0_65]
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)[:1.7.0_65]
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)[:1.7.0_65]
    at java.lang.reflect.Method.invoke(Method.java:606)[:1.7.0_65]
    at org.apache.camel.component.bean.MethodInfo.invoke(MethodInfo.java:407)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.component.bean.MethodInfo$1.doProceed(MethodInfo.java:278)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.component.bean.MethodInfo$1.proceed(MethodInfo.java:251)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:166)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:105)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:67)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:103)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:71)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:110)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:398)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.processor.Pipeline.process(Pipeline.java:118)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:105)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:87)[107:org.apache.camel.camel-core:2.12.3]
    at org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:103)[108:org.apache.camel.camel-jms:2.12.3]
    at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:562)[105:org.springframework.jms:3.2.4.RELEASE]
    at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:500)[105:org.springframework.jms:3.2.4.RELEASE]
    at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:468)[105:org.springframework.jms:3.2.4.RELEASE]
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)[105:org.springframework.jms:3.2.4.RELEASE]
    at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)[105:org.springframework.jms:3.2.4.RELEASE]
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1103)[105:org.springframework.jms:3.2.4.RELEASE]
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1095)[105:org.springframework.jms:3.2.4.RELEASE]
    at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:992)[105:org.springframework.jms:3.2.4.RELEASE]
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_65]
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_65]
    at java.lang.Thread.run

[michael-conway]

This might be an issue with the indexer not provided expected values, have added a ticket under indexer to map out the Message content on various events of interest at DICE-UNC/indexing#6

Once that is done a new issue can be created to better map/test these messages