[ https://issues.apache.org/jira/browse/BEAM-9470?focusedWorklogId=401227&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-401227 ]
ASF GitHub Bot logged work on BEAM-9470: ---------------------------------------- Author: ASF GitHub Bot Created on: 11/Mar/20 06:11 Start Date: 11/Mar/20 06:11 Worklog Time Spent: 10m Work Description: jfarr commented on pull request #11090: [BEAM-9470] :sdks:java:io:kinesis:test is flaky URL: https://github.com/apache/beam/pull/11090#discussion_r390762635 ########## File path: sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/ShardReadersPoolTest.java ########## @@ -324,10 +325,15 @@ public void shouldCallRateLimitPolicy() } } + ArgumentCaptor<List<KinesisRecord>> recordsCaptor = ArgumentCaptor.forClass(List.class); + verify(customRateLimitPolicy, atLeastOnce()).onSuccess(recordsCaptor.capture()); + List<List<KinesisRecord>> capturedRecords = recordsCaptor.getAllValues(); + assertThat(capturedRecords).contains( + ImmutableList.of(a, b), + singletonList(c), + singletonList(d), + Collections.emptyList() + ); verify(customRateLimitPolicy).onThrottle(same(e)); - verify(customRateLimitPolicy).onSuccess(eq(ImmutableList.of(a, b))); - verify(customRateLimitPolicy).onSuccess(eq(singletonList(c))); - verify(customRateLimitPolicy).onSuccess(eq(singletonList(d))); Review comment: Thanks, that's how I thought Mockito.verify() worked too but this made me doubt it. I didn't do any detailed testing, though, so thanks for taking the time to validate. I'm honestly at a loss for what could be causing intermittent failures then. All I can say is this version of the test is semantically equivalent and might not be subject to the same failure mode. I have not been able to reproduce the failure myself. ---------------------------------------------------------------- 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 Issue Time Tracking ------------------- Worklog Id: (was: 401227) Time Spent: 1h 40m (was: 1.5h) > :sdks:java:io:kinesis:test is flaky > ----------------------------------- > > Key: BEAM-9470 > URL: https://issues.apache.org/jira/browse/BEAM-9470 > Project: Beam > Issue Type: Test > Components: io-java-kinesis > Reporter: Etienne Chauchot > Assignee: Jonothan Farr > Priority: Major > Time Spent: 1h 40m > Remaining Estimate: 0h > > [https://scans.gradle.com/s/b4jmmu72ku5jc/console-log?task=:sdks:java:io:kinesis:test] -- This message was sent by Atlassian Jira (v8.3.4#803005)