Yuepeng Pan created FLINK-41226:
-----------------------------------
Summary: 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
[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)
