The Apache Flink community is very happy to announce the release of Apache
Flink Kafka Connectors 3.0.2. This release is compatible with the Apache
Flink 1.17.x and 1.18.x release series.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing,
Hi Barak,
The missing class is in "flink-core", I think adding that dependency will
provide it.
The release notes for 1.14 note that Connectors no longer bundle
"flink-core". I imagine this is what has caused your issue.
hi,
I am trying to upgrade my app to Flink 1.18.
I have tests that run my stream from/to Embedded (in-memory) Kafka.
I.e. They create a flink cluster thus:
val flinkCluster = new MiniClusterWithClientResource(new
MiniClusterResourceConfiguration.Builder()
.setNumberSlotsPerTaskManager(2)
Regarding the inputQueueSize metric. What does it express after all?
Observing the inputQueueSize and inPoolUsage metrics in Prometheus,
I found that when the inPoolUsage is high, the inputQueueSize is low.
Thisobservation does not match the description of the inputQueueSize.
Therefore, does this
Ok, thanks for the clarification.
On Fri, Dec 1, 2023 at 2:05 PM Gyula Fóra wrote:
> Hi!
>
> I already answered your question on slack :
>
>
> “The main reason is that this allows us to completely separate release
> resources etc. much easier for the release process
>
> But this could be
Hi!
I already answered your question on slack :
“The main reason is that this allows us to completely separate release
resources etc. much easier for the release process
But this could be improved in the future if there is a good proposal for
the process”
Please do not cross post questions
Hi! I'm curious why there is not a single repo URL for the Flink Kubernetes
Operator Helm Chart, but multiples ones, one for each version. This forces
users to add one repo for each version, like this (directly from the docs):
```
helm repo add flink-operator-repo
I missed the Reply All button in my previous message. Here's my previous
email for the sake of transparency sent to the user ML once more:
Hi Oscar,
sorry for the late reply. I didn't see that you posted the question at the
beginning of the month already.
I used jmap [1] in the past to get some
