You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2018/01/23 23:21:43 UTC
[kafka] branch trunk updated: KAFKA-6461
TableTableJoinIntegrationTest is unstable if caching is enabled (#4451)
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new faafdbe KAFKA-6461 TableTableJoinIntegrationTest is unstable if caching is enabled (#4451)
faafdbe is described below
commit faafdbe014ca6ac7e253be6934f78885642666ed
Author: tedyu <yu...@gmail.com>
AuthorDate: Tue Jan 23 15:21:40 2018 -0800
KAFKA-6461 TableTableJoinIntegrationTest is unstable if caching is enabled (#4451)
Reviewers: Guozhang Wang <wa...@gmail.com>, Matthias J. Sax <mj...@apache.org>
---
.../apache/kafka/streams/integration/TableTableJoinIntegrationTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java
index f3eceb0..b5e6fcb 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/TableTableJoinIntegrationTest.java
@@ -79,7 +79,7 @@ public class TableTableJoinIntegrationTest extends AbstractJoinIntegrationTest {
@Override
public void apply(final Long key, final String value) {
numRecordsExpected++;
- if (value.equals(expected)) {
+ if (expected.equals(value)) {
boolean ret = finalResultReached.compareAndSet(false, true);
if (!ret) {
--
To stop receiving notification emails like this one, please contact
guozhang@apache.org.