Re: Flink/Scala contract positions ?

Hi Jing, thanks for reaching back are you offering a contract Job to fix Flink Scala to fix Scala API for Flink? yes, I would be interested we can talk if you want to schedule some time? Thanks Sri On Fri, Jun 3, 2022 at 9:00 AM Jing Ge wrote: > Hi, > > Currently, the Flink Scala API is not in

Re: Flink/Scala contract positions ?

Hi, Currently, the Flink Scala API is not in a good shape. Would you like to start from there? Best regards, Jing On Fri, Jun 3, 2022 at 4:29 PM sri hari kali charan Tummala < kali.tumm...@gmail.com> wrote: > Hi Folks, > > Is anyone hiring for Flink or Scala Akka contract corp to corp positions

Flink/Scala contract positions ?

Hi Folks, Is anyone hiring for Flink or Scala Akka contract corp to corp positions ? I am open in market looking for work in Scala Spark or Flink Scala or Scala Akka world. Thanks Sri

Unable to retrieve savepoint status from non-leader/standby in HA with Flink 1.15

Hello everyone! Our current setup has us running Flink on Kubernetes in HA mode (Zookeeper) with multiple JobManagers. This appears to be a regression from 1.14. We can use the flink CLI to communicate with the REST API to reproduce this. We directly target a standby JobManager (by using `kubectl

Re: [ANNOUNCE] Welcome to join the Apache Flink community on Slack

Thanks, Xintong and Jark the great effort driving this, and everyone for making this possible. I've also Twittered this announcement on our Apache Flink Twitter account. Best Yuan On Fri, Jun 3, 2022 at 12:54 AM Jing Ge wrote: > Thanks everyone for your effort! > > Best regards, > Jing > >

Re: Flink task stuck - MapPartition WAITING on java.util.concurrent.CompletableFuture$Signaller

Hi Jan, This is a batch job so no windows. It is basically a job launched by a TFX component, so I don't have control over Beam code being executed. I conclude that the job is stuck, since the number of bytes and processed rows do not move for a long time on a specific task and subtask (always the

Re: flink-ml algorithms

Hi, It seems like an evaluation with a small dataset. In this case, would you like to share your data sample and code? In addition, have you tried KMeans with the same dataset and got inconsistent results too? Best regards, Jing On Fri, Jun 3, 2022 at 4:29 AM Natia Chachkhiani < natia.chachkhia.

Re: Issue Facing While Using EmbeddedRocksDbCheckpointing FlinkVersion(1.15.0)

Hi, I guess that the traceback log you provided might not be the root cause of the failure, could you please provide the complete log of the Taskmanager？ Best, Shuiqiang harshit.varsh...@iktara.ai 于2022年6月2日周四 22:04写道： > Dear Team, > > > > I am new to pyflink and request for your support in is