samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Branislav Cogic <b.co...@levi9.com>
Subject Review Request 52213: SAMZA-952: Add validation for broadcast inputs configured for partitions that don't exist
Date Fri, 23 Sep 2016 10:23:14 GMT

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


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message