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/e9e3b37f Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/e9e3b37f Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/e9e3b37f Branch: refs/heads/0.8.0 Commit: e9e3b37fb2cac53a0bc4aa7f1cd9187abfebebe5 Parents: d751bd7 Author: Martin Kleppmann <[email protected]> Authored: Thu Nov 6 14:26:00 2014 +0000 Committer: Martin Kleppmann <[email protected]> Committed: Thu Nov 6 14:27:27 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/e9e3b37f/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]()
