[
https://issues.apache.org/jira/browse/FLINK-39105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18059338#comment-18059338
]
Mate Czagany commented on FLINK-39105:
--------------------------------------
[~martijnvisser]
I think this issue comes from the networking level of Azure CI rather than the
Netty upgrade, I've already tried fixing this (before Netty upgrade even) and
saw some improvements since FLINK-38369.
I agree with relaxing the test and accepting `SocketException` instead, I don't
see much value added by this test anyways to be honest, it feels like we are
just testing Netty's timeout mechanics.
If you want I can take this task, just let me know.
> RestClientTest.testConnectionTimeout fails with different expected exception
> ----------------------------------------------------------------------------
>
> Key: FLINK-39105
> URL: https://issues.apache.org/jira/browse/FLINK-39105
> Project: Flink
> Issue Type: Bug
> Components: Runtime / REST
> Affects Versions: 2.3.0
> Reporter: Martijn Visser
> Priority: Major
>
> {code:java}
> 2026-02-17T21:12:14.5160184Z Feb 17 21:12:14 21:12:14.514 [ERROR] Failures:
> 2026-02-17T21:12:14.5160957Z Feb 17 21:12:14 21:12:14.514 [ERROR]
> RestClientTest.testConnectionTimeout:116
> 2026-02-17T21:12:14.5161589Z Feb 17 21:12:14 Expecting a throwable with cause
> being an instance of:
> 2026-02-17T21:12:14.5162214Z Feb 17 21:12:14
> org.apache.flink.shaded.netty4.io.netty.channel.ConnectTimeoutException
> 2026-02-17T21:12:14.5162805Z Feb 17 21:12:14 but was an instance of:
> 2026-02-17T21:12:14.5163402Z Feb 17 21:12:14
> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel.AnnotatedSocketException
> 2026-02-17T21:12:14.5164013Z Feb 17 21:12:14 Throwable that failed the check:
> 2026-02-17T21:12:14.5164439Z Feb 17 21:12:14
> 2026-02-17T21:12:14.5165159Z Feb 17 21:12:14
> java.util.concurrent.ExecutionException:
> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedSocketException:
> Network is unreachable: /192.0.2.1:80
> 2026-02-17T21:12:14.5169687Z Feb 17 21:12:14 at
> java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
> 2026-02-17T21:12:14.5171318Z Feb 17 21:12:14 at
> java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2073)
> 2026-02-17T21:12:14.5173314Z Feb 17 21:12:14 at
> org.apache.flink.core.testutils.FlinkCompletableFutureAssert.assertEventuallyFails(FlinkCompletableFutureAssert.java:161)
> 2026-02-17T21:12:14.5174993Z Feb 17 21:12:14 at
> org.apache.flink.core.testutils.FlinkCompletableFutureAssert.eventuallyFails(FlinkCompletableFutureAssert.java:123)
> 2026-02-17T21:12:14.5176835Z Feb 17 21:12:14 at
> org.apache.flink.core.testutils.FlinkCompletableFutureAssert.eventuallyFailsWith(FlinkCompletableFutureAssert.java:135)
> 2026-02-17T21:12:14.5178430Z Feb 17 21:12:14 at
> org.apache.flink.runtime.rest.RestClientTest.testConnectionTimeout(RestClientTest.java:115)
> 2026-02-17T21:12:14.5179800Z Feb 17 21:12:14 at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2026-02-17T21:12:14.5181323Z Feb 17 21:12:14 at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
> 2026-02-17T21:12:14.5182850Z Feb 17 21:12:14 at
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2026-02-17T21:12:14.5184227Z Feb 17 21:12:14 at
> java.base/java.lang.reflect.Method.invoke(Method.java:568)
> 2026-02-17T21:12:14.5185910Z Feb 17 21:12:14 at
> org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:767)
> 2026-02-17T21:12:14.5187362Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
> 2026-02-17T21:12:14.5188976Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
> 2026-02-17T21:12:14.5190734Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
> 2026-02-17T21:12:14.5192259Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
> 2026-02-17T21:12:14.5193856Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:86)
> 2026-02-17T21:12:14.5195811Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
> 2026-02-17T21:12:14.5197727Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
> 2026-02-17T21:12:14.5199541Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
> 2026-02-17T21:12:14.5201372Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
> 2026-02-17T21:12:14.5202984Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
> 2026-02-17T21:12:14.5204566Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
> 2026-02-17T21:12:14.5206367Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
> 2026-02-17T21:12:14.5207979Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
> 2026-02-17T21:12:14.5209714Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$8(TestMethodTestDescriptor.java:217)
> 2026-02-17T21:12:14.5211462Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2026-02-17T21:12:14.5213443Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:213)
> 2026-02-17T21:12:14.5215081Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:138)
> 2026-02-17T21:12:14.5217094Z Feb 17 21:12:14 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:68)
> 2026-02-17T21:12:14.5218733Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:156)
> 2026-02-17T21:12:14.5220284Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2026-02-17T21:12:14.5221861Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:146)
> 2026-02-17T21:12:14.5223277Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2026-02-17T21:12:14.5224751Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:144)
> 2026-02-17T21:12:14.5226355Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2026-02-17T21:12:14.5227864Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:143)
> 2026-02-17T21:12:14.5229273Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:100)
> 2026-02-17T21:12:14.5231144Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.exec(ForkJoinPoolHierarchicalTestExecutorService.java:274)
> 2026-02-17T21:12:14.5233164Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.execSync(ForkJoinPoolHierarchicalTestExecutorService.java:247)
> 2026-02-17T21:12:14.5235172Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.executeSync(ForkJoinPoolHierarchicalTestExecutorService.java:194)
> 2026-02-17T21:12:14.5237230Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:166)
> 2026-02-17T21:12:14.5238943Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:160)
> 2026-02-17T21:12:14.5240499Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2026-02-17T21:12:14.5242006Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:146)
> 2026-02-17T21:12:14.5243416Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2026-02-17T21:12:14.5244843Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:144)
> 2026-02-17T21:12:14.5246545Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2026-02-17T21:12:14.5248103Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:143)
> 2026-02-17T21:12:14.5249596Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:100)
> 2026-02-17T21:12:14.5251490Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.exec(ForkJoinPoolHierarchicalTestExecutorService.java:274)
> 2026-02-17T21:12:14.5253601Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.execSync(ForkJoinPoolHierarchicalTestExecutorService.java:247)
> 2026-02-17T21:12:14.5256128Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:159)
> 2026-02-17T21:12:14.5258008Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:160)
> 2026-02-17T21:12:14.5259803Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2026-02-17T21:12:14.5261506Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:146)
> 2026-02-17T21:12:14.5262993Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2026-02-17T21:12:14.5264505Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:144)
> 2026-02-17T21:12:14.5266294Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2026-02-17T21:12:14.5267870Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:143)
> 2026-02-17T21:12:14.5269403Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:100)
> 2026-02-17T21:12:14.5271374Z Feb 17 21:12:14 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.exec(ForkJoinPoolHierarchicalTestExecutorService.java:274)
> 2026-02-17T21:12:14.5273112Z Feb 17 21:12:14 at
> java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373)
> 2026-02-17T21:12:14.5274500Z Feb 17 21:12:14 at
> java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
> 2026-02-17T21:12:14.5276006Z Feb 17 21:12:14 at
> java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
> 2026-02-17T21:12:14.5277349Z Feb 17 21:12:14 at
> java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
> 2026-02-17T21:12:14.5278693Z Feb 17 21:12:14 at
> java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
> 2026-02-17T21:12:14.5280315Z Feb 17 21:12:14 Caused by:
> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedSocketException:
> Network is unreachable: /192.0.2.1:80
> 2026-02-17T21:12:14.5281662Z Feb 17 21:12:14 Caused by:
> java.net.SocketException: Network is unreachable
> 2026-02-17T21:12:14.5282657Z Feb 17 21:12:14 at
> java.base/sun.nio.ch.Net.pollConnect(Native Method)
> 2026-02-17T21:12:14.5283748Z Feb 17 21:12:14 at
> java.base/sun.nio.ch.Net.pollConnectNow(Net.java:672)
> 2026-02-17T21:12:14.5284937Z Feb 17 21:12:14 at
> java.base/sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:946)
> 2026-02-17T21:12:14.5286801Z Feb 17 21:12:14 at
> org.apache.flink.shaded.netty4.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:330)
> 2026-02-17T21:12:14.5288437Z Feb 17 21:12:14 at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:384)
> 2026-02-17T21:12:14.5290264Z Feb 17 21:12:14 at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.handle(AbstractNioChannel.java:432)
> 2026-02-17T21:12:14.5291913Z Feb 17 21:12:14 at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioIoHandler$DefaultNioRegistration.handle(NioIoHandler.java:381)
> 2026-02-17T21:12:14.5293525Z Feb 17 21:12:14 at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioIoHandler.processSelectedKey(NioIoHandler.java:587)
> 2026-02-17T21:12:14.5295099Z Feb 17 21:12:14 at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioIoHandler.processSelectedKeysOptimized(NioIoHandler.java:562)
> 2026-02-17T21:12:14.5296819Z Feb 17 21:12:14 at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioIoHandler.processSelectedKeys(NioIoHandler.java:503)
> 2026-02-17T21:12:14.5298528Z Feb 17 21:12:14 at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioIoHandler.run(NioIoHandler.java:475)
> 2026-02-17T21:12:14.5300089Z Feb 17 21:12:14 at
> org.apache.flink.shaded.netty4.io.netty.channel.SingleThreadIoEventLoop.runIo(SingleThreadIoEventLoop.java:225)
> 2026-02-17T21:12:14.5301808Z Feb 17 21:12:14 at
> org.apache.flink.shaded.netty4.io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:196)
> 2026-02-17T21:12:14.5303396Z Feb 17 21:12:14 at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1193)
> 2026-02-17T21:12:14.5304987Z Feb 17 21:12:14 at
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> 2026-02-17T21:12:14.5306379Z Feb 17 21:12:14 at
> java.base/java.lang.Thread.run(Thread.java:833)
> 2026-02-17T21:12:14.5307189Z Feb 17 21:12:14
> 2026-02-17T21:12:14.5307850Z Feb 17 21:12:14 21:12:14.514 [INFO]
> 2026-02-17T21:12:14.5308801Z Feb 17 21:12:14 21:12:14.514 [ERROR] Tests run:
> 109671, Failures: 1, Errors: 0, Skipped: 354
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=72464&view=logs&j=0da23115-68bb-5dcd-192c-bd4c8adebde1&t=1ffc5ec2-7913-50ff-0177-3fca16f1b8f0&l=79996
--
This message was sent by Atlassian Jira
(v8.20.10#820010)