|
36 | 36 | import org.apache.hadoop.fs.FileSystem;
|
37 | 37 | import org.apache.hadoop.fs.Path;
|
38 | 38 | import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
|
39 |
| -import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder; |
40 | 39 | import org.apache.hadoop.hbase.client.RegionInfo;
|
41 | 40 | import org.apache.hadoop.hbase.client.TableDescriptor;
|
42 | 41 | import org.apache.hadoop.hbase.errorhandling.ForeignExceptionSnare;
|
@@ -311,17 +310,7 @@ protected void addRegion(Path tableDir, RegionInfo regionInfo, RegionVisitor vis
|
311 | 310 | for (ColumnFamilyDescriptor cfd : htd.getColumnFamilies()) {
|
312 | 311 | Object familyData = visitor.familyOpen(regionData, cfd.getName());
|
313 | 312 | monitor.rethrowException();
|
314 |
| - StoreFileTracker tracker = null; |
315 |
| - if (isMobRegion) { |
316 |
| - // MOB regions are always using the default SFT implementation |
317 |
| - ColumnFamilyDescriptor defaultSFTCfd = ColumnFamilyDescriptorBuilder.newBuilder(cfd) |
318 |
| - .setValue(StoreFileTrackerFactory.TRACKER_IMPL, |
319 |
| - StoreFileTrackerFactory.Trackers.DEFAULT.name()) |
320 |
| - .build(); |
321 |
| - tracker = StoreFileTrackerFactory.create(conf, htd, defaultSFTCfd, regionFs); |
322 |
| - } else { |
323 |
| - tracker = StoreFileTrackerFactory.create(conf, htd, cfd, regionFs); |
324 |
| - } |
| 313 | + StoreFileTracker tracker = StoreFileTrackerFactory.create(conf, htd, cfd, regionFs); |
325 | 314 | List<StoreFileInfo> storeFiles = tracker.load();
|
326 | 315 | if (storeFiles.isEmpty()) {
|
327 | 316 | LOG.debug("No files under family: {}", cfd.getNameAsString());
|
|
0 commit comments