cvinacuasonoc opened a new issue, #12785:
URL: https://github.com/apache/pinot/issues/12785

   On Pinot version 1.2.0-SNAPSHOT-3697552290f64b62e938152b891764adfb0ee031
   We get a NoSuchMethodError when ingesting Avro messages from Kafka.
   The same configuration works fine on Pinot version 1.0.0
   
   1    2024-04-03T10:26:01.458004170+00:00 stderr F    at 
java.base/java.lang.Thread.run(Thread.java:829)
   2024-04-03 12:26:01.611      2024-04-03T10:26:01.458004170+00:00 stderr F    
at 
org.apache.pinot.core.data.manager.realtime.RealtimeSegmentDataManager$PartitionConsumer.run(RealtimeSegmentDataManager.java:703)
   2024-04-03 12:26:01.611      2024-04-03T10:26:01.458004170+00:00 stderr F    
at 
org.apache.pinot.core.data.manager.realtime.RealtimeSegmentDataManager.consumeLoop(RealtimeSegmentDataManager.java:465)
   2024-04-03 12:26:01.611      2024-04-03T10:26:01.458004170+00:00 stderr F    
at 
org.apache.pinot.core.data.manager.realtime.RealtimeSegmentDataManager.processStreamEvents(RealtimeSegmentDataManager.java:576)
   2024-04-03 12:26:01.611      2024-04-03T10:26:01.458004170+00:00 stderr F    
at 
org.apache.pinot.spi.stream.StreamDataDecoderImpl.decode(StreamDataDecoderImpl.java:54)
   2024-04-03 12:26:01.611      2024-04-03T10:26:01.458004170+00:00 stderr F    
at 
org.apache.pinot.plugin.inputformat.avro.confluent.KafkaConfluentSchemaRegistryAvroMessageDecoder.decode(KafkaConfluentSchemaRegistryAvroMessageDecoder.java:53)
   2024-04-03 12:26:01.611      2024-04-03T10:26:01.458004170+00:00 stderr F    
at 
org.apache.pinot.plugin.inputformat.avro.confluent.KafkaConfluentSchemaRegistryAvroMessageDecoder.decode(KafkaConfluentSchemaRegistryAvroMessageDecoder.java:121)
   2024-04-03 12:26:01.610      2024-04-03T10:26:01.458004170+00:00 stderr F    
at 
org.apache.pinot.plugin.inputformat.avro.confluent.KafkaConfluentSchemaRegistryAvroMessageDecoder.decode(KafkaConfluentSchemaRegistryAvroMessageDecoder.java:111)
   2024-04-03 12:26:01.610      2024-04-03T10:26:01.458004170+00:00 stderr F    
at 
io.confluent.kafka.serializers.KafkaAvroDeserializer.deserialize(KafkaAvroDeserializer.java:103)
   2024-04-03 12:26:01.610      2024-04-03T10:26:01.458004170+00:00 stderr F    
at 
io.confluent.kafka.serializers.KafkaAvroDeserializer.deserialize(KafkaAvroDeserializer.java:108)
   2024-04-03 12:26:01.610      2024-04-03T10:26:01.458004170+00:00 stderr F    
at 
io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer.deserialize(AbstractKafkaAvroDeserializer.java:188)
   2024-04-03 12:26:01.610      2024-04-03T10:26:01.458004170+00:00 stderr F    
at 
io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer$DeserializationContext.read(AbstractKafkaAvroDeserializer.java:532)
   2024-04-03 12:26:01.610      2024-04-03T10:26:01.458004170+00:00 stderr F 
Exception in thread "sbts_edr_dlr__25__0__20240403T1024Z" 
java.lang.NoSuchMethodError: 'java.lang.Object 
io.confluent.kafka.serializers.AbstractKafkaAvroDeserializer.executeRules(java.lang.String,
 java.lang.String, 
org.apache.pinot.shaded.org.apache.kafka.common.header.Headers, 
java.lang.Object, 
io.confluent.kafka.schemaregistry.client.rest.entities.RuleMode, 
io.confluent.kafka.schemaregistry.ParsedSchema, 
io.confluent.kafka.schemaregistry.ParsedSchema, java.lang.Object)'
   2024-04-03 12:26:01.61
   
    


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to