test

Thanks & Regards, Samir Vasani

Re: java.lang.Exception: Job leader for job id 0efd8681eda64b072b72baef58722bc0 lost leadership.

how to unsubscribe? On Sat, Apr 16, 2022 at 3:21 AM Jai Patel wrote: > Hi Nico, > > Wanted to close the loop here. We did end up find a number of problems in > our code: > 1. Our operator was slow. It was iterating over several large Protobufs > in a MapState then filtering it down to 1.

Unsubscribed

Unsubscribe

Azure blob storage credential configuration in flink on ververica is giving java.lang.ClassNotFoundException

-1.13.1-stream1.jar:1.13.1-stream1] Caused by: org.apache.flink.fs.shaded.hadoop3.org.apache.hadoop.fs.azure.KeyProviderException: Unable to load key provider class. It seems that flink is unable to load user defined class . Is there any approach to load this user defined MyAppEnvironmentVariableKeyProvider class. Thanks & Regards, Samir Vasani

Re: Move already processed file from one folder to another folder in flink

me) FROM csvSource; > > This will, of course, add in a "useless" column and you'll have to deal > with it in your result file. > > For more on UDF, see > https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/functions/udfs/ > > Samir Vasani

Re: Unable to read a (text)file in FileProcessing.PROCESS_CONTINUOS mode

HI, Accessing file is not the problem. If i put the file before starting the job then this job reads it correctly but with if i add any file at runtime then it does not read this newly added files. Let me know if you need more information. Thanks & Regards, Samir Vasani On Mon, Aug 30,

Unable to read a (text)file in FileProcessing.PROCESS_CONTINUOS mode

9.2). Unlike windows path i changed the file location as per docker location but the same above program in not running there. Need help to find the solution. Thanks in advance. Thanks & Regards, Samir Vasani

How to keep flink batch job running continously on local

ob but the job finished in a matter of seconds. I want to keep the job running continuously so that I can test my use case . Can you guide my possible ways to achieve this? Thanks & Regards, Samir Vasani

Re: Move already processed file from one folder to another folder in flink

Hi, Let me know if you have any idea as this is very critical for my project. Thanks & Regards, Samir Vasani On Fri, Jul 23, 2021 at 1:26 PM Samir Vasani wrote: > Hi, > > Can you elaborate more on UDF as I did not understand it. > > Thanks & Regards, > Samir Vas

Re: Move already processed file from one folder to another folder in flink

Hi, Can you elaborate more on UDF as I did not understand it. Thanks & Regards, Samir Vasani On Fri, Jul 23, 2021 at 1:22 PM Caizhi Weng wrote: > Hi! > > In this case it won't work, as JobListener#onJobExecuted will only be > called when the job finishes, successfu

Re: Move already processed file from one folder to another folder in flink

suggestion work? Thanks & Regards, Samir Vasani On Fri, Jul 23, 2021 at 1:07 PM Caizhi Weng wrote: > Hi! > > JobListener#onJobExecuted might help, if your job is not a forever-running > streaming job. See > https://ci.apache.org/projects/flink/flink-docs-master/api/java/or

Move already processed file from one folder to another folder in flink

achieve this. Let me know if anything else is required. Samir Vasani

Flink user subscription request

Hi, This is the user subscription request. Thanks & Regards, Samir Vasani