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
[FLINK-12154][network] Remove legacy fields for SingleInputGate #8136
Conversation
cc @azagrebin |
Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community Review Progress
Please see the Pull Request Review Guide for a full explanation of the review process. The Bot is tracking the review progress through labels. Labels are applied according to the order of the review items. For consensus, approval by a Flink committer of PMC member is required Bot commandsThe @flinkbot bot supports the following commands:
|
@flinkbot approve all |
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 @zhijiangW ! LGTM 👍
Thanks for your review @azagrebin . |
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.
LGTM merging :)
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.
Ops, taking it back. Can you resolve conflicts @zhijiangW ?
Sure, I would solve it right now. |
@pnowojski I already rebased the master. :) |
…he#8136) This work is a preparation for FLINK-11726. In SingleInputGate#create, we could remove unused parameter ExecutionAttemptID. And for the constructor of SingleInputGate, we could remove unused parameter TaskIOMetricGroup. Then we introduce createSingleInputGate for reusing the process of creating SingleInputGate in related tests.
…he#8136) This work is a preparation for FLINK-11726. In SingleInputGate#create, we could remove unused parameter ExecutionAttemptID. And for the constructor of SingleInputGate, we could remove unused parameter TaskIOMetricGroup. Then we introduce createSingleInputGate for reusing the process of creating SingleInputGate in related tests.
What is the purpose of the change
This work is a preparation for FLINK-11726.
In
SingleInputGate#create
, we could remove unused parameterExecutionAttemptID
.And for the constructor of
SingleInputGate
, we could remove unused parameterTaskIOMetricGroup
.Then we introduce
createSingleInputGate
for reusing the process of creatingSingleInputGate
in related tests.Brief change log
ExecutionAttemptID
parameter fromSingleInputGate#create
TaskIOMetricGroup
from constructor ofSingleInputGate
createSingleInputGate
for tests reuseVerifying this change
(Please pick either of the following options)
This change is a trivial rework / code cleanup without any test coverage.
Does this pull request potentially affect one of the following parts:
@Public(Evolving)
: (yes / no)Documentation