You are viewing a plain text version of this content. The canonical link for it is here.
Posted to reviews@spark.apache.org by zsxwing <gi...@git.apache.org> on 2014/09/30 10:33:54 UTC

[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

GitHub user zsxwing opened a pull request:

    https://github.com/apache/spark/pull/2593

    [SPARK-3741] Make ConnectionManager propagate errors properly and add mo...

    ...re logs to avoid Executors swallowing errors
    
    This PR made the following changes:
    * Register a callback to `Connection` so that the error will be propagated properly.
    * Add more logs so that the errors won't be swallowed by Executors.
    * Use trySuccess/tryFailure because `Promise` doesn't allow to call success/failure more than once.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/zsxwing/spark SPARK-3741

Alternatively you can review and apply these changes as the patch at:

    https://github.com/apache/spark/pull/2593.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #2593
    
----
commit 764aec5f256babf5baff20cb0c0cf5532c2a5f20
Author: zsxwing <zs...@gmail.com>
Date:   2014-09-30T07:04:16Z

    [SPARK-3741] Make ConnectionManager propagate errors properly and add more logs to avoid Executors swallowing errors

----


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:

    https://github.com/apache/spark/pull/2593


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by SparkQA <gi...@git.apache.org>.
Github user SparkQA commented on the pull request:

    https://github.com/apache/spark/pull/2593#issuecomment-58461622
  
      [QA tests have started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/21518/consoleFull) for   PR 2593 at commit [`1d5aed5`](https://github.com/apache/spark/commit/1d5aed5b1db0c16b8f8dd557e8b428355a6029c3).
     * This patch merges cleanly.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by SparkQA <gi...@git.apache.org>.
Github user SparkQA commented on the pull request:

    https://github.com/apache/spark/pull/2593#issuecomment-57283216
  
      [QA tests have started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/21035/consoleFull) for   PR 2593 at commit [`764aec5`](https://github.com/apache/spark/commit/764aec5f256babf5baff20cb0c0cf5532c2a5f20).
     * This patch merges cleanly.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by AmplabJenkins <gi...@git.apache.org>.
Github user AmplabJenkins commented on the pull request:

    https://github.com/apache/spark/pull/2593#issuecomment-57288749
  
    Test FAILed.
    Refer to this link for build results (access rights to CI server needed): 
    https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/21035/


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by JoshRosen <gi...@git.apache.org>.
Github user JoshRosen commented on a diff in the pull request:

    https://github.com/apache/spark/pull/2593#discussion_r18614772
  
    --- Diff: core/src/main/scala/org/apache/spark/network/nio/ConnectionManager.scala ---
    @@ -51,14 +53,23 @@ private[nio] class ConnectionManager(
       class MessageStatus(
           val message: Message,
           val connectionManagerId: ConnectionManagerId,
    -      completionHandler: MessageStatus => Unit) {
    +      completionHandler: Try[Message] => Unit) {
     
    -    /** This is non-None if message has been ack'd */
    -    var ackMessage: Option[Message] = None
    +    def success(ackMessage: Message) {
    +      if (ackMessage == null) {
    +        failure(new NullPointerException)
    +      }
    +      else {
    +        completionHandler(scala.util.Success(ackMessage))
    +      }
    +    }
     
    -    def markDone(ackMessage: Option[Message]) {
    -      this.ackMessage = ackMessage
    -      completionHandler(this)
    +    def receiveNonAck() {
    --- End diff --
    
    I understand what this corresponds to, but it might be clearer to call it something like `failWithoutAck`.  The `receiveNonAck` seems slightly confusing to me, since we sometimes call this method when closing a connection, in which case we haven't received anything (this is actually triggered in cases of non-receipt).


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by JoshRosen <gi...@git.apache.org>.
Github user JoshRosen commented on a diff in the pull request:

    https://github.com/apache/spark/pull/2593#discussion_r18615059
  
    --- Diff: core/src/main/scala/org/apache/spark/network/nio/Connection.scala ---
    @@ -134,20 +137,24 @@ abstract class Connection(val channel: SocketChannel, val selector: Selector,
         onCloseCallback = callback
       }
     
    -  def onException(callback: (Connection, Exception) => Unit) {
    -    onExceptionCallback = callback
    +  def onException(callback: (Connection, Throwable) => Unit) {
    +    onExceptionCallbacks.add(callback)
       }
     
       def onKeyInterestChange(callback: (Connection, Int) => Unit) {
         onKeyInterestChangeCallback = callback
       }
     
    -  def callOnExceptionCallback(e: Exception) {
    -    if (onExceptionCallback != null) {
    -      onExceptionCallback(this, e)
    -    } else {
    -      logError("Error in connection to " + getRemoteConnectionManagerId() +
    --- End diff --
    
    Ah, nevermind: I see that we now log the errors at the error sites before calling the callbacks.  Good change.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by JoshRosen <gi...@git.apache.org>.
Github user JoshRosen commented on the pull request:

    https://github.com/apache/spark/pull/2593#issuecomment-58435802
  
    Hi @zsxwing,
    
    Thanks for submitting this PR (and sorry for the delayed review)!  These changes will be _very_ helpful in debugging certain types of connection manager issues that we've encountered.  I like the careful attention to error-handling cases that we missed before, especially the use of `afterExecute` to detect unhandled errors.
    
    I left a few comments, mostly regarding naming.  If you fix up the merge conflicts, I think this looks ready to merge.  Thanks!


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by AmplabJenkins <gi...@git.apache.org>.
Github user AmplabJenkins commented on the pull request:

    https://github.com/apache/spark/pull/2593#issuecomment-57297950
  
    Test PASSed.
    Refer to this link for build results (access rights to CI server needed): 
    https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/21036/


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by JoshRosen <gi...@git.apache.org>.
Github user JoshRosen commented on the pull request:

    https://github.com/apache/spark/pull/2593#issuecomment-58554451
  
    This looks good to me, so I'm going to merge it.  Thanks a bunch; this will really help with debugging!


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by JoshRosen <gi...@git.apache.org>.
Github user JoshRosen commented on a diff in the pull request:

    https://github.com/apache/spark/pull/2593#discussion_r18664008
  
    --- Diff: core/src/main/scala/org/apache/spark/network/nio/ConnectionManager.scala ---
    @@ -72,14 +83,32 @@ private[nio] class ConnectionManager(
         conf.getInt("spark.core.connection.handler.threads.max", 60),
         conf.getInt("spark.core.connection.handler.threads.keepalive", 60), TimeUnit.SECONDS,
         new LinkedBlockingDeque[Runnable](),
    -    Utils.namedThreadFactory("handle-message-executor"))
    +    Utils.namedThreadFactory("handle-message-executor")) {
    +
    +    override def afterExecute(r: Runnable, t: Throwable): Unit = {
    +      super.afterExecute(r, t)
    +      if (t != null && NonFatal(t)) {
    --- End diff --
    
    Nice change.  


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by zsxwing <gi...@git.apache.org>.
Github user zsxwing commented on a diff in the pull request:

    https://github.com/apache/spark/pull/2593#discussion_r18626201
  
    --- Diff: core/src/main/scala/org/apache/spark/network/nio/ConnectionManager.scala ---
    @@ -72,14 +83,32 @@ private[nio] class ConnectionManager(
         conf.getInt("spark.core.connection.handler.threads.max", 60),
         conf.getInt("spark.core.connection.handler.threads.keepalive", 60), TimeUnit.SECONDS,
         new LinkedBlockingDeque[Runnable](),
    -    Utils.namedThreadFactory("handle-message-executor"))
    +    Utils.namedThreadFactory("handle-message-executor")) {
    +
    +    override def afterExecute(r: Runnable, t: Throwable): Unit = {
    +      super.afterExecute(r, t)
    +      if (t != null && NonFatal(t)) {
    --- End diff --
    
    I added `NonFatal(t)` to avoid to output nonfatal exceptions. It's expected that they are not be handled.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by JoshRosen <gi...@git.apache.org>.
Github user JoshRosen commented on a diff in the pull request:

    https://github.com/apache/spark/pull/2593#discussion_r18614326
  
    --- Diff: core/src/main/scala/org/apache/spark/network/nio/ConnectionManager.scala ---
    @@ -51,14 +53,23 @@ private[nio] class ConnectionManager(
       class MessageStatus(
           val message: Message,
           val connectionManagerId: ConnectionManagerId,
    -      completionHandler: MessageStatus => Unit) {
    +      completionHandler: Try[Message] => Unit) {
     
    -    /** This is non-None if message has been ack'd */
    -    var ackMessage: Option[Message] = None
    +    def success(ackMessage: Message) {
    +      if (ackMessage == null) {
    --- End diff --
    
    Good change; this was a corner-case that we didn't anticipate before.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by SparkQA <gi...@git.apache.org>.
Github user SparkQA commented on the pull request:

    https://github.com/apache/spark/pull/2593#issuecomment-57291615
  
      [QA tests have started](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/21036/consoleFull) for   PR 2593 at commit [`764aec5`](https://github.com/apache/spark/commit/764aec5f256babf5baff20cb0c0cf5532c2a5f20).
     * This patch merges cleanly.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by JoshRosen <gi...@git.apache.org>.
Github user JoshRosen commented on a diff in the pull request:

    https://github.com/apache/spark/pull/2593#discussion_r18614120
  
    --- Diff: core/src/main/scala/org/apache/spark/network/nio/Connection.scala ---
    @@ -134,20 +137,24 @@ abstract class Connection(val channel: SocketChannel, val selector: Selector,
         onCloseCallback = callback
       }
     
    -  def onException(callback: (Connection, Exception) => Unit) {
    -    onExceptionCallback = callback
    +  def onException(callback: (Connection, Throwable) => Unit) {
    +    onExceptionCallbacks.add(callback)
       }
     
       def onKeyInterestChange(callback: (Connection, Int) => Unit) {
         onKeyInterestChangeCallback = callback
       }
     
    -  def callOnExceptionCallback(e: Exception) {
    -    if (onExceptionCallback != null) {
    -      onExceptionCallback(this, e)
    -    } else {
    -      logError("Error in connection to " + getRemoteConnectionManagerId() +
    -        " and OnExceptionCallback not registered", e)
    +  def callOnExceptionCallback(e: Throwable) {
    +    onExceptionCallbacks foreach {
    +      callback =>
    +        try {
    +          callback(this, e)
    +        } catch {
    +          case NonFatal(e) => {
    +            logWarning("Ignore error", e)
    --- End diff --
    
    Could you change this to be more descriptive?  How about something like "Ignored error in onExceptionCallback"?


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by JoshRosen <gi...@git.apache.org>.
Github user JoshRosen commented on a diff in the pull request:

    https://github.com/apache/spark/pull/2593#discussion_r18614238
  
    --- Diff: core/src/main/scala/org/apache/spark/network/nio/Connection.scala ---
    @@ -134,20 +137,24 @@ abstract class Connection(val channel: SocketChannel, val selector: Selector,
         onCloseCallback = callback
       }
     
    -  def onException(callback: (Connection, Exception) => Unit) {
    -    onExceptionCallback = callback
    +  def onException(callback: (Connection, Throwable) => Unit) {
    +    onExceptionCallbacks.add(callback)
       }
     
       def onKeyInterestChange(callback: (Connection, Int) => Unit) {
         onKeyInterestChangeCallback = callback
       }
     
    -  def callOnExceptionCallback(e: Exception) {
    -    if (onExceptionCallback != null) {
    -      onExceptionCallback(this, e)
    -    } else {
    -      logError("Error in connection to " + getRemoteConnectionManagerId() +
    --- End diff --
    
    Can we keep this warning in case `onExceptionCallsbacks` is empty?  Maybe we could add an explicit `isEmpty` check inside of `callOnExceptionCallback`


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by SparkQA <gi...@git.apache.org>.
Github user SparkQA commented on the pull request:

    https://github.com/apache/spark/pull/2593#issuecomment-58464527
  
      [QA tests have finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/21518/consoleFull) for   PR 2593 at commit [`1d5aed5`](https://github.com/apache/spark/commit/1d5aed5b1db0c16b8f8dd557e8b428355a6029c3).
     * This patch **passes all tests**.
     * This patch merges cleanly.
     * This patch adds no public classes.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by zsxwing <gi...@git.apache.org>.
Github user zsxwing commented on the pull request:

    https://github.com/apache/spark/pull/2593#issuecomment-58461588
  
    Merged and updated the naming.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by JoshRosen <gi...@git.apache.org>.
Github user JoshRosen commented on a diff in the pull request:

    https://github.com/apache/spark/pull/2593#discussion_r18614256
  
    --- Diff: core/src/main/scala/org/apache/spark/network/nio/Connection.scala ---
    @@ -134,20 +137,24 @@ abstract class Connection(val channel: SocketChannel, val selector: Selector,
         onCloseCallback = callback
       }
     
    -  def onException(callback: (Connection, Exception) => Unit) {
    -    onExceptionCallback = callback
    +  def onException(callback: (Connection, Throwable) => Unit) {
    +    onExceptionCallbacks.add(callback)
       }
     
       def onKeyInterestChange(callback: (Connection, Int) => Unit) {
         onKeyInterestChangeCallback = callback
       }
     
    -  def callOnExceptionCallback(e: Exception) {
    -    if (onExceptionCallback != null) {
    -      onExceptionCallback(this, e)
    -    } else {
    -      logError("Error in connection to " + getRemoteConnectionManagerId() +
    -        " and OnExceptionCallback not registered", e)
    +  def callOnExceptionCallback(e: Throwable) {
    --- End diff --
    
    Can you change this to `callOnExceptionCallbacks` (plural), since we now might call multiple callbacks?


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by zsxwing <gi...@git.apache.org>.
Github user zsxwing commented on the pull request:

    https://github.com/apache/spark/pull/2593#issuecomment-57291052
  
    retest this please. This test is OK in my machine.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by SparkQA <gi...@git.apache.org>.
Github user SparkQA commented on the pull request:

    https://github.com/apache/spark/pull/2593#issuecomment-57288745
  
      [QA tests have finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/21035/consoleFull) for   PR 2593 at commit [`764aec5`](https://github.com/apache/spark/commit/764aec5f256babf5baff20cb0c0cf5532c2a5f20).
     * This patch **fails** unit tests.
     * This patch merges cleanly.
     * This patch adds no public classes.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org


[GitHub] spark pull request: [SPARK-3741] Make ConnectionManager propagate ...

Posted by AmplabJenkins <gi...@git.apache.org>.
Github user AmplabJenkins commented on the pull request:

    https://github.com/apache/spark/pull/2593#issuecomment-58464534
  
    Test PASSed.
    Refer to this link for build results (access rights to CI server needed): 
    https://amplab.cs.berkeley.edu/jenkins//job/SparkPullRequestBuilder/21518/Test PASSed.


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org