Skip to content

Commit b366c19

Browse files
authored
MINOR: fix test after upstream change (#478)
Upstream fix: apache/kafka#14426
1 parent 43fde6b commit b366c19

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/test/java/io/confluent/examples/streams/StreamToStreamJoinIntegrationTest.java

+1
Original file line numberDiff line numberDiff line change
@@ -134,6 +134,7 @@ public void shouldJoinTwoStreams() {
134134
impressionInput.pipeKeyValueList(inputAdImpressions);
135135
clickInput.pipeKeyValueList(inputAdClicks);
136136
// Flush result
137+
topologyTestDriver.advanceWallClockTime(Duration.ofSeconds(1L));
137138
impressionInput.pipeInput("dummy", "dummy", currentMs + windowSize.toMillis() * 3);
138139

139140
//

0 commit comments

Comments
 (0)