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,

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 <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/