Skip to content

Commit cf2c9b2

Browse files
committed
HBASE-29574 Resolve the issue that splitting HFiles results in write failures due to storage policy during bulkload
1 parent e203a59 commit cf2c9b2

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

hbase-server/src/main/java/org/apache/hadoop/hbase/tool/LoadIncrementalHFiles.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1164,6 +1164,11 @@ private static void copyHFileHalf(Configuration conf, Path inFile, Path outFile,
11641164
hfile.initMetaAndIndex(halfReader.getHFileReader());
11651165
Map<byte[], byte[]> fileInfo = halfReader.loadFileInfo();
11661166

1167+
if (familyDescriptor.getStoragePolicy() != null) {
1168+
conf = new Configuration(conf);
1169+
conf.set(ColumnFamilyDescriptorBuilder.STORAGE_POLICY, familyDescriptor.getStoragePolicy());
1170+
}
1171+
11671172
int blocksize = familyDescriptor.getBlocksize();
11681173
Algorithm compression = familyDescriptor.getCompressionType();
11691174
BloomType bloomFilterType = familyDescriptor.getBloomFilterType();

0 commit comments

Comments
 (0)