java.io.IOException: Hadoop home directory does not exist, is not a directory, or is not an absolute path.

Google Groups | Robin Moffatt | 7 months ago
tip
Do you know that we can give you better hits? Get more relevant results from Samebug’s stack trace search.
  1. 0

    HDFS Connector Sink - should it work with non-Connect topic?

    Google Groups | 7 months ago | Robin Moffatt
    java.io.IOException: Hadoop home directory does not exist, is not a directory, or is not an absolute path.
  2. 0

    ERROR Task hdfs-sink-0 threw an uncaught and unrecoverable exception

    Google Groups | 3 months ago | Sneha Jayaram
    java.lang.reflect.InvocationTargetException

    1 unregistered visitors

    Root Cause Analysis

    1. java.io.IOException

      Hadoop home directory does not exist, is not a directory, or is not an absolute path.

      at org.apache.hadoop.util.Shell.checkHadoopHome()
    2. Hadoop
      FileSystem.newInstance
      1. org.apache.hadoop.util.Shell.checkHadoopHome(Shell.java:312)
      2. org.apache.hadoop.util.Shell.<clinit>(Shell.java:327)
      3. org.apache.hadoop.util.StringUtils.<clinit>(StringUtils.java:79)
      4. org.apache.hadoop.security.Groups.parseStaticMapping(Groups.java:104)
      5. org.apache.hadoop.security.Groups.<init>(Groups.java:86)
      6. org.apache.hadoop.security.Groups.<init>(Groups.java:66)
      7. org.apache.hadoop.security.Groups.getUserToGroupsMappingService(Groups.java:280)
      8. org.apache.hadoop.security.UserGroupInformation.initialize(UserGroupInformation.java:271)
      9. org.apache.hadoop.security.UserGroupInformation.ensureInitialized(UserGroupInformation.java:248)
      10. org.apache.hadoop.security.UserGroupInformation.loginUserFromSubject(UserGroupInformation.java:763)
      11. org.apache.hadoop.security.UserGroupInformation.getLoginUser(UserGroupInformation.java:748)
      12. org.apache.hadoop.security.UserGroupInformation.getCurrentUser(UserGroupInformation.java:621)
      13. org.apache.hadoop.fs.FileSystem$Cache$Key.<init>(FileSystem.java:2753)
      14. org.apache.hadoop.fs.FileSystem$Cache.getUnique(FileSystem.java:2617)
      15. org.apache.hadoop.fs.FileSystem.newInstance(FileSystem.java:417)
      15 frames
    3. io.confluent.connect
      HdfsStorage.<init>
      1. io.confluent.connect.hdfs.storage.HdfsStorage.<init>(HdfsStorage.java:39)
      1 frame
    4. Java RT
      Constructor.newInstance
      1. sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
      2. sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
      3. sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
      4. java.lang.reflect.Constructor.newInstance(Constructor.java:423)
      4 frames
    5. io.confluent.connect
      HdfsSinkTask.start
      1. io.confluent.connect.hdfs.storage.StorageFactory.createStorage(StorageFactory.java:29)
      2. io.confluent.connect.hdfs.DataWriter.<init>(DataWriter.java:168)
      3. io.confluent.connect.hdfs.HdfsSinkTask.start(HdfsSinkTask.java:64)
      3 frames
    6. org.apache.kafka
      WorkerTask.run
      1. org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:207)
      2. org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:139)
      3. org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
      4. org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
      4 frames
    7. Java RT
      Thread.run
      1. java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
      2. java.util.concurrent.FutureTask.run(FutureTask.java:266)
      3. java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
      4. java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
      5. java.lang.Thread.run(Thread.java:745)
      5 frames