From 4a83dfc3927af6f390b95a576f63decd98c786c4 Mon Sep 17 00:00:00 2001 From: "Matthias J. Sax" Date: Thu, 10 Dec 2020 17:53:20 -0800 Subject: [PATCH 1/2] MINOR: fix error message --- .../streams/integration/EosBetaUpgradeIntegrationTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java index 22c5cf00ba01d..052941e730a25 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java @@ -1045,8 +1045,8 @@ private void checkResultPerKey(final List> result, assertThat(getAllRecordPerKey(key, result), equalTo(getAllRecordPerKey(key, expectedResult))); } catch (final AssertionError error) { throw new AssertionError( - "expected result: " + expectedResult.stream().map(KeyValue::toString).reduce("", (kv, str) -> str.isEmpty() ? kv : str + ", " + kv) + - "\nreceived records: " + result.stream().map(KeyValue::toString).reduce("", (kv, str) -> str.isEmpty() ? kv : str + ", " + kv), + "expected result: " + expectedResult.stream().map(KeyValue::toString).reduce("", (str, kv) -> str.isEmpty() ? kv : str + ", " + kv) + + "\nreceived records: " + result.stream().map(KeyValue::toString).reduce("", (str, kv) -> str.isEmpty() ? kv : str + ", " + kv), error ); } From 2186d53624884e3fe57b08ad6d70da67f3f3fdb9 Mon Sep 17 00:00:00 2001 From: "Matthias J. Sax" Date: Wed, 16 Dec 2020 16:31:29 -0800 Subject: [PATCH 2/2] Github comments --- .../streams/integration/EosBetaUpgradeIntegrationTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java index 052941e730a25..30f44dce5a01e 100644 --- a/streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java +++ b/streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java @@ -1045,8 +1045,8 @@ private void checkResultPerKey(final List> result, assertThat(getAllRecordPerKey(key, result), equalTo(getAllRecordPerKey(key, expectedResult))); } catch (final AssertionError error) { throw new AssertionError( - "expected result: " + expectedResult.stream().map(KeyValue::toString).reduce("", (str, kv) -> str.isEmpty() ? kv : str + ", " + kv) + - "\nreceived records: " + result.stream().map(KeyValue::toString).reduce("", (str, kv) -> str.isEmpty() ? kv : str + ", " + kv), + "expected result: " + expectedResult.stream().map(KeyValue::toString).collect(Collectors.joining(", ")) + + "\nreceived records: " + result.stream().map(KeyValue::toString).collect(Collectors.joining(", ")), error ); }