Skip to content

Commit

Permalink
Remove python3 incompatibilities
Browse files Browse the repository at this point in the history
  • Loading branch information
bersprockets committed Feb 9, 2018
1 parent b1556aa commit 3dc4f9a
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions python/pyspark/daemon.py
Original file line number Diff line number Diff line change
Expand Up @@ -184,23 +184,23 @@ def handle_sigterm(*args):

if __name__ == '__main__':
if len(sys.argv) < 2:
print >> sys.stderr, "No parent port number specified"
sys.stderr.write("No parent port number specified\n")
sys.exit(1)
try:
parent_port = int(sys.argv[1])
except ValueError:
print >> sys.stderr, "Non-numeric port number specified:", sys.argv[1]
sys.stderr.write("Non-numeric port number specified: %s\n" % sys.argv[1])
sys.exit(1)

token_string = os.environ.get("PYSPARK_DAEMON_TOKEN")
if token_string is None:
print >> sys.stderr, "PYSPARK_DAEMON_TOKEN environment variable is not set"
sys.stderr.write("PYSPARK_DAEMON_TOKEN environment variable is not set\n")
sys.exit(1)
try:
token = long(token_string)
# works for long values too
token = int(token_string)
except ValueError:
print >> sys.stderr, \
"Non-numeric value set in environment variable PYSPARK_DAEMON_TOKEN:", token_string
sys.stderr.write("Non-numeric value set in environment variable PYSPARK_DAEMON_TOKEN: %s\n" % token_string)
sys.exit(1)

manager(parent_port, token)

0 comments on commit 3dc4f9a

Please sign in to comment.