Re: reinterpretAsKeyedStream and Elastic Scaling in Reactive Mode

2022-01-08 Thread Martin
Hello David, > That is just to avoid falling back to Kryo serialization, which is less effective, but this IMO shouldn't break your application.  Thanks for that hint. I would have spend some hours working on that without fixing my issue. > Maybe can you try to check these for possible null values

Re: CVE-2021-44228 - Log4j2 vulnerability

2022-01-08 Thread David Morávek
Hi Suchithra, there is currently no plan on doing another 1.12 release D. On Sat 8. 1. 2022 at 18:02, V N, Suchithra (Nokia - IN/Bangalore) < suchithra@nokia.com> wrote: > Hi, > > > > When can we expect the flink 1.12 releases with log4j 2.17.1? > > > > Thanks, > > Suchithra > > > > *From:*

RE: CVE-2021-44228 - Log4j2 vulnerability

2022-01-08 Thread V N, Suchithra (Nokia - IN/Bangalore)
Hi, When can we expect the flink 1.12 releases with log4j 2.17.1? Thanks, Suchithra From: Martijn Visser Sent: Thursday, January 6, 2022 7:45 PM To: patrick.eif...@sony.com Cc: David Morávek ; swamy.haj...@gmail.com; subharaj.ma...@gmail.com; V N, Suchithra (Nokia - IN/Bangalore) ; Chesnay Sc

Re: Flink rest api to start a job

2022-01-08 Thread Qihua Yang
Hi Yun, Thank you for your reply! testB.jar doesn't have the same entry class as testA.jar. So is it expected behavior? What is the theory behind? Thanks, Qihua On Fri, Jan 7, 2022 at 4:27 PM Yun Gao wrote: > > Hi Qihua > > Sorry may I double confirm that whether the entry class exists in both

Creating DS in low level conversion operators i.e ProcessFunctions

2022-01-08 Thread Siddhesh Kalgaonkar
Hey Team, I have a flow like Kafka Sink Datastream -> Process Function (Separate Class) -> DBSink(Separate Class). Process Function returns me the output as a string and now I want to create a DataStream out of the string variable so that I can call something like ds.addSink(new DBSink()). For th

Re: reinterpretAsKeyedStream and Elastic Scaling in Reactive Mode

2022-01-08 Thread David Morávek
> > What I understand from the docs [1] and David A. answer on SO [2] is, that > I have to create for my POJOs with Lists and Maps TypeInfos. > That is just to avoid falling back to Kryo serialization, which is less effective, but this IMO shouldn't break your application. There might be of course

RE: Flink upgrade and rollback query

2022-01-08 Thread Deepti Sharma S
Hello Team, Could you please help us in below question. Regards, Deepti Sharma PMPR & ITIL From: Deepti Sharma S Sent: Friday, January 7, 2022 11:58 AM To: user@flink.apache.org Subject: Flink upgrade and rollback query Importance: High Hello Team, We are using Flink 1.

Re: Windowing on the consumer side

2022-01-08 Thread Flink Lover
Hi David, It happened due to lack of patience. I apologise. On Sat, Jan 8, 2022 at 3:06 PM David Morávek wrote: > I just have to answer to this. > > This was again cross posted on stackoverflow [1]. I think you seriously > need to rethink your behavior here. The cross posting is one thing, but

Re: Windowing on the consumer side

2022-01-08 Thread David Morávek
I just have to answer to this. This was again cross posted on stackoverflow [1]. I think you seriously need to rethink your behavior here. The cross posting is one thing, but creating a second "fake" email, so you can repeat the behavior you've been discouraged from [2], makes me feel that you don