Hi Averell,
This could be the root cause of your problem!
Thanks for digging into it.
Would it be possible for you to verify that this is your problem by manually
setting
the UUID and seeing if the problem disappears? In addition, please file a JIRA.
Thanks a lot,
Kostas
> On Oct 15, 2018, at 8:29 AM, Averell <lvhu...@gmail.com> wrote:
>
> Hi everyone,
>
> In the StreamExecutionEnvironment.createFileInput method, a file source is
> created as following:
> /SingleOutputStreamOperator<OUT> source =
> *addSource*(monitoringFunction,
> sourceName)
> .*transform*("Split Reader: " + sourceName,
> typeInfo, reader);/
>
> Does this create two different operators? If yes, then it seems impossible
> to assign a UID to the 1st operator. And might it be the cause for my
> problem?
>
> Thanks and best regards,
> Averell
>
>
>
> --
> Sent from:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
