osdir.com


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Error restoring from savepoint while there's no modification to the job


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/