Browse Source

MINOR: improve QueryableStateIntegrationTest (#5988)

Fix test Comparators.

Reviewers: Guozhang Wang <wangguoz@gmail.com>
0.10.1
Matthias J. Sax 6 years ago committed by Guozhang Wang
parent
commit
9bdd8d6b60
  1. 6
      streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java

6
streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java

@ -152,7 +152,8 @@ public class QueryableStateIntegrationTest { @@ -152,7 +152,8 @@ public class QueryableStateIntegrationTest {
@Override
public int compare(final KeyValue<String, String> o1,
final KeyValue<String, String> o2) {
return o1.key.compareTo(o2.key);
final int keyComparison = o1.key.compareTo(o2.key);
return keyComparison != 0 ? keyComparison : o1.value.compareTo(o2.value);
}
};
stringLongComparator = new Comparator<KeyValue<String, Long>>() {
@ -160,7 +161,8 @@ public class QueryableStateIntegrationTest { @@ -160,7 +161,8 @@ public class QueryableStateIntegrationTest {
@Override
public int compare(final KeyValue<String, Long> o1,
final KeyValue<String, Long> o2) {
return o1.key.compareTo(o2.key);
final int keyComparison = o1.key.compareTo(o2.key);
return keyComparison != 0 ? keyComparison : o1.value.compareTo(o2.value);
}
};
inputValues = Arrays.asList(

Loading…
Cancel
Save