[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


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?


> On 15. Oct 2018, at 08:29, Averell <lvhuyen@xxxxxxxxx> 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/