org.apache.kafka.connect.errors.ConnectException

java.io.FileNotFoundException: File /logs/test-streamx/0/log does not exist

Samebug tips0

There are no available Samebug tips for this exception. If you know how to solve this issue, help other users by writing a short tip.

Don't give up yet. Paste your full stack trace to get a solution.

Solutions on the web34

  • java.io.FileNotFoundException: File /logs/test-streamx/0/log does not exist
  • Error creating writer for log file s3a://s3 bucket/streamx/logs/streamx/0/log**
  • via Google Groups by Basti, 3 months ago
    Error creating writer >> for log file hdfs://10.42.0.86:9000/logs/testApp/0/log
  • Stack trace

    • org.apache.kafka.connect.errors.ConnectException: java.io.FileNotFoundException: File /logs/test-streamx/0/log does not exist at io.confluent.connect.hdfs.utils.MemoryWAL.truncate(MemoryWAL.java:87) at io.confluent.connect.hdfs.TopicPartitionWriter.truncateWAL(TopicPartitionWriter.java:457) at io.confluent.connect.hdfs.TopicPartitionWriter.recover(TopicPartitionWriter.java:205) at io.confluent.connect.hdfs.TopicPartitionWriter.write(TopicPartitionWriter.java:232) at io.confluent.connect.hdfs.DataWriter.write(DataWriter.java:237) at io.confluent.connect.hdfs.HdfsSinkTask.put(HdfsSinkTask.java:92) at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:384) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:240) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:172) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:143) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) Caused by: java.io.FileNotFoundException: File /logs/test-streamx/0/log does not exist at org.apache.hadoop.fs.RawLocalFileSystem.deprecatedGetFileStatus(RawLocalFileSystem.java:609) at org.apache.hadoop.fs.RawLocalFileSystem.getFileLinkStatusInternal(RawLocalFileSystem.java:822) at org.apache.hadoop.fs.RawLocalFileSystem.getFileStatus(RawLocalFileSystem.java:599) at org.apache.hadoop.fs.FileUtil.copy(FileUtil.java:337) at org.apache.hadoop.fs.FileUtil.copy(FileUtil.java:289) at org.apache.hadoop.fs.RawLocalFileSystem.rename(RawLocalFileSystem.java:372) at org.apache.hadoop.fs.ChecksumFileSystem.rename(ChecksumFileSystem.java:513) at com.qubole.streamx.s3.S3Storage.renameFile(S3Storage.java:140) at com.qubole.streamx.s3.S3Storage.commit(S3Storage.java:96) at io.confluent.connect.hdfs.utils.MemoryWAL.truncate(MemoryWAL.java:84) ... 16 more

    Write tip

    You have a different solution? A short tip here would help you and many other users who saw this issue last week.

    Users with the same issue

    Unknown user
    Once, 1 year ago
    8 times, 1 year ago
    Once, 5 months ago
    Unknown user
    Once, 10 months ago
    Unknown user
    Once, 11 months ago
    4 more bugmates