diff --git a/python/pyspark/ml/base.py b/python/pyspark/ml/base.py index 20540ebbef65..34c3aa9c62cf 100644 --- a/python/pyspark/ml/base.py +++ b/python/pyspark/ml/base.py @@ -110,8 +110,6 @@ class Estimator(Params, Generic[M], metaclass=ABCMeta): .. versionadded:: 1.3.0 """ - pass - @abstractmethod def _fit(self, dataset: DataFrame) -> M: """ @@ -220,8 +218,6 @@ class Transformer(Params, metaclass=ABCMeta): .. versionadded:: 1.3.0 """ - pass - @abstractmethod def _transform(self, dataset: DataFrame) -> DataFrame: """ diff --git a/python/pyspark/ml/evaluation.py b/python/pyspark/ml/evaluation.py index ff0e5b91e424..19d123debaea 100644 --- a/python/pyspark/ml/evaluation.py +++ b/python/pyspark/ml/evaluation.py @@ -67,8 +67,6 @@ class Evaluator(Params, metaclass=ABCMeta): .. versionadded:: 1.4.0 """ - pass - @abstractmethod def _evaluate(self, dataset: DataFrame) -> float: """ diff --git a/python/pyspark/tests/test_worker.py b/python/pyspark/tests/test_worker.py index 0fdf6adb031b..06ada8f81d55 100644 --- a/python/pyspark/tests/test_worker.py +++ b/python/pyspark/tests/test_worker.py @@ -70,7 +70,6 @@ def run(): try: daemon_pid, worker_pid = map(int, data) except ValueError: - pass # In case the value is not written yet. cnt += 1 if cnt == 10: