[
https://issues.apache.org/jira/browse/APEXMALHAR-2230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15474990#comment-15474990
]
Siyuan Hua commented on APEXMALHAR-2230:
----------------------------------------
Not necessarily related to Kafka. This is caused by another exception
2016-09-07 20:13:14,825 [6/Kafka
inputtesttopic6.outputPort#unifier:DefaultUnifier] ERROR
engine.StreamingContainer run - Operator set
[OperatorDeployInfo.UnifierDeployInfo[id=6,name=Kafka
inputtesttopic6.outputPort#unifier,type=UNIFIER,checkpoint={57d074d300000001,
0,
0},inputs=[OperatorDeployInfo.InputDeployInfo[portName=<merge#outputPort>(1.outputPort),streamId=Kafka
messagetesttopic6,sourceNodeId=1,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>],
OperatorDeployInfo.InputDeployInfo[portName=<merge#outputPort>(2.outputPort),streamId=Kafka
messagetesttopic6,sourceNodeId=2,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>],
OperatorDeployInfo.InputDeployInfo[portName=<merge#outputPort>(3.outputPort),streamId=Kafka
messagetesttopic6,sourceNodeId=3,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>],
OperatorDeployInfo.InputDeployInfo[portName=<merge#outputPort>(4.outputPort),streamId=Kafka
messagetesttopic6,sourceNodeId=4,sourcePortName=outputPort,locality=<null>,partitionMask=0,partitionKeys=<null>]],outputs=[OperatorDeployInfo.OutputDeployInfo[portName=outputPort,streamId=Kafka
messagetesttopic6,bufferServer=testing-worker-linux-docker-c25f223a-3424-linux-7]]]]
stopped running due to an exception.
java.lang.NullPointerException
at com.datatorrent.bufferserver.packet.Tuple.getTuple(Tuple.java:54)
at
com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sweep(BufferServerSubscriber.java:309)
at com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:259)
at
com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1407)
2016-09-07 20:13:14,826 [6/Kafka
inputtesttopic6.outputPort#unifier:DefaultUnifier] INFO
stram.StramLocalCluster log - container-1 msg: Stopped running due to an
exception. java.lang.NullPointerException
at com.datatorrent.bufferserver.packet.Tuple.getTuple(Tuple.java:54)
at
com.datatorrent.stram.stream.BufferServerSubscriber$BufferReservoir.sweep(BufferServerSubscriber.java:309)
at com.datatorrent.stram.engine.GenericNode.run(GenericNode.java:259)
at
com.datatorrent.stram.engine.StreamingContainer$2.run(StreamingContainer.java:1407)This
is related to some
Basically on the bufferserver side it already received some unexpected data.
> Intermittent test failure in Kafka module
> -----------------------------------------
>
> Key: APEXMALHAR-2230
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2230
> Project: Apache Apex Malhar
> Issue Type: Bug
> Affects Versions: 3.5.0
> Reporter: Thomas Weise
> Assignee: Siyuan Hua
>
> Test fails intermittently in Travis CI. Could be a race condition in the test?
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
