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/
