avro-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kostas Margaritis <Kostas.Margari...@inps.co.uk>
Subject RE: java.lang.ClassCastException: java.util.ArrayList$Itr cannot be cast to org.apache.avro.generic.IndexedRecord
Date Tue, 04 Feb 2014 16:54:05 GMT
Hi all,

after many experiments of using camel-avro, I decided to send an email to the list as I'm
getting ClassCastException errors, even with simple schemas.
Java class from AVRO Schema file (avsc) generation works fine and the resulting class builds
and is included in the end project, but I can't really make it work.
Using Avro 1.7.5, and trying to send messages over jetty (using camel-avro and camel-jetty
resp), and using this schema:

{   "namespace" :   "serialisationtests.generated",
    "type"      :   "record",
    "name"      :   "TestPacket",
    "fields"    :   [
        { "name": "firstname", "type": "string" },
        { "name": "lastname",  "type": "string" },
        { "name": "date", "type" : "string" },
        { "name": "features", "type": {"type": "array", "items": "string"}},
        { "name": "properties", "type": {"type": "map", "values": "string"}}
    ]
}

I then use camel-dataset to produce such objects and then pass them through avro marshalling
to a jetty listener.
This is the exception I'm getting when trying to run mvn test:

-------------------------------------------------------
 T E S T S
-------------------------------------------------------
Running serialisationtests.test.SerialisationTest
[                          main] SerialisationTest              INFO  ********************************************************************************
[                          main] SerialisationTest              INFO  Testing: testReceivedDirectJettyMessages(serialisationtests.test.SerialisationTest)
[                          main] SerialisationTest              INFO  ********************************************************************************
[                          main] SpringCamelContext             INFO  Apache Camel 2.12.0.redhat-610336
(CamelContext: camel-1) is starting
[                          main] ManagedManagementStrategy      INFO  JMX is enabled
[                          main] DefaultTypeConverter           INFO  Loaded 186 type converters
[                          main] set://myDataSet?produceDelay=0 INFO  Endpoint[dataset://myDataSet?produceDelay=0]
expecting 6000 messages
[                          main] SpringCamelContext             INFO  StreamCaching is not
in use. If using streams then its recommended to enable stream caching. See more details at
http://camel.apache.org/stream-caching.html
[                          main] SpringCamelContext             INFO  Route: route1 started
and consuming from: Endpoint[dataset://myDataSet?produceDelay=0]
[                          main] JettyHttpComponent             WARN  You use localhost interface!
It means that no external connections will be available. Don't you want to use 0.0.0.0 instead
(all network interfaces)? Endpoint[http://localhost:8888/myservice]
[                          main] JettyHttpComponent             INFO  Using default Jetty
continuation timeout for: Endpoint[http://localhost:8888/myservice]
[                          main] Server                         INFO  jetty-8.1.9.v20130131
[                          main] AbstractConnector              INFO  Started SelectChannelConnector@localhost:8888
[                          main] SpringCamelContext             INFO  Route: route2 started
and consuming from: Endpoint[http://localhost:8888/myservice]
[                          main] SpringCamelContext             INFO  Total 2 routes, of which
2 is started.
[                          main] SpringCamelContext             INFO  Apache Camel 2.12.0.redhat-610336
(CamelContext: camel-1) started in 2.611 seconds
[                          main] MockEndpoint                   INFO  Asserting: Endpoint[mock://result-jetty]
is satisfied
[hread #0 - dataset://myDataSet] DefaultErrorHandler            ERROR Failed delivery for
(MessageId: ID-pippin-46409-1391532031804-0-1 on ExchangeId: ID-pippin-46409-1391532031804-0-2).
Exhausted after delivery attempt: 1 caught: java.lang.ClassCastException: java.util.ArrayList$Itr
cannot be cast to org.apache.avro.generic.IndexedRecord

Message History
---------------------------------------------------------------------------------------------------------------------------------------
RouteId              ProcessorId          Processor                                      
                                 Elapsed (ms)
[route1            ] [route1            ] [dataset://myDataSet?produceDelay=0            
                               ] [        81]
[route1            ] [marshal1          ] [marshal[ref:avro]                             
                               ] [        69]

Exchange
---------------------------------------------------------------------------------------------------------------------------------------
Exchange[
        Id                  ID-pippin-46409-1391532031804-0-2
        ExchangePattern     InOnly
        Headers             {breadcrumbId=ID-pippin-46409-1391532031804-0-1, CamelDataSetIndex=0,
CamelRedelivered=false, CamelRedeliveryCounter=0}
        BodyType            java.util.ArrayList.Itr
        Body                java.util.ArrayList$Itr@104ff98
]

Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
java.lang.ClassCastException: java.util.ArrayList$Itr cannot be cast to org.apache.avro.generic.IndexedRecord
        at org.apache.avro.generic.GenericData.getField(GenericData.java:576)[avro-1.7.5.jar:1.7.5]
        at org.apache.avro.generic.GenericData.getField(GenericData.java:591)[avro-1.7.5.jar:1.7.5]
        at org.apache.avro.generic.GenericDatumWriter.writeField(GenericDatumWriter.java:112)[avro-1.7.5.jar:1.7.5]
        at org.apache.avro.generic.GenericDatumWriter.writeRecord(GenericDatumWriter.java:104)[avro-1.7.5.jar:1.7.5]
        at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:66)[avro-1.7.5.jar:1.7.5]
        at org.apache.avro.generic.GenericDatumWriter.write(GenericDatumWriter.java:58)[avro-1.7.5.jar:1.7.5]
        at org.apache.camel.dataformat.avro.AvroDataFormat.marshal(AvroDataFormat.java:124)[camel-avro-2.12.0.redhat-610336.jar:2.12.0.redhat-610336]
        at org.apache.camel.processor.MarshalProcessor.process(MarshalProcessor.java:81)[camel-core-2.12.0.redhat-610336.jar:2.12.0.redhat-610336]
        at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72)[camel-core-2.12.0.redhat-610336.jar:2.12.0.redhat-610336]
        at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:398)[camel-core-2.12.0.redhat-610336.jar:2.12.0.redhat-610336]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[camel-core-2.12.0.redhat-610336.jar:2.12.0.redhat-610336]
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:118)[camel-core-2.12.0.redhat-610336.jar:2.12.0.redhat-610336]
        at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[camel-core-2.12.0.redhat-610336.jar:2.12.0.redhat-610336]
        at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191)[camel-core-2.12.0.redhat-610336.jar:2.12.0.redhat-610336]
        at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:105)[camel-core-2.12.0.redhat-610336.jar:2.12.0.redhat-610336]
        at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:87)[camel-core-2.12.0.redhat-610336.jar:2.12.0.redhat-610336]
        at org.apache.camel.component.dataset.DataSetConsumer.sendMessages(DataSetConsumer.java:89)[camel-core-2.12.0.redhat-610336.jar:2.12.0.redhat-610336]
        at org.apache.camel.component.dataset.DataSetConsumer$1.run(DataSetConsumer.java:70)[camel-core-2.12.0.redhat-610336.jar:2.12.0.redhat-610336]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1146)[:1.6.0_29]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.6.0_29]
        at java.lang.Thread.run(Thread.java:701)[:1.6.0_29]
[hread #0 - dataset://myDataSet] DefaultErrorHandler            ERROR Failed delivery for
(MessageId: ID-pippin-46409-1391532031804-0-3 on ExchangeId: ID-pippin-46409-1391532031804-0-4).
Exhausted after delivery attempt: 1 caught: java.lang.ClassCastException: java.util.ArrayList$Itr
cannot be cast to org.apache.avro.generic.IndexedRecord


Any suggestions/solutions appreciated.

Thanks

Kostas Margaritis

Mime
View raw message