showuon commented on a change in pull request #10409:
URL: https://github.com/apache/kafka/pull/10409#discussion_r601988722
##########
File path:
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinMultiIntegrationTest.java
##########
@@ -184,26 +186,25 @@ public void shouldInnerJoinMultiPartitionQueryable()
throws Exception {
final Set<KeyValue<Integer, String>> expectedOne = new HashSet<>();
expectedOne.add(new KeyValue<>(1,
"value1=1.33,value2=10,value3=waffle"));
- verifyKTableKTableJoin(JoinType.INNER, expectedOne, true);
+ verifyKTableKTableJoin(JoinType.INNER, expectedOne);
Review comment:
In this test suite, we only have 1 test to verify QueryableState. So,
remove unnecessary parameter and check.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
