HBASE-29574 Resolve the issue that splitting HFiles results in write failures due to storage policy during bulkload

Huginn-kio · Huginn-kio · commit 2b7ea3ccbadd · 2025-09-07T17:21:37.000+08:00
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/BulkLoadHFilesTool.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/tool/BulkLoadHFilesTool.java
@@ -832,6 +832,8 @@ private static void copyHFileHalf(Configuration conf, Path inFile, Path outFile,
           }
           if (halfWriter == null) {
             // init halfwriter
+            conf = new Configuration(conf);
+            conf.set(ColumnFamilyDescriptorBuilder.STORAGE_POLICY, familyDescriptor.getStoragePolicy());
             halfWriter = initStoreFileWriter(conf, cell, hFileContext, cacheConf, bloomFilterType,
               fs, outFile, loc);
           }

Original file line number	Diff line number	Diff line change
`@@ -832,6 +832,8 @@ private static void copyHFileHalf(Configuration conf, Path inFile, Path outFile,`
`832`	`832`	`}`
`833`	`833`	`if (halfWriter == null) {`
`834`	`834`	`// init halfwriter`
	`835`	`+ conf = new Configuration(conf);`
	`836`	`+ conf.set(ColumnFamilyDescriptorBuilder.STORAGE_POLICY, familyDescriptor.getStoragePolicy());`
`835`	`837`	`halfWriter = initStoreFileWriter(conf, cell, hFileContext, cacheConf, bloomFilterType,`
`836`	`838`	`fs, outFile, loc);`
`837`	`839`	`}`