Searched on Google with the first line of a JAVA stack trace?

We can recommend more relevant solutions and speed up debugging when you paste your entire stack trace with the exception message. Try a sample exception.

Recommended solutions based on your search

Solutions on the web

via Google Groups by Mangesh B, 1 year ago
java.nio.channels.ClosedChannelException: 	at org.apache.hadoop.hdfs.DFSOutputStream.checkClosed(DFSOutputStream.java:1622)	at org.apache.hadoop.fs.FSOutputSummer.write(FSOutputSummer.java:104)	at org.apache.hadoop.fs.FSDataOutputStream$PositionCache.write(FSDataOutputStream.java:58)	at java.io.DataOutputStream.write(DataOutputStream.java:107)	at org.apache.avro.file.DataFileWriter$BufferedFileOutputStream$PositionFilter.write(DataFileWriter.java:446)	at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:82)	at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:140)	at org.apache.avro.io.BufferedBinaryEncoder$OutputStreamSink.innerFlush(BufferedBinaryEncoder.java:220)	at org.apache.avro.io.BufferedBinaryEncoder.flush(BufferedBinaryEncoder.java:85)	at org.apache.avro.file.DataFileWriter.create(DataFileWriter.java:154)	at io.confluent.connect.hdfs.avro.AvroRecordWriterProvider.getRecordWriter(AvroRecordWriterProvider.java:99)	at io.confluent.connect.hdfs.TopicPartitionWriter.getWriter(TopicPartitionWriter.java:416)	at io.confluent.connect.hdfs.TopicPartitionWriter.writeRecord(TopicPartitionWriter.java:488)	at io.confluent.connect.hdfs.TopicPartitionWriter.write(TopicPartitionWriter.java:264)	at io.confluent.connect.hdfs.DataWriter.write(DataWriter.java:234)	at io.confluent.connect.hdfs.HdfsSinkTask.put(HdfsSinkTask.java:91)	at org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:280)	at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:176)	at org.apache.kafka.connect.runtime.WorkerSinkTaskThread.iteration(WorkerSinkTaskThread.java:90)	at org.apache.kafka.connect.runtime.WorkerSinkTaskThread.execute(WorkerSinkTaskThread.java:58)	at org.apache.kafka.connect.util.ShutdownableThread.run(ShutdownableThread.java:82)