Re: [External] Re: Source vs SourceFunction and testing

2022-06-09 Thread Jing Ge
the FLIP-238 to be accepted? > > -Original Message- > From: Qingsheng Ren > Sent: jueves, 9 de junio de 2022 12:16 > To: Sanabria, Carlos > Cc: user > Subject: Re: [External] Re: Source vs SourceFunction and testing > > Hi Carlos, > > FLIP-238 [1] is proposing

RE: [External] Re: Source vs SourceFunction and testing

2022-06-09 Thread Sanabria, Carlos
? -Original Message- From: Qingsheng Ren Sent: jueves, 9 de junio de 2022 12:16 To: Sanabria, Carlos Cc: user Subject: Re: [External] Re: Source vs SourceFunction and testing Hi Carlos, FLIP-238 [1] is proposing a FLIP-27-based data generator source and I think this is what you are looking

Re: [External] Re: Source vs SourceFunction and testing

2022-06-09 Thread Qingsheng Ren
Hi Carlos, FLIP-238 [1] is proposing a FLIP-27-based data generator source and I think this is what you are looking for. This FLIP was created just days ago so it may take some time to get accepted and released. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-238%3A+Introduce+FLIP-27-

RE: [External] Re: Source vs SourceFunction and testing

2022-06-09 Thread Sanabria, Carlos
Hi everyone! Sorry for reopening the thread, but I am having some problems related to this case while migrating our code from Flink 1.12 to Flink 1.15. We have a base project that encapsulates a ton of common code and configurations. One of the abstractions we have is an AbstractDataStreamJob