add a config for using the legacy methods (apache#45)

ndimiduk · Mar 16, 2023 · cd1c883 · cd1c883
1 parent 2f45f25
commit cd1c883
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/util/CommonFSUtils.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/util/CommonFSUtils.java
@@ -794,6 +794,14 @@ public static FSDataOutputStream createForWal(FileSystem fs, Path path, boolean
    */
   public static FSDataOutputStream createForWal(FileSystem fs, Path path, boolean overwrite,
     int bufferSize, short replication, long blockSize, boolean isRecursive) throws IOException {
+    // temporary for use while we work on upgrading clients to hadoop3
+    if (fs.getConf().getBoolean("use.legacy.hdfs.create.methods", false)) {
+      if (isRecursive) {
+        return fs.create(path, overwrite, bufferSize, replication, blockSize);
+      } else {
+        return fs.createNonRecursive(path, overwrite, bufferSize, replication, blockSize, null);
+      }
+    }
     FSDataOutputStreamBuilder<?, ?> builder = fs.createFile(path).overwrite(overwrite)
       .bufferSize(bufferSize).replication(replication).blockSize(blockSize);
     if (isRecursive) {