-
Notifications
You must be signed in to change notification settings - Fork 8.9k
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
HDFS-16016. BPServiceActor to provide new thread to handle IBR #2998
Conversation
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
0f58570
to
0832df5
Compare
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
0832df5
to
e44d2f8
Compare
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
e44d2f8
to
a204a95
Compare
This comment has been minimized.
This comment has been minimized.
Surprisingly I am not able to repro |
@jojochuang @smengcl would you like to take a look? |
@liuml07 would you like to take a look? |
May take a look next week if no one reviews. |
This comment has been minimized.
This comment has been minimized.
FYI @liuml07 if you get some bandwidth. Thanks |
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 patch @virajjasani . Overall looks good. Pls find comments inline.
} | ||
// There is no work to do; sleep until hearbeat timer elapses, | ||
// or work arrives, and then iterate again. | ||
ibrManager.waitTillNextIBR(scheduler.getHeartbeatWaitTime()); |
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.
This implies this IBR timer will expire around the same time as the FBR one (offerService()
). This should be fine.
With IBR separated in a new thread, maybe later we could have a new config key that controls IBR interval separately, or add a configurable constant offset (from the FBR timer) to the IBR timer. This isn't something we need to add to this jira. Just a thought.
Just in case I miss anything, @sodonnel would you like to take a quick look at this?
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.
With IBR separated in a new thread, maybe later we could have a new config key that controls IBR interval separately, or add a configurable constant offset (from the FBR timer) to the IBR timer. This isn't something we need to add to this jira. Just a thought.
I agree. We can add new config or continue with IBR/FBR expiring around same time for some time.
...project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/datanode/BPServiceActor.java
Outdated
Show resolved
Hide resolved
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDatanodeReport.java
Outdated
Show resolved
Hide resolved
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDatanodeReport.java
Outdated
Show resolved
Hide resolved
...p-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestIncrementalBlockReports.java
Outdated
Show resolved
Hide resolved
2450cc2
to
a5ca479
Compare
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
Thanks for the review @smengcl. I have addressed your concerns. |
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.
+1
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/TestDatanodeReport.java
Outdated
Show resolved
Hide resolved
…p/hdfs/TestDatanodeReport.java Co-authored-by: Siyao Meng <[email protected]>
Thanks @virajjasani for patch. Will merge shortly. |
💔 -1 overall
This message was automatically generated. |
…e#2998) Contributed by Viraj Jasani
Contributed by Viraj Jasani (cherry picked from commit c1bf3cb)
…e IBR (apache#2998) Contributed by Viraj Jasani (cherry picked from commit c1bf3cb) Change-Id: Iedabb8f14c8165c62431916ae34320a5f63f1977 (cherry picked from commit 49c412895085c996ebf77352aee7e5961fe91aef)
@virajjasani We plan to revert this pr. There have been user reports indicating that it may cause dn ibr and fbr to be mis-order. we can refer to #6244 for more details. |
apache#2998)" This reverts commit c1bf3cb
#2998)" (#6457) Contributed by Shilun Fan. This reverts commit c1bf3cb. Reviewed-by: Takanobu Asanuma <[email protected]> Reviewed-by: He Xiaoqiao <[email protected]> Reviewed-by: Ayush Saxena <[email protected]> Reviewed-by: Viraj Jasani <[email protected]> Signed-off-by: Shilun Fan <[email protected]>
#2998)" (#6457) Contributed by Shilun Fan. This reverts commit c1bf3cb. Reviewed-by: Takanobu Asanuma <[email protected]> Reviewed-by: He Xiaoqiao <[email protected]> Reviewed-by: Ayush Saxena <[email protected]> Reviewed-by: Viraj Jasani <[email protected]> Signed-off-by: Shilun Fan <[email protected]>
#2998)" (#6457) Contributed by Shilun Fan. This reverts commit c1bf3cb. Reviewed-by: Takanobu Asanuma <[email protected]> Reviewed-by: He Xiaoqiao <[email protected]> Reviewed-by: Ayush Saxena <[email protected]> Reviewed-by: Viraj Jasani <[email protected]> Signed-off-by: Shilun Fan <[email protected]>
apache#2998)" (apache#6457) Contributed by Shilun Fan. This reverts commit c1bf3cb. Reviewed-by: Takanobu Asanuma <[email protected]> Reviewed-by: He Xiaoqiao <[email protected]> Reviewed-by: Ayush Saxena <[email protected]> Reviewed-by: Viraj Jasani <[email protected]> Signed-off-by: Shilun Fan <[email protected]>
…e#2998) Contributed by Viraj Jasani
https://issues.apache.org/jira/browse/HDFS-16016