Hi Chesnay,
added it to the Gist but also here:
10/10/2016 14:00:44 Job execution switched to status FAILING.
java.lang.ClassCastException: java.lang.Long cannot be cast to
[Ljava.lang.Object;
at
org.apache.flink.api.common.typeutils.base.GenericArraySerializer.serialize(GenericArraySerializer.java:36)
at
org.apache.flink.api.common.typeutils.base.GenericArraySerializer.serialize(GenericArraySerializer.java:112)
at
org.apache.flink.api.common.typeutils.base.GenericArraySerializer.serialize(GenericArraySerializer.java:36)
at
org.apache.flink.api.java.typeutils.runtime.TupleSerializer.serialize(TupleSerializer.java:124)
at
org.apache.flink.api.java.typeutils.runtime.TupleSerializer.serialize(TupleSerializer.java:30)
at
org.apache.flink.runtime.plugable.SerializationDelegate.write(SerializationDelegate.java:56)
at
org.apache.flink.runtime.io.network.api.serialization.SpanningRecordSerializer.addRecord(SpanningRecordSerializer.java:83)
at
org.apache.flink.runtime.io.network.api.writer.RecordWriter.emit(RecordWriter.java:85)
at
org.apache.flink.runtime.operators.shipping.OutputCollector.collect(OutputCollector.java:65)
at
org.apache.flink.runtime.operators.util.metrics.CountingCollector.collect(CountingCollector.java:35)
at org.gradoop.examples.TypeProblem$2.join(TypeProblem.java:61)
at org.gradoop.examples.TypeProblem$2.join(TypeProblem.java:57)
at
org.apache.flink.runtime.operators.hash.NonReusingBuildFirstHashJoinIterator.callWithNextKey(NonReusingBuildFirstHashJoinIterator.java:149)
at
org.apache.flink.runtime.operators.JoinDriver.run(JoinDriver.java:222)
at org.apache.flink.runtime.operators.BatchTask.run(BatchTask.java:486)
at
org.apache.flink.runtime.operators.BatchTask.invoke(BatchTask.java:351)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:584)
at java.lang.Thread.run(Thread.java:745)
On 10.10.2016 13:39, Chesnay Schepler wrote:
Hello Martin,
Could you include the error you are getting?
Regards,
Chesnay
On 10.10.2016 13:31, Martin Junghanns wrote:
Hi,
I ran into a problem when using generic arrays in a tuple. I wrote a
minimal program to reproduce the error [1].
The problem seems to be related to the order of tuple fields. When
I switch Tuple2<K[], K> to Tuple2<K, K[]> and perform the join on
field 0, everything works as expected.
Using Flink 1.1.2.
Cheers,
Martin
[1] https://gist.github.com/s1ck/37aefb19198cd01a8b998fab354c2cfd
