-
Notifications
You must be signed in to change notification settings - Fork 3.4k
HBASE-24795 : RegionMover to deal with unknown region while (un)loading #2172
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
This comment has been minimized.
This comment has been minimized.
| if (!sameServer) { | ||
| break; | ||
| } | ||
| Thread.sleep(100); |
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.
Maybe the interval can be a bit longer since maxWait is in seconds.
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.
Agree, this was old code anyways, we can update this to 1 sec at least.
hbase-server/src/main/java/org/apache/hadoop/hbase/util/MoveWithAck.java
Show resolved
Hide resolved
| LOG.error("Got Exception From Thread While moving region " + e.getMessage(), e); | ||
| throw e; | ||
| if (e.getCause() instanceof UnknownRegionException) { | ||
| LOG.debug("Ignore unknown region, it might have been split/merged."); |
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.
Should this be logged at more prominent level ?
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.
sure, let me use info
This comment has been minimized.
This comment has been minimized.
|
+1 |
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.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
|
is there a particular reason we're conflating formatting changes here? are the qa failures related? |
hbase-server/src/main/java/org/apache/hadoop/hbase/util/MoveWithoutAck.java
Outdated
Show resolved
Hide resolved
hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionMover.java
Outdated
Show resolved
Hide resolved
hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover.java
Outdated
Show resolved
Hide resolved
QA failures are not relevant, tried locally and both builds have one common test failure: I just thought of refactoring |
that's a good idea; please make sure there is a note about that in the commit message body. |
virajjasani
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.
Incorporated review comments
hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionMover.java
Outdated
Show resolved
Hide resolved
This comment has been minimized.
This comment has been minimized.
hbase-server/src/main/java/org/apache/hadoop/hbase/util/MoveWithAck.java
Outdated
Show resolved
Hide resolved
hbase-server/src/main/java/org/apache/hadoop/hbase/util/MoveWithAck.java
Outdated
Show resolved
Hide resolved
hbase-server/src/main/java/org/apache/hadoop/hbase/util/MoveWithAck.java
Outdated
Show resolved
Hide resolved
hbase-server/src/main/java/org/apache/hadoop/hbase/util/MoveWithAck.java
Outdated
Show resolved
Hide resolved
| ExecutorService moveRegionsPool = Executors.newFixedThreadPool(this.maxthreads); | ||
| List<Future<Boolean>> taskList = new ArrayList<>(); | ||
| int serverIndex = 0; | ||
| while (counter < regionsToMove.size()) { |
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.
nit: this should be a for each loop on the regionsToMove list
hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover2.java
Outdated
Show resolved
Hide resolved
hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover2.java
Outdated
Show resolved
Hide resolved
hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover2.java
Outdated
Show resolved
Hide resolved
hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover2.java
Outdated
Show resolved
Hide resolved
hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover2.java
Outdated
Show resolved
Hide resolved
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
This comment has been minimized.
|
Precommit run is not getting scheduled, waiting logs are present for long time: I tried manual trigger but the run is still not scheduled. |
it's backlog waiting for executors to open up on the new ci host: https://ci-hadoop.apache.org/label/Hadoop/load-statistics looks like the queue size started to climb yesterday around midnight CDT. peaked about 5 hours ago at ~300. is now sitting around 280. |
hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover1.java
Outdated
Show resolved
Hide resolved
hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover1.java
Outdated
Show resolved
Hide resolved
hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover2.java
Outdated
Show resolved
Hide resolved
hbase-server/src/test/java/org/apache/hadoop/hbase/util/TestRegionMover2.java
Outdated
Show resolved
Hide resolved
|
🎊 +1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
|
🎊 +1 overall
This message was automatically generated. |
* RegionMover to ignore move failures for split/merged regions with ack mode * Refactor MoveWithAck and MoveWithoutAck as high level classes * UT for RegionMover gracefully handling split/merged regions while loading regions and throwing failure while loading offline regions Closes #2172 Signed-off-by: Sean Busbey <[email protected]> Signed-off-by: Ted Yu <[email protected]>
* RegionMover to ignore move failures for split/merged regions with ack mode * Refactor MoveWithAck and MoveWithoutAck as high level classes * UT for RegionMover gracefully handling split/merged regions while loading regions and throwing failure while loading offline regions Closes #2172 Signed-off-by: Sean Busbey <[email protected]> Signed-off-by: Ted Yu <[email protected]>
* RegionMover to ignore move failures for split/merged regions with ack mode * Refactor MoveWithAck and MoveWithoutAck as high level classes * UT for RegionMover gracefully handling split/merged regions while loading regions and throwing failure while loading offline regions Closes apache#2172 Signed-off-by: Sean Busbey <[email protected]> Signed-off-by: Ted Yu <[email protected]>
Uh oh!
There was an error while loading. Please reload this page.