You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "sunsc (JIRA)" <ji...@apache.org> on 2014/07/23 03:26:40 UTC
[jira] [Comment Edited] (SPARK-2379) stopReceive in dead loop,
cause stackoverflow exception
[ https://issues.apache.org/jira/browse/SPARK-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14071240#comment-14071240 ]
sunsc edited comment on SPARK-2379 at 7/23/14 1:26 AM:
-------------------------------------------------------
--- a/spark/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisor.scala
+++ b/spark/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisor.scala
@@ -138,7 +138,7 @@ private[streaming] abstract class ReceiverSupervisor(
onReceiverStop(message, error)
} catch {
case t: Throwable =>
- stop("Error stopping receiver " + streamId, Some(t))
/////////////////////////////////////////////////////////////////////////////////
+ logError("Error stopping receiver " + streamId + t.getStackTraceString)
}
}
was (Author: joyyoj):
--- a/spark/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisor.scala
+++ b/spark/streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisor.scala
@@ -138,7 +138,7 @@ private[streaming] abstract class ReceiverSupervisor(
onReceiverStop(message, error)
} catch {
case t: Throwable =>
- stop("Error stopping receiver " + streamId, Some(t))
\n
+ logError("Error stopping receiver " + streamId + t.getStackTraceString)
}
}
> stopReceive in dead loop, cause stackoverflow exception
> -------------------------------------------------------
>
> Key: SPARK-2379
> URL: https://issues.apache.org/jira/browse/SPARK-2379
> Project: Spark
> Issue Type: Bug
> Components: Streaming
> Affects Versions: 1.0.0
> Reporter: sunsc
>
> streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisor.scala
> stop will call stopReceiver and stopReceiver will call stop if exception occurs, that make a dead loop.
--
This message was sent by Atlassian JIRA
(v6.2#6252)