You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Reynold Xin (JIRA)" <ji...@apache.org> on 2015/01/05 06:10:34 UTC
[jira] [Resolved] (SPARK-5083) Fix a flaky test in
TaskResultGetterSuite
[ https://issues.apache.org/jira/browse/SPARK-5083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Reynold Xin resolved SPARK-5083.
--------------------------------
Resolution: Fixed
Fix Version/s: 1.3.0
Assignee: Shixiong Zhu
> Fix a flaky test in TaskResultGetterSuite
> -----------------------------------------
>
> Key: SPARK-5083
> URL: https://issues.apache.org/jira/browse/SPARK-5083
> Project: Spark
> Issue Type: Test
> Components: Spark Core
> Reporter: Shixiong Zhu
> Assignee: Shixiong Zhu
> Priority: Minor
> Labels: flaky-test
> Fix For: 1.3.0
>
>
> Fix the following flaky test
> {noformat}
> [info] TaskResultGetterSuite:
> [info] - task retried if result missing from block manager *** FAILED *** (343 milliseconds)
> [info] org.apache.spark.SparkException: Job aborted due to stage failure: Exception while getting task result: java.lang.RuntimeException: org.apache.spark.storage.BlockNotFoundException: Block taskresult_0 not found
> [info] at org.apache.spark.storage.BlockManager.getBlockData(BlockManager.scala:314)
> [info] at org.apache.spark.network.netty.NettyBlockRpcServer$$anonfun$2.apply(NettyBlockRpcServer.scala:57)
> [info] at org.apache.spark.network.netty.NettyBlockRpcServer$$anonfun$2.apply(NettyBlockRpcServer.scala:57)
> [info] at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
> [info] at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
> [info] at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
> [info] at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:108)
> [info] at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
> [info] at scala.collection.mutable.ArrayOps$ofRef.map(ArrayOps.scala:108)
> [info] at org.apache.spark.network.netty.NettyBlockRpcServer.receive(NettyBlockRpcServer.scala:57)
> [info] at org.apache.spark.network.server.TransportRequestHandler.processRpcRequest(TransportRequestHandler.java:124)
> [info] at org.apache.spark.network.server.TransportRequestHandler.handle(TransportRequestHandler.java:97)
> [info] at org.apache.spark.network.server.TransportChannelHandler.channelRead0(TransportChannelHandler.java:91)
> [info] at org.apache.spark.network.server.TransportChannelHandler.channelRead0(TransportChannelHandler.java:44)
> [info] at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
> [info] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
> [info] at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
> [info] at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)
> [info] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
> [info] at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:319)
> [info] at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:163)
> [info] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:333)
> [info] at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerCont
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org