Re: Apache Flink - Uid and name for Flink sources and sinks

2019-11-25 Thread M Singh
Thanks DIan for your pointers.  MansOn Sunday, November 24, 2019, 08:57:53 PM EST, Dian Fu wrote: Hi Mans, Please see my reply inline below. 在 2019年11月25日,上午5:42,M Singh 写道: Thanks Dian for your answers. A few more questions: 1. If I do not assign uids to operators/sources and sink

Re: Apache Flink - Uid and name for Flink sources and sinks

2019-11-24 Thread Dian Fu
Hi Mans, Please see my reply inline below. > 在 2019年11月25日,上午5:42,M Singh 写道: > > Thanks Dian for your answers. > > A few more questions: > > 1. If I do not assign uids to operators/sources and sinks - I am assuming the > framework assigns it one. Now how does another run of the the same

Re: Apache Flink - Uid and name for Flink sources and sinks

2019-11-24 Thread M Singh
Thanks Dian for your answers. A few more questions: 1. If I do not assign uids to operators/sources and sinks - I am assuming the framework assigns it one.  Now how does another run of the the same application using the previous runs savepoint/checkpoint match it's tasks/operators to the savepo

Re: Apache Flink - Uid and name for Flink sources and sinks

2019-11-24 Thread Dian Fu
1. Should we assign uid and name to the sources and sinks too ? >> If the sources/sinks have used state, you should assign uid for them. This is usually true for sources. 2. What are the pros and cons of adding uid to sources and sinks ? >> I'm not seeing the cons for assigning uid to sources and

Re: Apache Flink - Uid and name for Flink sources and sinks

2019-11-22 Thread M Singh
Hi Folks - Please let me know if you have any advice on the best practices for setting uid for sources and sinks.  Thanks.  MansOn Thursday, November 21, 2019, 10:10:49 PM EST, M Singh wrote: Hi Folks: I am assigning uid and name for all stateful processors in our application and wan

Apache Flink - Uid and name for Flink sources and sinks

2019-11-21 Thread M Singh
Hi Folks: I am assigning uid and name for all stateful processors in our application and wanted to find out the following: 1. Should we assign uid and name to the sources and sinks too ?  2. What are the pros and cons of adding uid to sources and sinks ?3. The sinks have uid and hashUid - which