Github user BryanCutler commented on a diff in the pull request:
https://github.com/apache/spark/pull/12790#discussion_r75392014
--- Diff: python/pyspark/status.py ---
@@ -83,6 +85,8 @@ def getJobInfo(self, jobId):
job = self._jtracker.getJobInfo(jobId)
if
Github user MechCoder commented on a diff in the pull request:
https://github.com/apache/spark/pull/12790#discussion_r75390810
--- Diff: python/pyspark/status.py ---
@@ -83,6 +85,8 @@ def getJobInfo(self, jobId):
job = self._jtracker.getJobInfo(jobId)
if
Github user BryanCutler commented on a diff in the pull request:
https://github.com/apache/spark/pull/12790#discussion_r75229691
--- Diff: python/pyspark/ml/tests.py ---
@@ -230,6 +230,15 @@ def test_pipeline(self):
self.assertEqual(5, transformer3.dataset_index)
Github user BryanCutler commented on a diff in the pull request:
https://github.com/apache/spark/pull/12790#discussion_r75229100
--- Diff: python/pyspark/ml/pipeline.py ---
@@ -57,9 +57,8 @@ def __init__(self, stages=None):
"""
__init__(self, stages=None)
Github user MechCoder commented on a diff in the pull request:
https://github.com/apache/spark/pull/12790#discussion_r75024959
--- Diff: python/pyspark/ml/pipeline.py ---
@@ -57,9 +57,8 @@ def __init__(self, stages=None):
"""
__init__(self, stages=None)
Github user MechCoder commented on a diff in the pull request:
https://github.com/apache/spark/pull/12790#discussion_r75023876
--- Diff: python/pyspark/ml/tests.py ---
@@ -230,6 +230,15 @@ def test_pipeline(self):
self.assertEqual(5, transformer3.dataset_index)
