-
Notifications
You must be signed in to change notification settings - Fork 13.8k
[FLINK-31642][network] Introduce the MemoryTierConsumerAgent #22733
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
a140e71 to
ba06975
Compare
...he/flink/runtime/io/network/partition/hybrid/tiered/tier/memory/MemoryTierConsumerAgent.java
Outdated
Show resolved
Hide resolved
...he/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageConsumerClient.java
Outdated
Show resolved
Hide resolved
1b8c20d to
1ce2cc2
Compare
...he/flink/runtime/io/network/partition/hybrid/tiered/tier/memory/MemoryTierConsumerAgent.java
Outdated
Show resolved
Hide resolved
...he/flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStorageNettyServiceImpl.java
Outdated
Show resolved
Hide resolved
...he/flink/runtime/io/network/partition/hybrid/tiered/tier/memory/MemoryTierConsumerAgent.java
Outdated
Show resolved
Hide resolved
4ab8b65 to
4b86233
Compare
4b86233 to
a38cbed
Compare
xintongsong
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
In addition to the two comments below, I added a fixup commit regarding NettyConnectionReaderRegistration. Please take a look.
...he/flink/runtime/io/network/partition/hybrid/tiered/storage/TieredStorageConsumerClient.java
Outdated
Show resolved
Hide resolved
24da729 to
d66707a
Compare
|
@flinkbot run azure |
TanYuxin-tyx
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@WencongLiu Thanks for the contribution. I left some minor comments, please take a look again, thanks.
| import java.util.concurrent.ExecutionException; | ||
|
|
||
| /** The data client is used to fetch data from memory tier. */ | ||
| public class MemoryTierConsumerAgent implements TierConsumerAgent { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The class need not be public, package-level access is enough.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The test package needs it.
...g/apache/flink/runtime/io/network/partition/hybrid/tiered/tier/memory/MemoryTierFactory.java
Outdated
Show resolved
Hide resolved
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
Outdated
Show resolved
Hide resolved
...me/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java
Outdated
Show resolved
Hide resolved
...che/flink/runtime/io/network/partition/hybrid/tiered/netty/TestingNettyConnectionReader.java
Outdated
Show resolved
Hide resolved
.../flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStorageConsumerClientTest.java
Outdated
Show resolved
Hide resolved
.../flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStorageConsumerClientTest.java
Outdated
Show resolved
Hide resolved
reswqa
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Overall looks good to me, I only left some comment, PTAL.
...me/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java
Outdated
Show resolved
Hide resolved
...main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateFactory.java
Outdated
Show resolved
Hide resolved
...flink/runtime/io/network/partition/hybrid/tiered/netty/TestingTieredStorageNettyService.java
Outdated
Show resolved
Hide resolved
.../java/org/apache/flink/streaming/runtime/io/benchmark/StreamNetworkBenchmarkEnvironment.java
Outdated
Show resolved
Hide resolved
...src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
Outdated
Show resolved
Hide resolved
...he/flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStorageNettyServiceImpl.java
Show resolved
Hide resolved
d66707a to
f8f6a94
Compare
.../org/apache/flink/runtime/io/network/partition/hybrid/tiered/storage/TestingTierFactory.java
Outdated
Show resolved
Hide resolved
f8f6a94 to
c3e05a9
Compare
|
Thanks for the review from @TanYuxin-tyx and @reswqa ! I've made a round of changes. 🎉 |
.../flink/runtime/io/network/partition/hybrid/tiered/netty/TieredStorageConsumerClientTest.java
Outdated
Show resolved
Hide resolved
...test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java
Outdated
Show resolved
Hide resolved
…dStorageConsumerClient
…m required segment id
c3e05a9 to
23de77e
Compare
reswqa
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the update @WencongLiu! LGTM, merging % CI green,
What is the purpose of the change
Introduce the MemoryTierConsumerAgent
Does this pull request potentially affect one of the following parts:
@Public(Evolving): (no)Documentation