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

GitHub | zzbennett | 2 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

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

    GitHub | 2 months 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 | 9 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 | 11 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 | 2 months ago | Guillaume
    org.apache.kafka.connect.errors.ConnectException: java.io.EOFException
  6. 0

    Exceptions when network is broken

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

  1. tyson925 8 times, last 11 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