[
https://issues.apache.org/jira/browse/FLINK-24133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411367#comment-17411367
]
Anton Kalashnikov commented on FLINK-24133:
-------------------------------------------
Unfortunately, logs look pretty fragmented(I don't see the part of the logs
related to this test or this test class). But I see in the test that we request
the available port(`NetUtils.getAvailablePort()`) and then we try to connect to
this port and assume that we will fail because nobody listens to this port. But
since we don't lock this port anyhow I assume that it is possible if somebody
else from another test starts to listen to this port and our connection would
be successful which can exactly lead to the problem which we see.
Perhaps, it is not a bad idea to rewrite this code in such a way that we create
our own server which would fail all input requests explicitly instead of
relying on the random unbusy port.
> PartitionRequestClientFactoryTest.testThrowsWhenNetworkFailure fails on Azure
> -----------------------------------------------------------------------------
>
> Key: FLINK-24133
> URL: https://issues.apache.org/jira/browse/FLINK-24133
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Network
> Affects Versions: 1.14.0, 1.12.5, 1.13.2, 1.15.0
> Reporter: Till Rohrmann
> Priority: Major
> Labels: test-stability
> Fix For: 1.14.0, 1.12.6, 1.13.3
>
>
> The test {{PartitionRequestClientFactoryTest.testThrowsWhenNetworkFailure}}
> fails on Azure with
> {code}
> 2021-09-01T17:01:08.2338015Z Sep 01 17:01:08 [ERROR] Tests run: 7, Failures:
> 1, Errors: 0, Skipped: 0, Time elapsed: 1.465 s <<< FAILURE! - in
> org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactoryTest
> 2021-09-01T17:01:08.2341002Z Sep 01 17:01:08 [ERROR]
> testThrowsWhenNetworkFailure Time elapsed: 0.02 s <<< FAILURE!
> 2021-09-01T17:01:08.2341956Z Sep 01 17:01:08 java.lang.AssertionError:
> Expected exception:
> org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException
> 2021-09-01T17:01:08.2342854Z Sep 01 17:01:08 at
> org.junit.internal.runners.statements.ExpectException.evaluate(ExpectException.java:34)
> 2021-09-01T17:01:08.2343408Z Sep 01 17:01:08 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2021-09-01T17:01:08.2343916Z Sep 01 17:01:08 at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2021-09-01T17:01:08.2348096Z Sep 01 17:01:08 at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2021-09-01T17:01:08.2483997Z Sep 01 17:01:08 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2021-09-01T17:01:08.2484833Z Sep 01 17:01:08 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2021-09-01T17:01:08.2485521Z Sep 01 17:01:08 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2021-09-01T17:01:08.2486189Z Sep 01 17:01:08 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2021-09-01T17:01:08.2486892Z Sep 01 17:01:08 at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2021-09-01T17:01:08.2487565Z Sep 01 17:01:08 at
> org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2021-09-01T17:01:08.2488276Z Sep 01 17:01:08 at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2021-09-01T17:01:08.2488999Z Sep 01 17:01:08 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2021-09-01T17:01:08.2489818Z Sep 01 17:01:08 at
> org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> 2021-09-01T17:01:08.2490535Z Sep 01 17:01:08 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:137)
> 2021-09-01T17:01:08.2491159Z Sep 01 17:01:08 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:115)
> 2021-09-01T17:01:08.2491860Z Sep 01 17:01:08 at
> org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:43)
> 2021-09-01T17:01:08.2492760Z Sep 01 17:01:08 at
> java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> 2021-09-01T17:01:08.2493506Z Sep 01 17:01:08 at
> java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
> 2021-09-01T17:01:08.2494192Z Sep 01 17:01:08 at
> java.util.Iterator.forEachRemaining(Iterator.java:116)
> 2021-09-01T17:01:08.2494910Z Sep 01 17:01:08 at
> java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801)
> 2021-09-01T17:01:08.2495889Z Sep 01 17:01:08 at
> java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
> 2021-09-01T17:01:08.2496648Z Sep 01 17:01:08 at
> java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
> 2021-09-01T17:01:08.2497416Z Sep 01 17:01:08 at
> java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
> 2021-09-01T17:01:08.2498201Z Sep 01 17:01:08 at
> java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
> 2021-09-01T17:01:08.2498950Z Sep 01 17:01:08 at
> java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> 2021-09-01T17:01:08.2499767Z Sep 01 17:01:08 at
> java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
> 2021-09-01T17:01:08.2500567Z Sep 01 17:01:08 at
> org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:82)
> 2021-09-01T17:01:08.2501381Z Sep 01 17:01:08 at
> org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:73)
> 2021-09-01T17:01:08.2502189Z Sep 01 17:01:08 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:220)
> 2021-09-01T17:01:08.2503111Z Sep 01 17:01:08 at
> org.junit.platform.launcher.core.DefaultLauncher.lambda$execute$6(DefaultLauncher.java:188)
> 2021-09-01T17:01:08.2503992Z Sep 01 17:01:08 at
> org.junit.platform.launcher.core.DefaultLauncher.withInterceptedStreams(DefaultLauncher.java:202)
> 2021-09-01T17:01:08.2504826Z Sep 01 17:01:08 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:181)
> 2021-09-01T17:01:08.2505601Z Sep 01 17:01:08 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:128)
> 2021-09-01T17:01:08.2506481Z Sep 01 17:01:08 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:150)
> 2021-09-01T17:01:08.2507438Z Sep 01 17:01:08 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:120)
> 2021-09-01T17:01:08.2508345Z Sep 01 17:01:08 at
> org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
> 2021-09-01T17:01:08.2509480Z Sep 01 17:01:08 at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
> 2021-09-01T17:01:08.2510230Z Sep 01 17:01:08 at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
> 2021-09-01T17:01:08.2510986Z Sep 01 17:01:08 at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=23335&view=logs&j=0da23115-68bb-5dcd-192c-bd4c8adebde1&t=24c3384f-1bcb-57b3-224f-51bf973bbee8&l=9745
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
