You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ca...@apache.org on 2021/10/27 23:08:12 UTC
[samza] branch master updated: Minor: fixing duplicate validation
on kafka checkpoint manager test (#1549)
This is an automated email from the ASF dual-hosted git repository.
cameronlee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git
The following commit(s) were added to refs/heads/master by this push:
new 35e9151 Minor: fixing duplicate validation on kafka checkpoint manager test (#1549)
35e9151 is described below
commit 35e9151f185c45497fce0976d2f97919be02bdee
Author: Cameron Lee <ca...@linkedin.com>
AuthorDate: Wed Oct 27 16:08:03 2021 -0700
Minor: fixing duplicate validation on kafka checkpoint manager test (#1549)
---
.../samza/test/kafka/KafkaCheckpointManagerIntegrationTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/samza-test/src/test/java/org/apache/samza/test/kafka/KafkaCheckpointManagerIntegrationTest.java b/samza-test/src/test/java/org/apache/samza/test/kafka/KafkaCheckpointManagerIntegrationTest.java
index 612647c..95aafa4 100644
--- a/samza-test/src/test/java/org/apache/samza/test/kafka/KafkaCheckpointManagerIntegrationTest.java
+++ b/samza-test/src/test/java/org/apache/samza/test/kafka/KafkaCheckpointManagerIntegrationTest.java
@@ -118,8 +118,8 @@ public class KafkaCheckpointManagerIntegrationTest extends StreamApplicationInte
assertEquals(4, PROCESSED.size());
assertEquals(1, PROCESSED.get(commitMessage(0, 0)).get());
assertEquals(1, PROCESSED.get(noCommitMessage(0, 1)).get());
- assertEquals(1, PROCESSED.get(commitMessage(0, 0)).get());
- assertEquals(1, PROCESSED.get(noCommitMessage(0, 1)).get());
+ assertEquals(1, PROCESSED.get(commitMessage(1, 0)).get());
+ assertEquals(1, PROCESSED.get(noCommitMessage(1, 1)).get());
}
/**