diff options
author | Marcelo Vanzin <vanzin@cloudera.com> | 2016-04-29 23:13:50 -0700 |
---|---|---|
committer | Reynold Xin <rxin@databricks.com> | 2016-04-29 23:13:50 -0700 |
commit | 73c20bf32524c2232febc8c4b12d5fa228347163 (patch) | |
tree | 88e9f4f88c38b02d974a762c3482d716d62f0545 /launcher/src/main | |
parent | bc36fe6e896ab0e64f6334b1e3fd6386d0c38238 (diff) | |
download | spark-73c20bf32524c2232febc8c4b12d5fa228347163.tar.gz spark-73c20bf32524c2232febc8c4b12d5fa228347163.tar.bz2 spark-73c20bf32524c2232febc8c4b12d5fa228347163.zip |
[SPARK-14391][LAUNCHER] Fix launcher communication test, take 2.
There's actually a race here: the state of the handler was changed before
the connection was set, so the test code could be notified of the state
change, wake up, and still see the connection as null, triggering the assert.
Author: Marcelo Vanzin <vanzin@cloudera.com>
Closes #12785 from vanzin/SPARK-14391.
Diffstat (limited to 'launcher/src/main')
-rw-r--r-- | launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java b/launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java index 69fbf4387b..e3413fd665 100644 --- a/launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java +++ b/launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java @@ -298,8 +298,8 @@ class LauncherServer implements Closeable { Hello hello = (Hello) msg; ChildProcAppHandle handle = pending.remove(hello.secret); if (handle != null) { - handle.setState(SparkAppHandle.State.CONNECTED); handle.setConnection(this); + handle.setState(SparkAppHandle.State.CONNECTED); this.handle = handle; } else { throw new IllegalArgumentException("Received Hello for unknown client."); |