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)
Locked
