CRUNCH-606: Handle setting version correctly and removed stray System.out in test.
Project: http://git-wip-us.apache.org/repos/asf/crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/360d72a4 Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/360d72a4 Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/360d72a4 Branch: refs/heads/master Commit: 360d72a4f887505e020fdb8f99c3ccb1800693f6 Parents: 321cfef Author: Micah Whitacre <[email protected]> Authored: Mon May 23 15:13:02 2016 -0500 Committer: Micah Whitacre <[email protected]> Committed: Mon May 23 15:13:55 2016 -0500 ---------------------------------------------------------------------- crunch-kafka/pom.xml | 2 +- .../test/java/org/apache/crunch/kafka/KafkaRecordsIterableIT.java | 1 - 2 files changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/crunch/blob/360d72a4/crunch-kafka/pom.xml ---------------------------------------------------------------------- diff --git a/crunch-kafka/pom.xml b/crunch-kafka/pom.xml index a96a9b0..7d6256b 100644 --- a/crunch-kafka/pom.xml +++ b/crunch-kafka/pom.xml @@ -22,7 +22,7 @@ under the License. <parent> <groupId>org.apache.crunch</groupId> <artifactId>crunch-parent</artifactId> - <version>0.14.0-SNAPSHOT</version> + <version>0.14.1-SNAPSHOT</version> </parent> <artifactId>crunch-kafka</artifactId> http://git-wip-us.apache.org/repos/asf/crunch/blob/360d72a4/crunch-kafka/src/test/java/org/apache/crunch/kafka/KafkaRecordsIterableIT.java ---------------------------------------------------------------------- diff --git a/crunch-kafka/src/test/java/org/apache/crunch/kafka/KafkaRecordsIterableIT.java b/crunch-kafka/src/test/java/org/apache/crunch/kafka/KafkaRecordsIterableIT.java index ce97ec1..36f293f 100644 --- a/crunch-kafka/src/test/java/org/apache/crunch/kafka/KafkaRecordsIterableIT.java +++ b/crunch-kafka/src/test/java/org/apache/crunch/kafka/KafkaRecordsIterableIT.java @@ -177,7 +177,6 @@ public class KafkaRecordsIterableIT { Map<TopicPartition, Pair<Long, Long>> offsets = new HashMap<>(); for (Map.Entry<TopicPartition, Long> entry : startOffsets.entrySet()) { offsets.put(entry.getKey(), Pair.of(entry.getValue(), stopOffsets.get(entry.getKey()))); - System.out.println(entry.getKey()+ "start:"+entry.getValue()+":end:"+stopOffsets.get(entry.getKey())); } Iterable<Pair<String, String>> data = new KafkaRecordsIterable<String, String>(consumer, offsets, new Properties());
