----------------------------------------------------------- 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