Package org.apache.hadoop.hdfs

Class DFSClientFaultInjector

java.lang.Object
org.apache.hadoop.hdfs.DFSClientFaultInjector
@VisibleForTesting @Private public class DFSClientFaultInjector extends Object
Used for injecting faults in DFSClient and DFSOutputStream tests. Calls into this are a no-op in production code.

  • Field Details

    • exceptionNum

      public static AtomicLong exceptionNum

  • Constructor Details

    • DFSClientFaultInjector

      public DFSClientFaultInjector()

  • Method Details

    • get

      public static DFSClientFaultInjector get()

    • set

      public static void set(DFSClientFaultInjector instance)

    • corruptPacket

      public boolean corruptPacket()

    • uncorruptPacket

      public boolean uncorruptPacket()

    • failPacket

      public boolean failPacket()

    • startFetchFromDatanode

      public void startFetchFromDatanode()

    • fetchFromDatanodeException

      public void fetchFromDatanodeException()

    • readFromDatanodeDelay

      public void readFromDatanodeDelay()

    • skipRollingRestartWait

      public boolean skipRollingRestartWait()

    • sleepBeforeHedgedGet

      public void sleepBeforeHedgedGet()

    • delayWhenRenewLeaseTimeout

      public void delayWhenRenewLeaseTimeout()

    • onCreateBlockReader

      public void onCreateBlockReader(LocatedBlock block, int chunkIndex, long offset, long length)

    • failCreateBlockReader

      public void failCreateBlockReader() throws InvalidBlockTokenException
      Throws:
      InvalidBlockTokenException

    • failWhenReadWithStrategy

      public void failWhenReadWithStrategy(boolean isRetryRead) throws IOException
      Throws:
      IOException