Jacky Lau created FLINK-34556:
-
Summary: Migrate EnumerableToLogicalTableScan
Key: FLINK-34556
URL: https://issues.apache.org/jira/browse/FLINK-34556
Project: Flink
Issue Type: Sub-task
Hi Piotr,
Thanks for your thoughtful feedback!
In fact, we had a lot of internal debates on this topic :). The proposal
you mentioned is one of several possible alternatives we've considered. It
works well for simple use cases of ValueState or ListState, where users
typically read state by
Jacky Lau created FLINK-34555:
-
Summary: Migrate JoinConditionTypeCoerceRule
Key: FLINK-34555
URL: https://issues.apache.org/jira/browse/FLINK-34555
Project: Flink
Issue Type: Sub-task
Hilmi Al Fatih created FLINK-34554:
--
Summary: Using EXACTLY_ONCE with KafkaSink cause broker's OOM due
to newly created transactionalId per checkpoint
Key: FLINK-34554
URL:
Mehmet Aktas created FLINK-34553:
Summary: Time travel support by Flink catalogs
Key: FLINK-34553
URL: https://issues.apache.org/jira/browse/FLINK-34553
Project: Flink
Issue Type: Technical
Hey Robert,
Awesome thanks, that timeline works for me. Sounds good re: deciding on
FLIP once we have the PR, and thanks for looking into the field ids.
Looking forward to it!
On Thu, Feb 29, 2024 at 5:09 AM Robert Metzger wrote:
> Hey Kevin,
>
> Thanks a lot. Then let's contribute the
Sergey Anokhovskiy created FLINK-34552:
--
Summary: Support message deduplication for input data sources
Key: FLINK-34552
URL: https://issues.apache.org/jira/browse/FLINK-34552
Project: Flink
Matthias Pohl created FLINK-34551:
-
Summary: Align retry mechanisms of FutureUtils
Key: FLINK-34551
URL: https://issues.apache.org/jira/browse/FLINK-34551
Project: Flink
Issue Type:
Hi!
Thanks for this proposal. It looks like it will be a great improvement!
I've only started reading the FLIP's, but I already have some questions
about the FLIP-425, the async execution.
What's the motivation behind splitting execution of a single element into
multiple independent steps in
The Apache Flink community is very happy to announce the release of
Apache flink-connector-parent 1.1.0.
Apache Flink® is an open-source stream processing framework for
distributed, high-performing, always-available, and accurate data
streaming applications.
The release is available for
siwei.gao created FLINK-34550:
-
Summary: attempted task still report metric of
currentEmitEventTimeLag
Key: FLINK-34550
URL: https://issues.apache.org/jira/browse/FLINK-34550
Project: Flink
Weijie Guo created FLINK-34549:
--
Summary: FLIP-410: Config, Context and Processing Timer Service of
DataStream API V2
Key: FLINK-34549
URL: https://issues.apache.org/jira/browse/FLINK-34549
Project:
Weijie Guo created FLINK-34548:
--
Summary: FLIP-409: DataStream V2 Building Blocks: DataStream,
Partitioning and ProcessFunction
Key: FLINK-34548
URL: https://issues.apache.org/jira/browse/FLINK-34548
Weijie Guo created FLINK-34547:
--
Summary: Flink DataStream API V2
Key: FLINK-34547
URL: https://issues.apache.org/jira/browse/FLINK-34547
Project: Flink
Issue Type: New Feature
Hi devs,
I'm happy to announce that FLIP-410: Config, Context and Processing
Timer Service of DataStream API V2 [1] has been accepted with 5
approving votes (4 binding) [2]:
- Xintong Song (binding)
- Weijie Guo (binding)
- Rui Fan (binding)
- Xuannan Su (non-binding)
- Guowei Ma (binding)
Hi devs,
I'm happy to announce that FLIP-409: DataStream V2 Building Blocks:
DataStream, Partitioning and ProcessFunction [1] has been accepted
with 5 approving votes (4 binding) [2]:
- Xintong Song (binding)
- Weijie Guo (binding)
- Rui Fan (binding)
- Guowei Ma (binding)
- Xuannan Su
Hi devs,
I'm happy to announce that FLIP-408: [Umbrella] Introduce DataStream
API V2 [1] has been accepted with 5 approving votes (4 binding) [2]:
- Xintong Song (binding)
- Weijie Guo (binding)
- Xuannan Su (non-binding)
- Rui Fan (binding)
- Guowei Ma (binding)
There are no
Hi Venkat,
As Lijie mentioned, in Flink, the parallelism is required to be less than
or equal to the maximum parallelism. The config option
jobmanager.adaptive-batch-scheduler.max-parallelism and
jobmanager.adaptive-batch-scheduler.default-source-parallelism will be set
as the source's
Hey Kevin,
Thanks a lot. Then let's contribute the Confluent implementation to
apache/flink. We can't start working on this immediately because of a team
event next week, but within the next two weeks, we will start working on
this.
It probably makes sense for us to open a pull request of what we
Hi Venkat,
>> default-source-parallelism config should be independent from the
max-parallelism
Actually, it's not.
Firstly, it's obvious that the parallelism should be less than or equal to
the max parallelism(both literally and execution). The
Stefan Richter created FLINK-34546:
--
Summary: Emit span with failure labels on failure
Key: FLINK-34546
URL: https://issues.apache.org/jira/browse/FLINK-34546
Project: Flink
Issue Type:
Thanks, this looks similar. I'll do some work around.
On Thu, Feb 29, 2024 at 5:15 PM Aleksandr Pilipenko
wrote:
> Based on the stacktrace, this looks like an issue described here:
> https://issues.apache.org/jira/browse/FLINK-32964
> Is your configuration similar to the one described in the
Based on the stacktrace, this looks like an issue described here:
https://issues.apache.org/jira/browse/FLINK-32964
Is your configuration similar to the one described in the ticket? If so,
you can work around this issue by explicitly specifying the credentials
provider for connector, by doing so
Thank you Marton and Martijn, I will proceed with the FLIP then.
Best,
Ferenc
On Wednesday, February 28th, 2024 at 21:15, Martijn Visser
wrote:
>
>
> Hi all,
>
> +1 to have a connector FLIP to propose a Kudu connector. I'm +0 overall
> because I don't see a lot of activity happening in
He Wang created FLINK-34545:
---
Summary: Add OceanBase pipeline connector to Flink CDC
Key: FLINK-34545
URL: https://issues.apache.org/jira/browse/FLINK-34545
Project: Flink
Issue Type: New Feature
25 matches
Mail list logo
