You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by wc...@apache.org on 2022/06/05 18:51:35 UTC
[hbase] branch master updated: HBASE-27017: MOB snapshot is broken when FileBased SFT is used (#4466)
This is an automated email from the ASF dual-hosted git repository.
wchevreuil pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/master by this push:
new 7184949ceac HBASE-27017: MOB snapshot is broken when FileBased SFT is used (#4466)
7184949ceac is described below
commit 7184949ceac0904ba588fd5348492e0e7e8d27a0
Author: BukrosSzabolcs <sz...@cloudera.com>
AuthorDate: Sun Jun 5 20:51:28 2022 +0200
HBASE-27017: MOB snapshot is broken when FileBased SFT is used (#4466)
Signed-off-by: Duo Zhang <zh...@apache.org>
Signed-off-by: Wellington Chevreuil <wc...@apache.org>
---
.../org/apache/hadoop/hbase/snapshot/SnapshotManifest.java | 13 ++++++++++++-
1 file changed, 12 insertions(+), 1 deletion(-)
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/SnapshotManifest.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/SnapshotManifest.java
index e19be3f554b..e578b9f9764 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/SnapshotManifest.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/SnapshotManifest.java
@@ -36,6 +36,7 @@ import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
+import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder;
import org.apache.hadoop.hbase.client.RegionInfo;
import org.apache.hadoop.hbase.client.TableDescriptor;
import org.apache.hadoop.hbase.errorhandling.ForeignExceptionSnare;
@@ -310,7 +311,17 @@ public final class SnapshotManifest {
for (ColumnFamilyDescriptor cfd : htd.getColumnFamilies()) {
Object familyData = visitor.familyOpen(regionData, cfd.getName());
monitor.rethrowException();
- StoreFileTracker tracker = StoreFileTrackerFactory.create(conf, htd, cfd, regionFs);
+ StoreFileTracker tracker = null;
+ if (isMobRegion) {
+ // MOB regions are always using the default SFT implementation
+ ColumnFamilyDescriptor defaultSFTCfd = ColumnFamilyDescriptorBuilder.newBuilder(cfd)
+ .setValue(StoreFileTrackerFactory.TRACKER_IMPL,
+ StoreFileTrackerFactory.Trackers.DEFAULT.name())
+ .build();
+ tracker = StoreFileTrackerFactory.create(conf, htd, defaultSFTCfd, regionFs);
+ } else {
+ tracker = StoreFileTrackerFactory.create(conf, htd, cfd, regionFs);
+ }
List<StoreFileInfo> storeFiles = tracker.load();
if (storeFiles.isEmpty()) {
LOG.debug("No files under family: {}", cfd.getNameAsString());