You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by cr...@apache.org on 2015/04/08 01:26:00 UTC
[28/36] samza git commit: SAMZA-620;
torture test checker should start from oldest offset
SAMZA-620; torture test checker should start from oldest offset
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/8aeec8de
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/8aeec8de
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/8aeec8de
Branch: refs/heads/samza-sql
Commit: 8aeec8defcfb62cd805425811520ca6474973126
Parents: d20ae5c
Author: Chris Riccomini <cr...@apache.org>
Authored: Fri Mar 27 11:04:09 2015 -0700
Committer: Chris Riccomini <cr...@apache.org>
Committed: Fri Mar 27 11:04:09 2015 -0700
----------------------------------------------------------------------
samza-test/src/main/config/join/checker.samza | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/8aeec8de/samza-test/src/main/config/join/checker.samza
----------------------------------------------------------------------
diff --git a/samza-test/src/main/config/join/checker.samza b/samza-test/src/main/config/join/checker.samza
index ab557d9..c0e3df7 100644
--- a/samza-test/src/main/config/join/checker.samza
+++ b/samza-test/src/main/config/join/checker.samza
@@ -20,6 +20,7 @@
job.name=checker
systems.kafka.partitioner.class=org.apache.samza.test.integration.join.EpochPartitioner
+systems.kafka.samza.offset.default=oldest
# Task
task.class=org.apache.samza.test.integration.join.Checker