ibes the pod index.
>
>
>
> Regards,
> Zhuo.
> ---- Replied Message ----
> | From | Alexis Sarda-Espinosa |
> | Date | 06/3/2024 14:19 |
> | To | |
> | Subject | Re: Native Kubernetes Task Managers |
> Ah no, I meant that I wouldn't use a stateful set, rather j
you mean by the naming scheme. I think the
> limitation "pods in a StatefulSet are always terminated in the reverse
> order as they are created" comes from Kubernetes and has nothing to do with
> the naming scheme.
>
> Best,
>
> Xintong
>
>
>
> On Mon, Jun 3, 2
er, since the
> diagnostics are from K8s, I'm not 100% sure whether this behavior is same
> for all K8s versions,.
>
> Best,
>
> Xintong
>
>
>
> On Sun, Jun 2, 2024 at 7:35 PM Alexis Sarda-Espinosa <
> sarda.espin...@gmail.com> wrote:
>
> > Hi devs,
&
Hi devs,
Some time ago I asked about the way Task Manager pods are handled by the
native Kubernetes driver [1]. I have now looked a bit through the source
code and I think it could be possible to deploy TMs with a stateful set,
which could allow tracking OOM kills as I mentioned in my original
Alexis Sarda-Espinosa created FLINK-34400:
-
Summary: Kafka sources with watermark alignment sporadically stop
consuming
Key: FLINK-34400
URL: https://issues.apache.org/jira/browse/FLINK-34400
Alexis Sarda-Espinosa created FLINK-34325:
-
Summary: Inconsistent state with data loss after OutOfMemoryError
in Job Manager
Key: FLINK-34325
URL: https://issues.apache.org/jira/browse/FLINK-34325
Alexis Sarda-Espinosa created FLINK-30638:
-
Summary: Operator doesn't forward allowNonRestoredState flag
Key: FLINK-30638
URL: https://issues.apache.org/jira/browse/FLINK-30638
Project: Flink
Alexis Sarda-Espinosa created FLINK-30306:
-
Summary: Audit utils can expose potentially sensitive information
Key: FLINK-30306
URL: https://issues.apache.org/jira/browse/FLINK-30306
Project
Alexis Sarda-Espinosa created FLINK-30305:
-
Summary: Operator deletes HA metadata during stateful upgrade,
preventing potential manual rollback
Key: FLINK-30305
URL: https://issues.apache.org/jira/browse
Alexis Sarda-Espinosa created FLINK-30115:
-
Summary: Include log4j-layout-template-json jar in the default
operator image
Key: FLINK-30115
URL: https://issues.apache.org/jira/browse/FLINK-30115
Alexis Sarda-Espinosa created FLINK-29716:
-
Summary: Separate slf4j jar in the lib folder from the distribution
Key: FLINK-29716
URL: https://issues.apache.org/jira/browse/FLINK-29716
Project
Alexis Sarda-Espinosa created FLINK-27504:
-
Summary: State compaction not happening with sliding window and
incremental RocksDB backend
Key: FLINK-27504
URL: https://issues.apache.org/jira/browse/FLINK
leased after the operator version that is being used, he/she
> > > would
> need
> > > to upgrade the operator version first?
> > > I'm not questioning this, just trying to make sure I'm
> > > understanding
> this
> > > correctly.
> > >
&
Hi everyone,
just wanted to mention that my employer agreed to open source the PoC I
developed: https://github.com/MicroFocus/opsb-flink-k8s-operator
I understand the concern for maintainability, so Gradle & Kotlin might not be
appealing to you, but at least it gives you another reference. The
mean an operator is a bad
idea, it's just something that other users might want to keep in mind.
Regards,
Alexis.
From: Robert Metzger
Sent: Thursday, January 20, 2022 7:06 PM
To: Alexis Sarda-Espinosa
Cc: dev ; user
Subject: Re: Flink native k8s integration vs
Hi everyone,
Since I see this is getting some traction, I’d like to add a couple things. I
had been developing a Kubernetes controller for Flink as a Proof of Concept at
my company; I called it Flork because it was to be a Flink Orchestrator for
Kubernetes. In the end, we will most likely not
Alexis Sarda-Espinosa created FLINK-21763:
-
Summary: Extend Data Stream's batch mode to handle
partitioning/grouping/ordering
Key: FLINK-21763
URL: https://issues.apache.org/jira/browse/FLINK-21763
Alexis Sarda-Espinosa created FLINK-10489:
-
Summary: Inconsistent window information for streams with
EventTime characteristic
Key: FLINK-10489
URL: https://issues.apache.org/jira/browse/FLINK-10489
Alexis Sarda-Espinosa created FLINK-10408:
-
Summary: Cannot use window information in Table functions
Key: FLINK-10408
URL: https://issues.apache.org/jira/browse/FLINK-10408
Project: Flink
Alexis Sarda-Espinosa created FLINK-10194:
-
Summary: Serialization issue with Scala's AggregateDataSet[Row]
Key: FLINK-10194
URL: https://issues.apache.org/jira/browse/FLINK-10194
Project
Alexis Sarda-Espinosa created FLINK-10126:
-
Summary: There should be a Scala DataSource
Key: FLINK-10126
URL: https://issues.apache.org/jira/browse/FLINK-10126
Project: Flink
Issue
21 matches
Mail list logo
