You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@samza.apache.org by Branislav Cogic <b....@levi9.com> on 2016/09/23 10:23:14 UTC
Review Request 52213: SAMZA-952: Add validation for broadcast inputs
configured for partitions that don't exist
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/52213/
-----------------------------------------------------------
Review request for samza.
Bugs: SAMZA-952
https://issues.apache.org/jira/browse/SAMZA-952
Repository: samza
Description
-------
Added validation for broadcast inputs and a meaningful error messages when configured broadcast inputs doesn't match metadata and fail validation.
Diffs
-----
samza-core/src/main/scala/org/apache/samza/coordinator/JobCoordinator.scala ba38b5cfa4e61b5513ce38dd2be32438b62cd7ce
Diff: https://reviews.apache.org/r/52213/diff/
Testing
-------
Ran
./gradlew clean build
./gradlew checkstyleMain checkstyleTest
and tested manually with kafka
Thanks,
Branislav Cogic