[GitHub] [kafka] vvcephei commented on a change in pull request #9239: Adding reverse iterator usage for sliding windows processing (extending KIP-450)

2020-09-12 Thread GitBox
vvcephei commented on a change in pull request #9239: URL: https://github.com/apache/kafka/pull/9239#discussion_r487170646 ## File path: streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java ## @@ -131,14 +157,15 @@ public void

[GitHub] [kafka] vvcephei commented on a change in pull request #9239: Adding reverse iterator usage for sliding windows processing (extending KIP-450)

2020-09-12 Thread GitBox
vvcephei commented on a change in pull request #9239: URL: https://github.com/apache/kafka/pull/9239#discussion_r486742113 ## File path: streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java ## @@ -877,4 +1003,56 @@ private voi

[GitHub] [kafka] vvcephei commented on a change in pull request #9239: Adding reverse iterator usage for sliding windows processing (extending KIP-450)

2020-09-12 Thread GitBox
vvcephei commented on a change in pull request #9239: URL: https://github.com/apache/kafka/pull/9239#discussion_r486742113 ## File path: streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java ## @@ -877,4 +1003,56 @@ private voi

[GitHub] [kafka] vvcephei commented on a change in pull request #9239: Adding reverse iterator usage for sliding windows processing (extending KIP-450)

2020-09-11 Thread GitBox
vvcephei commented on a change in pull request #9239: URL: https://github.com/apache/kafka/pull/9239#discussion_r487174400 ## File path: streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressScenarioTest.java ## @@ -493,52 +494,59 @@ public void shouldSuppor

[GitHub] [kafka] vvcephei commented on a change in pull request #9239: Adding reverse iterator usage for sliding windows processing (extending KIP-450)

2020-09-11 Thread GitBox
vvcephei commented on a change in pull request #9239: URL: https://github.com/apache/kafka/pull/9239#discussion_r487171555 ## File path: streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java ## @@ -131,14 +157,15 @@ public void

[GitHub] [kafka] vvcephei commented on a change in pull request #9239: Adding reverse iterator usage for sliding windows processing (extending KIP-450)

2020-09-11 Thread GitBox
vvcephei commented on a change in pull request #9239: URL: https://github.com/apache/kafka/pull/9239#discussion_r487170646 ## File path: streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java ## @@ -131,14 +157,15 @@ public void

[GitHub] [kafka] vvcephei commented on a change in pull request #9239: Adding reverse iterator usage for sliding windows processing (extending KIP-450)

2020-09-10 Thread GitBox
vvcephei commented on a change in pull request #9239: URL: https://github.com/apache/kafka/pull/9239#discussion_r486742113 ## File path: streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java ## @@ -877,4 +1003,56 @@ private voi