[samza] branch master updated: Minor: fixing duplicate validation on kafka checkpoint manager test (#1549)

[cameronlee]

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());
   }
 
   /**