[jira] [Updated] (FLINK-963) Using ArrayList as second generic Tuple parameter doesn't work

["Ufuk Celebi (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ufuk Celebi updated FLINK-963:
------------------------------

    Component/s: Local Runtime

> Using ArrayList as second generic Tuple parameter doesn't work
> --------------------------------------------------------------
>
>                 Key: FLINK-963
>                 URL: https://issues.apache.org/jira/browse/FLINK-963
>             Project: Flink
>          Issue Type: Bug
>          Components: Local Runtime
>    Affects Versions: pre-apache-0.5.1
>            Reporter: Bastian Köcher
>
> I want to have a class like this
> "class ClusterHistory extends Tuple2<Integer, ArrayList<Tuple2<Integer, Integer>>>". 
> I already had a case where this was working and I could use an ArrayList as a second generic parameter. 
> Now I'm getting the following error:
> eu.stratosphere.nephele.client.JobExecutionException: org.apache.avro.AvroRuntimeException: Can't find element type of Collection
> 	at org.apache.avro.reflect.ReflectData.createSchema(ReflectData.java:430)
> 	at org.apache.avro.specific.SpecificData.getSchema(SpecificData.java:188)
> 	at org.apache.avro.reflect.ReflectDatumReader.<init>(ReflectDatumReader.java:46)
> 	at eu.stratosphere.api.java.typeutils.runtime.AvroSerializer.checkAvroInitialized(AvroSerializer.java:132)
> 	at eu.stratosphere.api.java.typeutils.runtime.AvroSerializer.serialize(AvroSerializer.java:102)
> 	at eu.stratosphere.api.java.typeutils.runtime.TupleSerializer.serialize(TupleSerializer.java:104)
> 	at eu.stratosphere.api.java.typeutils.runtime.TupleSerializer.serialize(TupleSerializer.java:26)
> 	at eu.stratosphere.pact.runtime.plugable.SerializationDelegate.write(SerializationDelegate.java:51)
> 	at eu.stratosphere.runtime.io.serialization.SpanningRecordSerializer.addRecord(SpanningRecordSerializer.java:70)
> 	at eu.stratosphere.runtime.io.api.RecordWriter.emit(RecordWriter.java:92)
> 	at eu.stratosphere.pact.runtime.shipping.OutputCollector.collect(OutputCollector.java:82)
> 	at eu.stratosphere.pact.runtime.task.DataSourceTask.invoke(DataSourceTask.java:209)
> 	at eu.stratosphere.nephele.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:284)
> 	at java.lang.Thread.run(Thread.java:745)
> 	at eu.stratosphere.nephele.client.JobClient.submitJobAndWait(JobClient.java:354)
> 	at eu.stratosphere.client.LocalExecutor.executePlan(LocalExecutor.java:222)
> 	at eu.stratosphere.api.java.LocalEnvironment.execute(LocalEnvironment.java:55)
> 	at eu.stratosphere.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:516)



--
This message was sent by Atlassian JIRA
(v6.2#6252)