소스 검색

Revert "HDFS-16033 Fix issue of the StatisticsDataReferenceCleaner cleanUp (#3042)"

This reverts commit 8c0f9480549a4e7fa7de02c9bf73bccb0381f22a.
Mingliang Liu 4 년 전
부모
커밋
91bcfbd72e
1개의 변경된 파일1개의 추가작업 그리고 8개의 파일을 삭제
  1. 1 8
      hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileSystem.java

+ 1 - 8
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/FileSystem.java

@@ -4013,19 +4013,12 @@ public abstract class FileSystem extends Configured
      * Background action to act on references being removed.
      */
     private static class StatisticsDataReferenceCleaner implements Runnable {
-      /**
-       * Represents the timeout period expires for remove reference objects from
-       * the STATS_DATA_REF_QUEUE when the queue is empty.
-       */
-      private static final int REF_QUEUE_POLL_TIMEOUT = 10000;
-
       @Override
       public void run() {
         while (!Thread.interrupted()) {
           try {
             StatisticsDataReference ref =
-                (StatisticsDataReference)STATS_DATA_REF_QUEUE.
-                        remove(REF_QUEUE_POLL_TIMEOUT);
+                (StatisticsDataReference)STATS_DATA_REF_QUEUE.remove();
             ref.cleanUp();
           } catch (InterruptedException ie) {
             LOGGER.warn("Cleaner thread interrupted, will stop", ie);