Remove references to third party cloudpickle.

Author: claudevdm

sdks/python/apache_beam/ml/anomaly/specifiable_test.py

@@ -25,6 +25,7 @@
 
 from parameterized import parameterized
 
+from apache_beam.internal.cloudpickle import cloudpickle
 from apache_beam.ml.anomaly.specifiable import _FALLBACK_SUBSPACE
 from apache_beam.ml.anomaly.specifiable import _KNOWN_SPECIFIABLE
 from apache_beam.ml.anomaly.specifiable import Spec
@@ -353,7 +354,6 @@ def test_on_pickle(self):
     self.assertEqual(FooForPickle.counter, 1)
     self.assertEqual(new_foo_2.__dict__, foo.__dict__)
 
-    import cloudpickle
     FooForPickle.counter = 0
     foo = FooForPickle(456)
     self.assertEqual(FooForPickle.counter, 0)

sdks/python/apache_beam/typehints/schemas_test.py

@@ -30,14 +30,14 @@
 from typing import Optional
 from typing import Sequence
 
-import cloudpickle
 import dill
 import numpy as np
 from hypothesis import given
 from hypothesis import settings
 from parameterized import parameterized
 from parameterized import parameterized_class
 
+from apache_beam.internal.cloudpickle import cloudpickle
 from apache_beam.portability import common_urns
 from apache_beam.portability.api import schema_pb2
 from apache_beam.typehints import row_type