From 377c5e17cd478e513714931f14fb93ddb3beb669 Mon Sep 17 00:00:00 2001
From: "terence.yoo" <terence.yoo@kakaocorp.com>
Date: Wed, 11 Jan 2023 19:56:39 +0900
Subject: [PATCH] Revert two commits

---
 .../hadoop/hbase/regionserver/HStoreFile.java | 12 ++------
 .../hbase/regionserver/StoreEngine.java       |  9 ++----
 .../hbase/regionserver/TestHStoreFile.java    | 28 -------------------
 3 files changed, 4 insertions(+), 45 deletions(-)

diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStoreFile.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStoreFile.java
index 73a684b5e972..ae514f0aef8d 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStoreFile.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HStoreFile.java
@@ -377,7 +377,7 @@ public HDFSBlocksDistribution getHDFSBlockDistribution() {
    * Opens reader on this store file. Called by Constructor.
    * @see #closeStoreFile(boolean)
    */
-  private void open(boolean warmup) throws IOException {
+  private void open() throws IOException {
     fileInfo.initHDFSBlocksDistribution();
     long readahead = fileInfo.isNoReadahead() ? 0L : -1L;
     ReaderContext context = fileInfo.createReaderContext(false, readahead, ReaderType.PREAD);
@@ -499,25 +499,17 @@ private void open(boolean warmup) throws IOException {
     firstKey = initialReader.getFirstKey();
     lastKey = initialReader.getLastKey();
     comparator = initialReader.getComparator();
-
-    if (warmup) {
-      closeStoreFile(cacheConf == null || cacheConf.shouldEvictOnClose());
-    }
   }
 
   /**
    * Initialize the reader used for pread.
    */
   public void initReader() throws IOException {
-    initReader(false);
-  }
-
-  public void initReader(boolean warmup) throws IOException {
     if (initialReader == null) {
       synchronized (this) {
         if (initialReader == null) {
           try {
-            open(warmup);
+            open();
           } catch (Exception e) {
             try {
               boolean evictOnClose = cacheConf != null ? cacheConf.shouldEvictOnClose() : true;
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreEngine.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreEngine.java
index 47473a5985d2..f6e3db0116bb 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreEngine.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreEngine.java
@@ -219,15 +219,10 @@ public HStoreFile createStoreFileAndReader(Path p) throws IOException {
   }
 
   public HStoreFile createStoreFileAndReader(StoreFileInfo info) throws IOException {
-    return createStoreFileAndReader(info, false);
-  }
-
-  public HStoreFile createStoreFileAndReader(StoreFileInfo info, boolean warmup)
-    throws IOException {
     info.setRegionCoprocessorHost(coprocessorHost);
     HStoreFile storeFile = new HStoreFile(info, ctx.getFamily().getBloomFilterType(),
       ctx.getCacheConf(), bloomFilterMetrics);
-    storeFile.initReader(warmup);
+    storeFile.initReader();
     return storeFile;
   }
 
@@ -268,7 +263,7 @@ private List<HStoreFile> openStoreFiles(Collection<StoreFileInfo> files, boolean
       // our store's CompoundConfiguration here.
       storeFileInfo.setConf(conf);
       // open each store file in parallel
-      completionService.submit(() -> createStoreFileAndReader(storeFileInfo, warmup));
+      completionService.submit(() -> createStoreFileAndReader(storeFileInfo));
       totalValidStoreFile++;
     }
 
diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStoreFile.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStoreFile.java
index fec008129a39..a0c23af5ef0d 100644
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStoreFile.java
+++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/TestHStoreFile.java
@@ -1279,32 +1279,4 @@ private void testDataBlockSizeWithCompressionRatePredicator(int expectedBlockCou
     assertEquals(expectedBlockCount, blockCount);
   }
 
-  @Test
-  public void testInitReaderForWarmup() throws Exception {
-    final RegionInfo hri =
-      RegionInfoBuilder.newBuilder(TableName.valueOf("testInitReaderForWarmup")).build();
-    HRegionFileSystem regionFs = HRegionFileSystem.createRegionOnFileSystem(conf, fs,
-      new Path(testDir, hri.getTable().getNameAsString()), hri);
-    HFileContext meta = new HFileContextBuilder().withBlockSize(8 * 1024).build();
-
-    // Make a store file and write data to it.
-    StoreFileWriter writer = new StoreFileWriter.Builder(conf, cacheConf, this.fs)
-      .withFilePath(regionFs.createTempName()).withFileContext(meta).build();
-    writeStoreFile(writer);
-    Path hsfPath = regionFs.commitStoreFile(TEST_FAMILY, writer.getPath());
-    writer.close();
-
-    HStoreFile file =
-      Mockito.spy(new HStoreFile(this.fs, hsfPath, conf, cacheConf, BloomType.NONE, true));
-
-    // after warmup the file reader should be closed and null to avoid file descriptor leakage
-    file.initReader(true);
-    assertNull(file.getReader());
-    Mockito.verify(file, Mockito.times(1)).closeStoreFile(Mockito.anyBoolean());
-
-    // not for warmup
-    file.initReader();
-    assertNotNull(file.getReader());
-    Mockito.verify(file, Mockito.times(1)).closeStoreFile(Mockito.anyBoolean());
-  }
 }