Re: [ANNOUNCE] Apache Flink 2.0.0 released

2025-03-25 Thread Neelesh Salian
Congratulations! Regards, Neelesh S. Salian On Tue, Mar 25, 2025 at 15:50 Jark Wu wrote: > Congratulations! And thanks to all who made this release possible! > > Best, > Jark > > On Tue, 25 Mar 2025 at 14:46, Jingsong Li wrote: > >> Congratulations! >> >> Best, >> Jingsong >> >> On Tue, Mar

Simple Example for Flink Java

2017-05-12 Thread Neelesh Salian
Hi, I have a java program in a jar that parses some Spark Api and does a distcp action. I intend to add a window / interval of 5 mins (arbitrary time) for this jar to execute and do the function. What's the easiest way to make a window and run the above jar in it and make sure it runs every 5 min

Re: [DISCUSS] Drop Hadoop 1 support with Flink 1.2

2016-10-13 Thread Neelesh Salian
+1 to dropping Hadoop 1.x I am fairly certain there are very few legacy Hadoop users. 2.x is heavily used at the moment. Spark actually changed not just Hadoop but Python versions as well. Hadoop 3 would take a while to mature so I would suggest holding off on that after it is well baked in and us