Merge branch 'MALHAR-1970' of https://github.com/siyuanh/incubator-apex-malhar into devel-3
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/9ba99b0c Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/9ba99b0c Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/9ba99b0c Branch: refs/heads/master Commit: 9ba99b0ca3cc556f8710393b2ee026bfbf21bb84 Parents: 8b37ee3 c464f06 Author: Thomas Weise <[email protected]> Authored: Wed Jan 13 23:53:27 2016 -0800 Committer: Thomas Weise <[email protected]> Committed: Wed Jan 13 23:53:27 2016 -0800 ---------------------------------------------------------------------- .../kafka/AbstractKafkaInputOperator.java | 4 +++- .../malhar/kafka/AbstractKafkaPartitioner.java | 7 +++--- .../apex/malhar/kafka/OneToManyPartitioner.java | 4 ++-- .../malhar/kafka/KafkaInputOperatorTest.java | 23 ++++++++++++-------- 4 files changed, 23 insertions(+), 15 deletions(-) ----------------------------------------------------------------------
