Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/19591
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158560723
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/InProcessAppHandle.java ---
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158537984
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/InProcessAppHandle.java ---
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software
Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158509926
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/InProcessAppHandle.java ---
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158355602
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java ---
@@ -210,8 +209,13 @@ int getPort() {
* Removes the client handle
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158351004
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java ---
@@ -260,24 +264,30 @@ private long getConnectionTimeout() {
}
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158349922
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/InProcessAppHandle.java ---
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software
Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158316971
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java ---
@@ -210,8 +209,13 @@ int getPort() {
* Removes the client handle
Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158307838
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java ---
@@ -210,8 +209,13 @@ int getPort() {
* Removes the client handle
Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158198274
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/InProcessAppHandle.java ---
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software
Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158201917
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/package-info.java ---
@@ -49,6 +49,15 @@
*
*
*
+ * Applications can also
Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158201527
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java ---
@@ -260,24 +264,30 @@ private long getConnectionTimeout() {
}
Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158200240
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/InProcessAppHandle.java ---
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software
Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158200059
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/ChildProcAppHandle.java ---
@@ -171,10 +90,11 @@ void monitorChild() {
}
Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158200163
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/InProcessAppHandle.java ---
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software
Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r158201743
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/LauncherServer.java ---
@@ -210,8 +209,13 @@ int getPort() {
* Removes the client handle
Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r156746267
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/InProcessLauncher.java ---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the Apache Software
Github user rezasafi commented on a diff in the pull request:
https://github.com/apache/spark/pull/19591#discussion_r156535010
--- Diff:
launcher/src/main/java/org/apache/spark/launcher/InProcessLauncher.java ---
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the Apache Software
GitHub user vanzin opened a pull request:
https://github.com/apache/spark/pull/19591
[SPARK-11035][core] Add in-process Spark app launcher.
This change adds a new launcher that allows applications to be run
in a separate thread in the same process as the calling code. To
19 matches
Mail list logo
