You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@crunch.apache.org by mk...@apache.org on 2016/05/23 20:21:50 UTC
[3/3] crunch git commit: CRUNCH-606: Handle setting version correctly
and removed stray System.out in test.
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 <mk...@gmail.com>
Authored: Mon May 23 15:13:02 2016 -0500
Committer: Micah Whitacre <mk...@gmail.com>
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());