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

["Bastian Köcher (JIRA)" <ji...@apache.org>]

Bastian Köcher created FLINK-963:
------------------------------------

             Summary: 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
    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)