[ANNOUNCE] Apache flink-connector-gcp-pubsub 3.0.2 released

The Apache Flink community is very happy to announce the release of Apache flink-connector-gcp-pubsub v3.0.2 with support for Flink 1.17 and 1.18. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data streaming application

RE: Deploying the K8S operator sample on GKE Autopilot : Association with remote system [akka.tcp://flink@basic-example.default:6123] has failed,

Hi, Some more tests results from the task/job managers pod : From task manager I cannot connect to job manager: root@basic-example-taskmanager-5d54f9f94-rbcr4:/opt/flink# wget basic-example.default:6123 --2024-01-12 15:16:15-- http://basic-example.default:6123/ Resolving basic-example.default (b

Re: Flink pending record metric weired after autoscaler rescaling

Yes, https://issues.apache.org/jira/browse/FLINK-34063 does match quite well the issues I have encountered. I'll leave a comment in that ticket then. Thanks, Yang On Fri, 12 Jan 2024 at 15:39, Gyula Fóra wrote: > Could this be related to the is

Re: Flink pending record metric weired after autoscaler rescaling

Could this be related to the issue reported here? https://issues.apache.org/jira/browse/FLINK-34063 Gyula On Wed, Jan 10, 2024 at 4:04 PM Yang LI wrote: > Just to give more context, my setup uses Apache Flink 1.18 with the > adaptive scheduler enabled, issues happen randomly particularly > post

FW: Deploying the K8S operator sample on GKE Autopilot : Association with remote system [akka.tcp://flink@basic-example.default:6123] has failed,

Hello, I am trying to follow the “quickstart” guide on a GKE Autopilot k8s cluster. https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-main/docs/try-flink-kubernetes-operator/quick-start/ I could install the operator (without webhook) without issue ; however, when running kubectl c

Re: Rabbitmq connector for Flink v1.18

Hi Charlotta, I've just pushed out a vote for RabbitMQ connector v3.0.2 which includes support for Flink 1.18. See https://lists.apache.org/thread/jmpmrnnwv6yw4ol1zjc5t0frz67jpnqr Best regards, Martijn On Tue, Jan 9, 2024 at 1:08 PM Jiabao Sun wrote: > > Hi Charlotta, > > The latest news about

Re: Flink 1.17 with Scala 2.13 or Scala 3

Hi Patrick, You need to make sure, the pre-packaged Scala runtime is removed from the Flink docker image: > rm flink-dist/lib/flink-scala* This is also mentioned in the Flink blog-post Martijn mentioned earlier. The smallest reproducible example would be required, if you want us to find the ro