Skip to content

Commit 42274c7

Browse files
committed
Fix testAtMostOnceWithFailure test case
1 parent e00fe68 commit 42274c7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/source/JdbcSourceStreamRelatedITCase.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -197,7 +197,7 @@ void testAtMostOnceWithFailure(@InjectClusterClient ClusterClient<?> client) thr
197197
env,
198198
() ->
199199
Math.abs(collectedRecords.size() - testEntries.size())
200-
<= DATA_NUM_PER_SECOND_SPAN_SPLIT);
200+
<= DATA_NUM_PER_SECOND_SPAN_SPLIT * TESTING_PARALLELISM);
201201

202202
assertThat(testEntries)
203203
.hasSizeGreaterThanOrEqualTo(collectedRecords.size())

0 commit comments

Comments
 (0)