Uploaded image for project: 'Hadoop HDFS'
  1. Hadoop HDFS
  2. HDFS-7314

When the DFSClient lease cannot be renewed, abort open-for-write files rather than the entire DFSClient

    XMLWordPrintableJSON

Details

    Description

      It happened in YARN nodemanger scenario. But it could happen to any long running service that use cached instance of DistrbutedFileSystem.

      1. Active NN is under heavy load. So it became unavailable for 10 minutes; any DFSClient request will get ConnectTimeoutException.

      2. YARN nodemanager use DFSClient for certain write operation such as log aggregator or shared cache in YARN-1492. DFSClient used by YARN NM's renewLease RPC got ConnectTimeoutException.

      2014-10-29 01:36:19,559 WARN org.apache.hadoop.hdfs.LeaseRenewer: Failed to renew lease for [DFSClient_NONMAPREDUCE_-550838118_1] for 372 seconds.  Aborting ...
      

      3. After DFSClient is in Aborted state, YARN NM can't use that cached instance of DistributedFileSystem.

      2014-10-29 20:26:23,991 INFO org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.ResourceLocalizationService: Failed to download rsrc...
      java.io.IOException: Filesystem closed
              at org.apache.hadoop.hdfs.DFSClient.checkOpen(DFSClient.java:727)
              at org.apache.hadoop.hdfs.DFSClient.getFileInfo(DFSClient.java:1780)
              at org.apache.hadoop.hdfs.DistributedFileSystem$17.doCall(DistributedFileSystem.java:1124)
              at org.apache.hadoop.hdfs.DistributedFileSystem$17.doCall(DistributedFileSystem.java:1120)
              at org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81)
              at org.apache.hadoop.hdfs.DistributedFileSystem.getFileStatus(DistributedFileSystem.java:1120)
              at org.apache.hadoop.yarn.util.FSDownload.copy(FSDownload.java:237)
              at org.apache.hadoop.yarn.util.FSDownload.call(FSDownload.java:340)
              at org.apache.hadoop.yarn.util.FSDownload.call(FSDownload.java:57)
              at java.util.concurrent.FutureTask.run(FutureTask.java:262)
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
              at java.util.concurrent.FutureTask.run(FutureTask.java:262)
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
              at java.lang.Thread.run(Thread.java:745)
      

      We can make YARN or DFSClient more tolerant to temporary NN unavailability. Given the callstack is YARN -> DistributedFileSystem -> DFSClient, this can be addressed at different layers.

      • YARN closes the DistributedFileSystem object when it receives some well defined exception. Then the next HDFS call will create a new instance of DistributedFileSystem. We have to fix all the places in YARN. Plus other HDFS applications need to address this as well.
      • DistributedFileSystem detects Aborted DFSClient and create a new instance of DFSClient. We will need to fix all the places DistributedFileSystem calls DFSClient.
      • After DFSClient gets into Aborted state, it doesn't have to reject all requests , instead it can retry. If NN is available again it can transition to healthy state.

      Comments?

      Attachments

        1. HDFS-7314-branch-2.7.2.txt
          7 kB
          Vinod Kumar Vavilapalli
        2. HDFS-7314-9.patch
          6 kB
          Ming Ma
        3. HDFS-7314-8.patch
          6 kB
          Ming Ma
        4. HDFS-7314-7.patch
          8 kB
          Ming Ma
        5. HDFS-7314-6.patch
          7 kB
          Ming Ma
        6. HDFS-7314-5.patch
          7 kB
          Ming Ma
        7. HDFS-7314-4.patch
          9 kB
          Ming Ma
        8. HDFS-7314-3.patch
          6 kB
          Ming Ma
        9. HDFS-7314-2.patch
          6 kB
          Ming Ma
        10. HDFS-7314.patch
          9 kB
          Ming Ma

        Activity

          People

            mingma Ming Ma
            mingma Ming Ma
            Votes:
            0 Vote for this issue
            Watchers:
            17 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: