SAMZA-453: Allow spaces in task.inputs config property.
Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/bbf7b2da Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/bbf7b2da Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/bbf7b2da Branch: refs/heads/master Commit: bbf7b2da1a4e4fed0c5beec9e6424cc75dab5cac Parents: f1d595d Author: Martin Kleppmann <[email protected]> Authored: Thu Nov 6 14:26:00 2014 +0000 Committer: Martin Kleppmann <[email protected]> Committed: Thu Nov 6 14:26:00 2014 +0000 ---------------------------------------------------------------------- samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/bbf7b2da/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala ---------------------------------------------------------------------- diff --git a/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala b/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala index d066ed8..1ca9e2c 100644 --- a/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala +++ b/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala @@ -61,7 +61,7 @@ class TaskConfig(config: Config) extends ScalaMapConfig(config) { def getInputStreams = getOption(TaskConfig.INPUT_STREAMS) match { case Some(streams) => if (streams.length > 0) { streams.split(",").map(systemStreamNames => { - Util.getSystemStreamFromNames(systemStreamNames) + Util.getSystemStreamFromNames(systemStreamNames.trim) }).toSet } else { Set[SystemStream]()
