Skip to content

Commit

Permalink
Improve the message
Browse files Browse the repository at this point in the history
  • Loading branch information
jakubhava committed Jun 25, 2020
1 parent 8275e1e commit cae6259
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -38,11 +38,10 @@ object SparklingGateway extends Logging {
} else {
logInfo(s"""Running Py4j Gateway on port $boundPort""")
}
// Exit on EOF or broken pipe to ensure that this process dies when the Python driver dies:
while (!(spark.sparkContext.isStopped || hc.isStopped())) {
Thread.sleep(1000)
}
logDebug("Exiting due to broken pipe from Python driver")
logDebug("Exiting since we received request to stop Spark or H2O.")
System.exit(0)
}

Expand Down

0 comments on commit cae6259

Please sign in to comment.