Re: [ANNOUNCE] Apache Flink 1.17.2 released

Thanks Yun for driving the release. Thanks a lot to everyone that has contributed with bug fixes and other improvements! Best, Leonard > 2023年11月29日 下午1:05，Yun Tang 写道： > > The Apache Flink community is very happy to announce the release of Apache > Flink 1.17.2, which is the second bugfi

[ANNOUNCE] Apache Flink 1.17.2 released

The Apache Flink community is very happy to announce the release of Apache Flink 1.17.2, which is the second bugfix release for the Apache Flink 1.17 series. Apache Flink® Is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams. Flink h

Re: Re: inputQueueSize metric

Hi Dimitris Yes, the inputQueueLength metric can only represent the number of buffers, and cannot obtain the actual size of the messages. Regarding the inputQueueSize metric, it ignores the LocalChannel. Therefore, when tasks are connected through the Forward partition strategy, it will consisten

Flink listener for Task failures and restarts

Hi Team, When a flink job fails we use an implementation of joblistener interface to get an handle of onJobSubmitted(job submitted) and onJobExecuted(failure,success). But if my flink application has restart strategy enabled flink automatically restarts specific task(which fail). How do we get an

Re: How to call the open method of JdbcSink?

Hi Sai I think you can directly cast SinkFunction to GenericJdbcSinkFunction. https://github.com/apache/flink-connector-jdbc/blob/b477d452ba3aac38d53d1f5d4c4820bdad3ad9cd/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/JdbcSink.java#L63C41-L63C41 ``` public static SinkFun

Re: Flink SQL and createRemoteEnvironment

Hi, createRemoteEnvironment(...) methods have some obscure documentation. createRemoteEnvironment(String host,int port,String ... jarF

Re: Getting a list of tasks for a running job

Hi Yuxin, Added flink user group Thanks, Tauseef On Tue, 28 Nov 2023 at 11:38, Tauseef Janvekar wrote: > Hi Yuxin, > We have deployed it on kubernetes using helm chart - > https://github.com/bitnami/charts/blob/main/bitnami/flink/values.yaml > We have used ingress and enabled basic authenticat

Re: Job Manager and Task Manager unable to communicate

Adding flink user group On Tue, 28 Nov 2023 at 13:39, Tauseef Janvekar wrote: > Did you set some specific job manager or task manager deployment > parameters ? - No > > Did you test without the basic ingress auth ? to be sure this is not > related to that. - yes we did. And the problem persists.

FlinkSQL environment values in ddl

We started using several flinksql jobs in kubernetes cluster and would like to understand how to safely pass passwords and other sensitive data in the description of DDLs of tables. Is there any way to use pointers to environment variables? "This message contai