pyspark.streaming.tests.test_dstream.CheckpointTests

test_get_or_create_and_get_active_or_create

test_transform_function_serializer_failure