From 2194ab289e40b282632028e29244da3f6615b517 Mon Sep 17 00:00:00 2001
From: darionyaphet <darion.yaphet@gmail.com>
Date: Sat, 7 May 2016 20:31:35 +0800
Subject: [PATCH] fix #106 DataSourceProcessor and DataSinkProcessor default
 parallelism

---
 .../scala/io/gearpump/streaming/sink/DataSinkProcessor.scala    | 2 +-
 .../io/gearpump/streaming/source/DataSourceProcessor.scala      | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/streaming/src/main/scala/io/gearpump/streaming/sink/DataSinkProcessor.scala b/streaming/src/main/scala/io/gearpump/streaming/sink/DataSinkProcessor.scala
index d753cc2bd..d6467af49 100644
--- a/streaming/src/main/scala/io/gearpump/streaming/sink/DataSinkProcessor.scala
+++ b/streaming/src/main/scala/io/gearpump/streaming/sink/DataSinkProcessor.scala
@@ -39,7 +39,7 @@ import io.gearpump.streaming.Processor
 object DataSinkProcessor {
   def apply(
       dataSink: DataSink,
-      parallelism: Int,
+      parallelism: Int = 1,
       description: String = "",
       taskConf: UserConfig = UserConfig.empty)(implicit system: ActorSystem)
     : Processor[DataSinkTask] = {
diff --git a/streaming/src/main/scala/io/gearpump/streaming/source/DataSourceProcessor.scala b/streaming/src/main/scala/io/gearpump/streaming/source/DataSourceProcessor.scala
index 384b86a95..5337de993 100644
--- a/streaming/src/main/scala/io/gearpump/streaming/source/DataSourceProcessor.scala
+++ b/streaming/src/main/scala/io/gearpump/streaming/source/DataSourceProcessor.scala
@@ -39,7 +39,7 @@ import io.gearpump.streaming.Processor
 object DataSourceProcessor {
   def apply(
       dataSource: DataSource,
-      parallelism: Int,
+      parallelism: Int = 1,
       description: String = "",
       taskConf: UserConfig = UserConfig.empty)(implicit system: ActorSystem)
     : Processor[DataSourceTask] = {