Repository: samza Updated Branches: refs/heads/master 947472a0b -> 479932242
SAMZA-959 allow empty serde for SystemConsumer Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/47993224 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/47993224 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/47993224 Branch: refs/heads/master Commit: 47993224273b00d402179dbae57e637619634671 Parents: 947472a Author: Boris Shkolnik <bor...@apache.org> Authored: Tue Jun 7 12:05:27 2016 -0700 Committer: Navina Ramesh <nram...@linkedin.com> Committed: Tue Jun 7 12:05:27 2016 -0700 ---------------------------------------------------------------------- .../main/scala/org/apache/samza/container/SamzaContainer.scala | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/47993224/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala ---------------------------------------------------------------------- diff --git a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala index cf3c4c0..951d479 100644 --- a/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala +++ b/samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala @@ -230,8 +230,10 @@ object SamzaContainer extends Logging { */ val buildSystemSerdeMap = (getSerdeName: (String) => Option[String]) => { systemNames - .filter(getSerdeName(_).isDefined) - .map(systemName => { + .filter( sn => { + val serde = getSerdeName(sn) + serde.isDefined && !serde.get.equals("") + }).map(systemName => { val serdeName = getSerdeName(systemName).get val serde = serdes.getOrElse(serdeName, throw new SamzaException("No class defined for serde: %s." format serdeName)) (systemName, serde)
