Shixiong Zhu created SPARK-5083:
-----------------------------------
Summary: 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
Priority: Minor
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: [email protected]
For additional commands, e-mail: [email protected]
