Thanks a lot Andrea!
On 21 June 2017 at 8:36:32 PM, Andrea Spina (andrea.sp...@radicalbit.io) wrote:
I Gordon, sadly no news since the last message.
At the end I jumped over the issue, I was not able to solve it. I'll try
provide a runnable example asap.
Thank you.
Andrea
--
View thi
I Gordon, sadly no news since the last message.
At the end I jumped over the issue, I was not able to solve it. I'll try
provide a runnable example asap.
Thank you.
Andrea
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Painful-KryoExcept
Hi Andrea,
I’ve rallied back to this and wanted to check on the status. Have you managed
to solve this in the end, or is this still a problem for you?
If it’s still a problem, would you be able to provide a complete runnable
example job that can reproduce the problem (ideally via a git branch I
Hi guys,
thank you for your interest. Yes @Flavio, I tried both 1.2.0 and 1.3.0
versions.
Following Gordon suggestion I tried to put setReference to false but sadly
it didn't help. What I did then was to declare a custom serializer as the
following:
class BlockSerializer extends Serializer[Block
Yes it looks very similar to the Exception I experienced (
https://issues.apache.org/jira/browse/FLINK-6398) but my error was more
related to Row serialization/deserialization (see [1]) while this looks
more like something related to Kryo. However also with Flink 1.3.0 the
error seems to appear fro
@Flavio, doesn’t this look like the exception you often encountered a while
back? If I remember correctly that was fixed by Kurt, right?
Best,
Aljoscha
> On 7. Jun 2017, at 18:11, Tzu-Li (Gordon) Tai wrote:
>
> Hi Andrea,
>
> I did some quick issue searching, and it seems like this is a frequ
Hi Andrea,
I did some quick issue searching, and it seems like this is a frequently asked
issue on Kryo: https://github.com/EsotericSoftware/kryo/issues/428.
I can’t be sure at the moment if the resolution / workaround mentioned in there
makes sense, I’ll have to investigate a bit more.
Also,
Good afternoon dear Community,
Since few days I'm really struggling to understand the reason behind this
KryoException. Here the stack trace.
2017-06-07 10:18:52,514 ERROR org.apache.flink.runtime.operators.BatchTask
- Error in task code: CHAIN GroupReduce (GroupReduce at
my.or
