Re: Understanding flink-autoscaler behavior

2024-06-07 Thread Sachin Sharma
) controls the parallelism or the Reactive mode in the Flink job controls it. Thanks & Regards, Sachin Sharma On Fri, Jun 7, 2024 at 4:55 AM Gyula Fóra wrote: > Hi! > > To simplify things you can generally look at TRUE_PROCESSING_RATE, > SCALUE_UP_RATE_THRESHOLD and SCALE_DOWN_RATE_THR

Flink 1.19.1 Java 17 Compatibility

2024-09-12 Thread Sachin Sharma
Hi, We are planning to use Flink 1.19.1 with kubernetes operator, I wanted to check if 1.19.1 is Java 17 compatible or not. In documentation it says in version 1.18 we added experimental support for it but nothing concrete is said whether it supports Java 17 completely. Thanks & Regards, Sa

Dynamic configuration FlinkDeployment with Kubernetes Operator 1.9

2024-09-12 Thread Sachin Sharma
along with many other properties. Thanks & Regards, Sachin Sharma +1-669-278-5239

Re: Flink 1.19.1 Java 17 Compatibility

2024-09-17 Thread Sachin Sharma
Thanks Zhanghao and Andreas. Thanks & Regards, Sachin Sharma +1-669-278-5239 On Tue, Sep 17, 2024 at 6:04 AM Zhanghao Chen wrote: > In our production environment, it works fine. > > Best, > Zhanghao Chen > ------ > *From:* Sachin Sharma >

Flink 1.15.4 JobGraphs not compatible with 1.19.1

2024-09-17 Thread Sachin Sharma
e.completeThrowable(Unknown > Source)\n\tat > java.util.concurrent.CompletableFuture$UniApply.tryFire(Unknown > Source)\n\tat java.util.concurrent.CompletableFuture$Completion.run(Unknown > Source)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown > Source)\n\t... 2 frames truncated > What should I do to make it compatible? Thanks & Regards, Sachin Sharma +1-669-278-5239