-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/31520/
-----------------------------------------------------------
(Updated Feb. 27, 2015, 5:59 p.m.)
Review request for samza.
Bugs: SAMZA-579
https://issues.apache.org/jira/browse/SAMZA-579
Repository: samza
Description (updated)
-------
fix test
clean up droppedTopicAndPartitions slightly
misc formatting cleanup from SAMZA-394. fix bug in KafkaSystemConsumer where we
weren't actually adding to droppedTopicAndPartitions
make refreshBrokers thread safe
temporarily drop ssps without metadata, and retry later.
Diffs (updated)
-----
samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala
e3b9d304353981abc4d9760ccb078ff6dddcbb19
samza-kafka/src/main/scala/org/apache/samza/system/kafka/BrokerProxy.scala
cc0a4c6913ac7a08d520bb485146b1488f43ef98
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumer.scala
4918e3e88c20f3db11f5ae651ae104cf63b3d592
samza-kafka/src/main/scala/org/apache/samza/system/kafka/MessageSink.scala
48ad66eb07e2b5743e4f0cf648c67b48dc05e067
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestBrokerProxy.scala
6f05f3c028cf77dbee9186d3463b1999c70dac43
samza-test/src/main/java/org/apache/samza/test/integration/join/Checker.java
1fef1eaa6266f638cf9f70c982f7d5f99f5c535c
samza-test/src/main/java/org/apache/samza/test/integration/join/Emitter.java
e958b51610d6927121bacffdf6d30efc13b5f444
samza-test/src/main/java/org/apache/samza/test/integration/join/Joiner.java
cb3083832986d5028fdfb804bc4e8c8e61b6c60b
Diff: https://reviews.apache.org/r/31520/diff/
Testing
-------
Thanks,
Chris Riccomini
