apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Siyuan Hua (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (APEXMALHAR-2230) Intermittent test failure in Kafka module
Date Thu, 08 Sep 2016 21:01:21 GMT

    [ 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)

Mime
View raw message