Skip to content

Commit c00e091

Browse files
committed
change test case not to use awaitTermination
1 parent e80647e commit c00e091

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

python/pyspark/streaming/context.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -102,6 +102,7 @@ def start(self):
102102
def awaitTermination(self, timeout=None):
103103
"""
104104
Wait for the execution to stop.
105+
@param timeout: time to wait in milliseconds
105106
"""
106107
if timeout is None:
107108
self._jssc.awaitTermination()

streaming/src/main/scala/org/apache/spark/streaming/api/python/PythonDStream.scala

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -184,8 +184,6 @@ class PythonForeachDStream(
184184
this.register()
185185
}
186186

187-
/*
188-
This does not work. Ignore this for now. -TD
189187
class PythonTransformedDStream(
190188
prev: DStream[Array[Byte]],
191189
transformFunction: PythonRDDFunction
@@ -204,7 +202,6 @@ class PythonTransformedDStream(
204202
val asJavaDStream = JavaDStream.fromDStream(this)
205203
//val asJavaPairDStream : JavaPairDStream[Long, Array[Byte]] = JavaPairDStream.fromJavaDStream(this)
206204
}
207-
*/
208205

209206
/**
210207
* This is a input stream just for the unitest. This is equivalent to a checkpointable,

0 commit comments

Comments
 (0)