[
https://issues.apache.org/jira/browse/FLINK-41226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18132541#comment-18132541
]
Yuepeng Pan commented on FLINK-41226:
-------------------------------------
Hi, [~pnowojski] [~nkruber]
Could you help take a look ?
Thanks
> Benchmark StreamNetworkThroughputBenchmarkExecutor.networkThroughput failed
> ---------------------------------------------------------------------------
>
> Key: FLINK-41226
> URL: https://issues.apache.org/jira/browse/FLINK-41226
> Project: Flink
> Issue Type: Bug
> Components: Benchmarks
> Affects Versions: 2.4.0
> Reporter: Yuepeng Pan
> Priority: Major
>
> [https://github.com/apache/flink-benchmarks/actions/runs/40335782988/job/121616829794]
> # Benchmark:
> org.apache.flink.benchmark.StreamNetworkThroughputBenchmarkExecutor.networkThroughput
>
> # Parameters: (channelsFlushTimeout = 1000,100ms,OpenSSL)
> # Run progress: 84.48% complete, ETA 00:03:18
> # Fork: 1 of 1
> org.apache.flink.runtime.io.network.partition.consumer.PartitionConnectionException:
> Connection for partition
> 3ad31d26d8b46cf9bbc0d67005dce0a3#-1@c68a0ff2e0bf51e1ea0705e0331ff80f_00000000000000000000000000000000_0_0
> not reachable.
> at
> org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.requestSubpartitions(RemoteInputChannel.java:402)
>
> at
> org.apache.flink.streaming.runtime.io.benchmark.SingleInputGateBenchmarkFactory$TestRemoteInputChannel.requestSubpartitions(SingleInputGateBenchmarkFactory.java:194)
>
> at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.internalRequestPartitions(SingleInputGate.java:430)
>
> at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.requestPartitions(SingleInputGate.java:356)
>
> at
> org.apache.flink.runtime.taskmanager.InputGateWithMetrics.requestPartitions(InputGateWithMetrics.java:135)
>
> at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.requestPartitions(UnionInputGate.java:368)
>
> at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.requestPartitions(UnionInputGate.java:362)
>
> at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:108)
>
> at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:48)
>
> at
> org.apache.flink.streaming.runtime.io.benchmark.SerializingLongReceiver.readRecords(SerializingLongReceiver.java:45)
>
> at
> org.apache.flink.streaming.runtime.io.benchmark.ReceiverThread.go(ReceiverThread.java:78)
>
> at org.apache.flink.core.testutils.CheckedThread.run(CheckedThread.java:67)
> Caused by:
> org.apache.flink.runtime.io.network.netty.exception.RemoteTransportException:
> Connecting to remote task manager 'localhost/127.0.0.1:36117 [
> 4da5c1bd3ac1fe2214f465773beb5f9c ] ' has failed. This might indicate that the
> remote task manager has been lost.
> at
> org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory.connect(PartitionRequestClientFactory.java:163)
>
> at
> org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory.connectWithRetries(PartitionRequestClientFactory.java:126)
>
> at
> org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory.createPartitionRequestClient(PartitionRequestClientFactory.java:87)
>
> at
> org.apache.flink.runtime.io.network.netty.NettyConnectionManager.createPartitionRequestClient(NettyConnectionManager.java:89)
>
> at
> org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.requestSubpartitions(RemoteInputChannel.java:398)
>
> ... 11 more
> Caused by:
> org.apache.flink.shaded.netty4.io.netty.channel.StacklessClosedChannelException
>
> at
> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AbstractUnsafe.ensureOpen(ChannelPromise)(Unknown
> Source)
> Suppressed: java.util.concurrent.CompletionException: Rethrowing promise
> failure cause
> at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.rethrowIfFailed(DefaultPromise.java:686)
>
> at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.sync(DefaultPromise.java:420)
>
> at
> org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPromise.sync(DefaultChannelPromise.java:119)
>
> at
> org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelPromise.sync(DefaultChannelPromise.java:30)
>
> at
> org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory.connect(PartitionRequestClientFactory.java:149)
>
> at
> org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory.connectWithRetries(PartitionRequestClientFactory.java:126)
>
> at
> org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory.createPartitionRequestClient(PartitionRequestClientFactory.java:87)
>
> at
> org.apache.flink.runtime.io.network.netty.NettyConnectionManager.createPartitionRequestClient(NettyConnectionManager.java:89)
>
> at
> org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.requestSubpartitions(RemoteInputChannel.java:398)
>
> at
> org.apache.flink.streaming.runtime.io.benchmark.SingleInputGateBenchmarkFactory$TestRemoteInputChannel.requestSubpartitions(SingleInputGateBenchmarkFactory.java:194)
>
> at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.internalRequestPartitions(SingleInputGate.java:430)
>
> at
> org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.requestPartitions(SingleInputGate.java:356)
>
> at
> org.apache.flink.runtime.taskmanager.InputGateWithMetrics.requestPartitions(InputGateWithMetrics.java:135)
>
> at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.requestPartitions(UnionInputGate.java:368)
>
> at
> org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate.requestPartitions(UnionInputGate.java:362)
>
> at
> org.apache.flink.runtime.io.network.api.reader.AbstractRecordReader.getNextRecord(AbstractRecordReader.java:108)
>
> at
> org.apache.flink.runtime.io.network.api.reader.MutableRecordReader.next(MutableRecordReader.java:48)
>
> at
> org.apache.flink.streaming.runtime.io.benchmark.SerializingLongReceiver.readRecords(SerializingLongReceiver.java:45)
>
> at
> org.apache.flink.streaming.runtime.io.benchmark.ReceiverThread.go(ReceiverThread.java:78)
>
> at org.apache.flink.core.testutils.CheckedThread.run(CheckedThread.java:67)
>
>
>
>
>
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
