From f4fbdb6f3613d5a6e9e50bd13dcf64da97a8de03 Mon Sep 17 00:00:00 2001 From: Sandeep Pal Date: Wed, 20 Nov 2019 12:46:58 -0800 Subject: [PATCH] HBASE-21776: Fix Duplicate Set storagePolicy calls --- .../hadoop/hbase/regionserver/HRegionFileSystem.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionFileSystem.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionFileSystem.java index c9c5fd0970..3079ff2cb2 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionFileSystem.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionFileSystem.java @@ -189,8 +189,12 @@ public class HRegionFileSystem { * @param familyName The name of column family. * @param policyName The name of the storage policy */ - public void setStoragePolicy(String familyName, String policyName) { - FSUtils.setStoragePolicy(this.fs, getStoreDir(familyName), policyName); + public void setStoragePolicy(String familyName, String policyName) throws IOException { + if (this.fs instanceof HFileSystem) { + FSUtils.setStoragePolicy(((HFileSystem) this.fs).getBackingFs(), getStoreDir(familyName), policyName); + } else { + FSUtils.setStoragePolicy(this.fs, getStoreDir(familyName), policyName); + } } /** -- 2.23.0