Hi,
I also had this problem and solved it.
In my case I had multiple objects which are created via anonymous
classes. When I broadcasted these objects, the serializer tried to
serialize the objects and for that it tried to serialize the anonymous
classes. This caused the problem.
For example
Hi!
Is it possible that some datatype has a recursive structure nonetheless?
Something like a linked list or so, which would create a large object graph?
There seems to be a large object graph that the Kryo serializer traverses,
which causes the StackOverflowError.
Greetings,
Stephan
On Sun, A
+1 I think the changes are good. Thanks!
On Sun, Apr 10, 2016 at 2:34 PM, Matthias J. Sax wrote:
> Done.
>
> This is a preview: https://github.com/mjsax/flink-web/tree/broken-links
>
> Please let me know if I can push it. (Maybe someone can verify, that I
> did not miss anything...)
>
> -Matthias
Hi Stephan,
thanks for answering.
This not from a recursive object. (it is used in a recursive method in the test
that is throwing this error, but the the depth is only 2 and there are no other
Flink DataSet operations before execution is triggered so it is trivial.)
Gere is a Gist of the code
Hi!
Sorry, I don't fully understand he diagnosis.
You say that this stack overflow is not from a recursive/object type?
Long graphs of operations in Flink usually do not cause
StackOverflowExceptions, because not the whole graph is recursively
processed.
Can you paste the entire Stack Trace (for
Done.
This is a preview: https://github.com/mjsax/flink-web/tree/broken-links
Please let me know if I can push it. (Maybe someone can verify, that I
did not miss anything...)
-Matthias
On 04/07/2016 04:41 PM, Stephan Ewen wrote:
> Hey Matthias!
>
> The mailing list and feature requests are ge
I don't know how close Phoenix' code style is to Flink's de-facto code
style.
I would create one that reflects Flink's de-facto code style, so that the
formatter does not change everything...
On Sun, Apr 10, 2016 at 4:40 AM, Naveen Madhire
wrote:
> Apache Phoenix has one code template which cont
Yijie Shen created FLINK-3723:
-
Summary: Aggregate Functions and scalar expressions shouldn't be
mixed in select
Key: FLINK-3723
URL: https://issues.apache.org/jira/browse/FLINK-3723
Project: Flink
