aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark/ml
diff options
context:
space:
mode:
Diffstat (limited to 'python/pyspark/ml')
-rw-r--r--python/pyspark/ml/param/__init__.py2
-rw-r--r--python/pyspark/ml/pipeline.py4
2 files changed, 3 insertions, 3 deletions
diff --git a/python/pyspark/ml/param/__init__.py b/python/pyspark/ml/param/__init__.py
index 9fccb65675..49c20b4cf7 100644
--- a/python/pyspark/ml/param/__init__.py
+++ b/python/pyspark/ml/param/__init__.py
@@ -30,7 +30,7 @@ class Param(object):
def __init__(self, parent, name, doc):
if not isinstance(parent, Params):
- raise ValueError("Parent must be a Params but got type %s." % type(parent).__name__)
+ raise TypeError("Parent must be a Params but got type %s." % type(parent))
self.parent = parent
self.name = str(name)
self.doc = str(doc)
diff --git a/python/pyspark/ml/pipeline.py b/python/pyspark/ml/pipeline.py
index d94ecfff09..7c1ec3026d 100644
--- a/python/pyspark/ml/pipeline.py
+++ b/python/pyspark/ml/pipeline.py
@@ -131,8 +131,8 @@ class Pipeline(Estimator):
stages = paramMap[self.stages]
for stage in stages:
if not (isinstance(stage, Estimator) or isinstance(stage, Transformer)):
- raise ValueError(
- "Cannot recognize a pipeline stage of type %s." % type(stage).__name__)
+ raise TypeError(
+ "Cannot recognize a pipeline stage of type %s." % type(stage))
indexOfLastEstimator = -1
for i, stage in enumerate(stages):
if isinstance(stage, Estimator):