Raymond Tay created FLINK-8327:
--
Summary: ClassLoader resolution of child-first does not appear to
work
Key: FLINK-8327
URL: https://issues.apache.org/jira/browse/FLINK-8327
Project: Flink
Issu
Hi Kostas & Ufuk,
Appreciate your detailed response. I'll give it a try.
Thanks,
Rafi
On Thu, Dec 28, 2017 at 5:16 PM, Ufuk Celebi wrote:
> Looks good to me, Klou. I would only add the following two things:
>
> 1) UIDs need to be unique for the complete program, so you would need
> more specif
Looks good to me, Klou. I would only add the following two things:
1) UIDs need to be unique for the complete program, so you would need
more specific ones, e.g. `filter-1-version-1` instead of only
`version-1`. These are used to map state from the savepoint back to
your program. We want to keep t
Hi again Rafi,
Coming back to the second part of the question on what you can do right now,
I would suggest that you launch your initial job with your initial patterns and
in your code you assign UID’s to your sources and the CEP operators, e.g.:
CEP.pattern(input, mySuperPattern).select(muSelec
Hi Rafi,
Currently this is unfortunately not supported out of the box.
To support this, we need 2 features with one having to be added in Flink itself,
and the other to the CEP library.
The first one is broadcast state and the ability to connect keyed and non-keyed
streams. This one is to be add
Wei-Che Wei created FLINK-8326:
--
Summary:
CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't
use the correct parameter to trigger test function
Key: FLINK-8326
URL: https://issues.apache.o
sunjincheng created FLINK-8325:
--
Summary: Add support for constant parameters in GROUP WINDOW
aggregate
Key: FLINK-8325
URL: https://issues.apache.org/jira/browse/FLINK-8325
Project: Flink
Issu
