We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9e36df1 commit 5e2ac50Copy full SHA for 5e2ac50
external/zeromq/src/main/scala/org/apache/spark/streaming/zeromq/ZeroMQUtils.scala
@@ -55,7 +55,7 @@ object ZeroMQUtils {
55
bytesToObjects: Seq[ByteString] => Iterator[T],
56
storageLevel: StorageLevel = StorageLevel.MEMORY_AND_DISK_SER_2,
57
actorSystemCreator: () => ActorSystem = ActorReceiver.defaultActorSystemCreator,
58
- supervisorStrategy: SupervisorStrategy = ActorReceiver.defaultStrategy
+ supervisorStrategy: SupervisorStrategy = ActorReceiver.defaultSupervisorStrategy
59
): ReceiverInputDStream[T] = {
60
AkkaUtils.createStream(
61
ssc,
0 commit comments