org.apache.kafka.connect.errors.ConnectException: java.io.FileNotFoundException: File /logs/test-streamx/0/log does not exist

GitHub | zzbennett | 1 month ago
tip
Your exception is missing from the Samebug knowledge base.
Here are the best solutions we found on the Internet.
Click on the to mark the helpful solution and get rewards for you help.
  1. 0

    org.apache.kafka.connect.errors.ConnectException: java.io.FileNotFoundException: File /logs/test-streamx/0/log does not exist

    GitHub | 1 month ago | zzbennett
    org.apache.kafka.connect.errors.ConnectException: java.io.FileNotFoundException: File /logs/test-streamx/0/log does not exist
  2. 0

    org.apache.hadoop.fs.s3a.S3AFileSystem.append not supported

    GitHub | 8 months ago | a2mehta
    org.apache.kafka.connect.errors.ConnectException: Error creating writer for log file s3a://s3 bucket/streamx/logs/streamx/0/log**
  3. 0

    Connector can't renew properly Kerberos ticket

    GitHub | 10 months ago | AlexPiermatteo
    org.apache.kafka.connect.errors.ConnectException: java.io.IOException: Failed on local exception: java.io.IOException: javax.security.sasl.SaslException: GSS initiate failed [Caused by GSSException: No valid credentials provided (Mechanism level: Failed to find any Kerberos tgt)]; Host Details : local host is: "myhostname1/IP"; destination host is: "namenode_hostname":8020;
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Hdfs connect error

    Google Groups | 4 weeks ago | Guillaume
    org.apache.kafka.connect.errors.ConnectException: java.io.EOFException
  6. 0

    Exceptions when network is broken

    GitHub | 4 months ago | skyahead
    org.apache.kafka.connect.errors.ConnectException: Cannot acquire lease after timeout, will retry.

  1. tyson925 8 times, last 10 months ago
1 unregistered visitors
Not finding the right solution?
Take a tour to get the most out of Samebug.

Tired of useless tips?

Automated exception search integrated into your IDE

Root Cause Analysis

  1. java.io.FileNotFoundException

    File /logs/test-streamx/0/log does not exist

    at org.apache.hadoop.fs.RawLocalFileSystem.deprecatedGetFileStatus()
  2. Hadoop
    ChecksumFileSystem.rename
    1. org.apache.hadoop.fs.RawLocalFileSystem.deprecatedGetFileStatus(RawLocalFileSystem.java:609)
    2. org.apache.hadoop.fs.RawLocalFileSystem.getFileLinkStatusInternal(RawLocalFileSystem.java:822)
    3. org.apache.hadoop.fs.RawLocalFileSystem.getFileStatus(RawLocalFileSystem.java:599)
    4. org.apache.hadoop.fs.FileUtil.copy(FileUtil.java:337)
    5. org.apache.hadoop.fs.FileUtil.copy(FileUtil.java:289)
    6. org.apache.hadoop.fs.RawLocalFileSystem.rename(RawLocalFileSystem.java:372)
    7. org.apache.hadoop.fs.ChecksumFileSystem.rename(ChecksumFileSystem.java:513)
    7 frames
  3. com.qubole.streamx
    S3Storage.commit
    1. com.qubole.streamx.s3.S3Storage.renameFile(S3Storage.java:140)
    2. com.qubole.streamx.s3.S3Storage.commit(S3Storage.java:96)
    2 frames
  4. io.confluent.connect
    HdfsSinkTask.put
    1. io.confluent.connect.hdfs.utils.MemoryWAL.truncate(MemoryWAL.java:84)
    2. io.confluent.connect.hdfs.TopicPartitionWriter.truncateWAL(TopicPartitionWriter.java:457)
    3. io.confluent.connect.hdfs.TopicPartitionWriter.recover(TopicPartitionWriter.java:205)
    4. io.confluent.connect.hdfs.TopicPartitionWriter.write(TopicPartitionWriter.java:232)
    5. io.confluent.connect.hdfs.DataWriter.write(DataWriter.java:237)
    6. io.confluent.connect.hdfs.HdfsSinkTask.put(HdfsSinkTask.java:92)
    6 frames
  5. org.apache.kafka
    WorkerTask.run
    1. org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:384)
    2. org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:240)
    3. org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:172)
    4. org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:143)
    5. org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
    6. org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
    6 frames
  6. 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