Hi,
I think it is rather unlikely that this is the problem because it should give
a different kind of exception. Would it be possible to provide a minimal and
self-contained example code for a problematic job?
Best,
Stefan
> On 15. Oct 2018, at 08:29, 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/
