org.apache.avro.file.DataFileWriter$AppendWriteException: org.apache.avro.AvroRuntimeException: Unknown datum type io.confluent.kafka.serializers.NonRecordContainer: io.confluent.kafka.serializers.NonRecordContainer@31d89133

GitHub | blbradley | 2 months ago
  1. 0

    exception when using StringConverter for key and value converter

    GitHub | 2 months ago | blbradley
    org.apache.avro.file.DataFileWriter$AppendWriteException: org.apache.avro.AvroRuntimeException: Unknown datum type io.confluent.kafka.serializers.NonRecordContainer: io.confluent.kafka.serializers.NonRecordContainer@31d89133
  2. 0

    runtime exception when load and store multiple files using avro in pig

    Stack Overflow | 4 years ago | user1591487
    org.apache.avro.file.DataFileWriter$AppendWriteException: java.lang.RuntimeException: Datum 1980-01-01 00:00:00.000 is not in union ["null","long"]
  3. 0

    Avro : java.lang.RuntimeException: Unsupported type in record

    Stack Overflow | 2 years ago | Murali Rao
    org.apache.avro.file.DataFileWriter$AppendWriteException: java.lang.RuntimeException: Unsupported type in record:class java.lang.String
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Avro GenericRecordBuilder weirdness

    Google Groups | 3 years ago | James Boorn
    cascading.tuple.TupleException: unable to sink into output identifier: /tmp/rc.pivotlinkqa.com/scaldingExample/3/out
  6. 0

    GitHub comment 21#73002279

    GitHub | 2 years ago | mkanchwala
    org.apache.avro.file.DataFileWriter$AppendWriteException: java.lang.NullPointerException: in topLevelRecord in long null of long in field ETL_UPDATED_TS of topLevelRecord

    4 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. org.apache.avro.AvroRuntimeException

      Unknown datum type io.confluent.kafka.serializers.NonRecordContainer: io.confluent.kafka.serializers.NonRecordContainer@31d89133

      at org.apache.avro.generic.GenericData.getSchemaName()
    2. Apache Avro
      DataFileWriter.append
      1. org.apache.avro.generic.GenericData.getSchemaName(GenericData.java:636)
      2. org.apache.avro.generic.GenericData.resolveUnion(GenericData.java:601)
      3. org.apache.avro.generic.GenericDatumWriter.resolveUnion(GenericDatumWriter.java:151)
      4. org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:71)
      5. org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:58)
      6. org.apache.avro.file.DataFileWriter.append(DataFileWriter.java:290)
      6 frames
    3. io.confluent.connect
      HdfsSinkTask.put
      1. io.confluent.connect.hdfs.avro.AvroRecordWriterProvider$1.write(AvroRecordWriterProvider.java:64)
      2. io.confluent.connect.hdfs.avro.AvroRecordWriterProvider$1.write(AvroRecordWriterProvider.java:59)
      3. io.confluent.connect.hdfs.TopicPartitionWriter.writeRecord(TopicPartitionWriter.java:487)
      4. io.confluent.connect.hdfs.TopicPartitionWriter.write(TopicPartitionWriter.java:264)
      5. io.confluent.connect.hdfs.DataWriter.write(DataWriter.java:234)
      6. io.confluent.connect.hdfs.HdfsSinkTask.put(HdfsSinkTask.java:91)
      6 frames
    4. org.apache.kafka
      WorkerTask.run
      1. org.apache.kafka.connect.runtime.WorkerSinkTask.deliverMessages(WorkerSinkTask.java:381)
      2. org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:227)
      3. org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:170)
      4. org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:142)
      5. org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:140)
      6. org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:175)
      6 frames
    5. 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