Skip to content

Commit bb36f50

Browse files
committed
hmmm lets makesure grab jvm is true
1 parent 89cf739 commit bb36f50

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

python/pyspark/java_gateway.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,8 @@ def launch_gateway(conf=None):
4949
redirect_shells = ["ZMQInteractiveShell", "StringIO"]
5050
grab_jvm_output = (sys.stdout != sys.__stdout__ and
5151
sys.stdout.__class__.__name__ in redirect_shells)
52+
if grab_jvm_output:
53+
print("Grabbing JVM output cause magic.....")
5254

5355
if "PYSPARK_GATEWAY_PORT" in os.environ:
5456
gateway_port = int(os.environ["PYSPARK_GATEWAY_PORT"])

0 commit comments

Comments
 (0)