Re: Opensearch Connector for Flink 1.18+

Hi, Kirti. We already have a 2.0.0 version in maven repo[1] for Opensearch connector for Flink 1.18/1.19. But it should be noted that this version is built on JDK11[2]. [1] https://mvnrepository.com/artifact/org.apache.flink/flink-connector-opensearch2 [2] https://lists.apache.org/thread/3w1rnj

Opensearch Connector for Flink 1.18+

Hi, Currently we are using Flink 1.16.3 with Opensearch connector version 1.0.1-1.16 as per link below: https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/datastream/opensearch/ Now, we want to upgrade Flink version to 1.18+, but found that there no Opensearch connector

Tenantive Flink 2.0 release date?

Hi, We are planning to explore Flink CDC for our CDC pipelines and have quickly noticed that Flink CDC is still using DBZ 1.9.2.Final. DBZ 2.0.0.Final is a major release that requires JDK 11, while the latest version, DBZ 3.0.0.Final, requires JDK 17. Currently, Flink CDC 3.2.0 is using Flink 1.1

Re:Backpressure causing operators to stop ingestion completely

Hi,  you can use flame_graphs to debug https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/ops/debugging/flame_graphs/ -- Original -- From: