Hi all,
Making the tag a static element worked out, thank you!
---
Oytun Tez
*M O T A W O R D*
The World's Fastest Human Translation Platform.
oy...@motaword.com — www.motaword.com
On Tue, Apr 23, 2019 at 10:37 AM Oytun Tez wrote:
> Thank you Guowei and Dawid! I am trying your suggestions
Thank you Guowei and Dawid! I am trying your suggestions today and will
report back.
- I assume the cleaning operation should be done only once because of the
upgrade, or should I run every time the application is up?
- `static` sounds a very simple fix to get rid of this. Any drawbacks here?
Hi Oytun,
I think there is a regression introduced in 1.8 how we handle output
tags. The problem is we do not call ClosureCleaner on OutputTag.
There are two options how you can workaround this issue:
1. Declare the OutputTag static
2. Clean the closure explicitly as Guowei suggested:
I think you could try StreamExecutionEnvironment.clean(pendingProjectsTag).
Oytun Tez 于2019年4月19日 周五下午9:58写道：
> Forgot to answer one of your points: the parent class compiles well
> without this CEP selector (with timeout signature)...
>
>
> ---
> Oytun Tez
>
> *M O T A W O R D*
> The World's
Forgot to answer one of your points: the parent class compiles well without
this CEP selector (with timeout signature)...
---
Oytun Tez
*M O T A W O R D*
The World's Fastest Human Translation Platform.
oy...@motaword.com — www.motaword.com
On Fri, Apr 19, 2019 at 9:40 AM Oytun Tez wrote:
>
Hey JingsongLee!
Here are some findings...
- flatSelect *without timeout* works normally:
patternStream.flatSelect(PatternFlatSelectFunction), this compiles well.
- Converted the both timeout and select selectors to an *inner class*
(not static), yielded the same results, doesn't
Hi @Oytun Tez
It Looks like your PatternFlatSelectFunction is not serializable.
Because you use anonymous inner class, Check the class to which getPending
belongs, maybe that class is not serializable?
Or you may be advised not to use internal classes, but to use a static internal
class.
Best,
Hi all,
We are just migration from 1.6 to 1.8. I encountered a serialization error
which we didn't have before if memory serves: The implementation of the
*PatternFlatSelectAdapter* is not serializable. The object probably
contains or references non serializable fields.
The method below simply
