Hongshun Wang created FLINK-35387:
-
Summary: PG CDC source support heart beat
Key: FLINK-35387
URL: https://issues.apache.org/jira/browse/FLINK-35387
Project: Flink
Issue Type: Bug
AFAIK, the main purpose of having `run-application` was to make sure
the user is aware that application mode is used, which executes the main
method of the user program in JM rather than in client. This was important
at the time application mode was first introduced, but maybe not that
important an
Qingsheng Ren created FLINK-35386:
-
Summary: Build Flink CDC 3.1 Documentation and mark it as stable
Key: FLINK-35386
URL: https://issues.apache.org/jira/browse/FLINK-35386
Project: Flink
Iss
Hi Jane,
Thank Jane for driving this proposal !
This makes sense for users, +1 for that.
Best,
Yubin
On Thu, May 16, 2024 at 3:17 PM Jark Wu wrote:
>
> Hi Jane,
>
> Thanks for the proposal. +1 from my side.
>
>
> Best,
> Jark
>
> On Thu, 16 May 2024 at 10:28, Xuannan Su wrote:
>
> > Hi Jane,
Hongshun Wang created FLINK-35385:
-
Summary: upgrader flink dependency version to 1.19
Key: FLINK-35385
URL: https://issues.apache.org/jira/browse/FLINK-35385
Project: Flink
Issue Type: Impro
Hi, Tucker
IIUC, this way is unsupported. You may try other way to work around it.
--
Best！
Xuyang
At 2024-05-17 00:22:57, "Tucker Harvey" wrote:
>Hi Xuyang,
>
>Thanks for your response. I can provide some better context, we are migrating
>a use case to FlinkSQL and they wa
Thanks for driving this proposal!
+1 (binding)
Best,
Jiabao
On 2024/05/10 22:18:04 Jeyhun Karimov wrote:
> Thanks for driving this!
>
> +1 (non-binding)
>
> Regards,
> Jeyhun
>
> On Fri, May 10, 2024 at 12:50 PM Muhammet Orazov
> wrote:
>
> > Thanks João for your efforts and driving this!
Hi everyone,
I'm happy to announce that we have unanimously approved this release.
There are 7 approving votes, 3 of which are binding:
- Hang Ruan (non-binding)
- Yanquan Lv (non-binding)
- Leonard Xu (binding)
- Jiabao Sun (non-binding)
- Zhongqiang Gong (non-binding)
- Jark Wu (binding)
- Jin
Hi Keith Lee,
Yeah, I think it makes sense that large changes to documentation should be
FLIP worthy. We've done it before when we reorganized the project website
as well.
>From a strict point of view, we can't retrospectively change an accepted
FLIP: we can create a new FLIP that refers to the o
Hi Martijn
Thank you for pointing me to this FLIP. I initially thought of making
limited scoped improvement hence the Jira.
Given that the Flip was voted on more than four years ago. Would it make
sense to for me to update the FLIP, reopen discussion and redrive a vote
for it?
On a side note, sh
>, it looks like opensearch-2.0.0 has been created now, all good.
yep, thanks to Martijn
I've created RCs for Opensearch connector
On Tue, May 14, 2024 at 12:38 PM Danny Cranmer
wrote:
> Hello,
>
> @Sergey Nuyanzin , it looks like opensearch-2.0.0
> has been created now, all good.
>
> @Hongshun
Hi,
I am trying to implement a custom range partitioner in the Flink Iceberg
sink. Want to publish some counter metrics for certain scenarios. This is
like the network metrics exposed in `TaskIOMetricGroup`.
This requires adding a new setup method to the custom `Partitioner`
interface. Like to ge
Steven Zhen Wu created FLINK-35384:
--
Summary: Expose metrics group to custom Partitioner
Key: FLINK-35384
URL: https://issues.apache.org/jira/browse/FLINK-35384
Project: Flink
Issue Type: Im
Aleksandr Pilipenko created FLINK-35383:
---
Summary: Update compatibility matrix to include 1.19 release
Key: FLINK-35383
URL: https://issues.apache.org/jira/browse/FLINK-35383
Project: Flink
Hi Xuyang,
Thanks for your response. I can provide some better context, we are migrating a
use case to FlinkSQL and they want to do some query that has a UDF like
SELECT user_id,
ARRAY_MAP(transactions, x -> x * 1.1) AS taxed_transactions
FROM users;
Based on my understanding of th
Ryan Skraba created FLINK-35382:
---
Summary: ChangelogCompatibilityITCase.testRestore fails with an NPE
Key: FLINK-35382
URL: https://issues.apache.org/jira/browse/FLINK-35382
Project: Flink
Issu
Hello devs,
I saw quite some examples when customers were confused about run, and run-
application in the Flink CLI and I was wondering about the necessity of
deploying
Application Mode (AM) jobs with a different command, than Session and Per-Job
mode jobs.
I can see a point that YarnDeployme
Ryan Skraba created FLINK-35381:
---
Summary: LocalRecoveryITCase failure on deleting directory
Key: FLINK-35381
URL: https://issues.apache.org/jira/browse/FLINK-35381
Project: Flink
Issue Type: B
Ryan Skraba created FLINK-35380:
---
Summary: ResumeCheckpointManuallyITCase hanging on tests
Key: FLINK-35380
URL: https://issues.apache.org/jira/browse/FLINK-35380
Project: Flink
Issue Type: Bu
Zakelly Lan created FLINK-35379:
---
Summary: File merging manager is not properly notified about
checkpoint
Key: FLINK-35379
URL: https://issues.apache.org/jira/browse/FLINK-35379
Project: Flink
Hmm sorry, I will try to search consensus..
I read 3 Votes but miss the binding part..
On 2024/05/16 01:36:46 Rui Fan wrote:
> Thanks Joao Boto for driving the FLIP. We need 3 +1(binding)
> votes according to Flink Bylaws[1] before the community accepts it.
>
> You can search "Consensus" and
Martijn Visser created FLINK-35378:
--
Summary: [FLIP-453] Promote Unified Sink API V2 to Public and
Deprecate SinkFunc
Key: FLINK-35378
URL: https://issues.apache.org/jira/browse/FLINK-35378
Project:
Hi Keith Lee,
There is actually an open and accepted FLIP [1] that was just never
implemented. I think that needs to be taken into account as well, since it
was voted on. I think it also makes more sense to have a proposal as a
FLIP, instead of under a Jira.
Best regards,
Martijn
[1]
https://cw
Tongkai Yin created FLINK-35377:
---
Summary: debezium-json support soft deletion.
Key: FLINK-35377
URL: https://issues.apache.org/jira/browse/FLINK-35377
Project: Flink
Issue Type: Improvement
中国无锡周良 created FLINK-35376:
--
Summary: When flink submits the job by calling the rest api, the
dependent jar package generated to the tmp is not removed
Key: FLINK-35376
URL: https://issues.apache.org/jira/browse/FLINK-35
Hi Piotr,
> we checked in the firing timers benchmark [1] and we didn't observe any
> performance regression.
Thanks for the feedback, it's good news to hear that. I didn't notice
we already have fireProcessingTimers benchmark.
If so, we can follow it after this FLIP is merged.
+1 for this FLIP
Hi Zakelly,
> I'm suggesting skipping the continuation mail during draining of async
state access.
I see. That makes sense to me now. I will later update the FLIP.
> the code path will become more complex after this FLIP
due to the addition of shouldIntterupt() checks, right?
Yes, that's correc
Hi Lorenzo,
> • concerns about memory and CPU used out of Flink's control
Please note that using AWS SDKv2 would have the same concerns. In both
cases Flink can control only to a certain extent what either the SDKv2
library does under the hood or the s5cmd process, via configuration
parameters. S
+1 (binding)
- Verified signature and checksum hash
- Verified that no binaries exist in the source archive
- Build source code successful
- Reviewed the release web PR
- Check tag and branch exist
Best,
Jingsong
On Thu, May 16, 2024 at 4:25 PM Jark Wu wrote:
>
> +1 (binding)
>
> - checked sign
+1 (binding)
- checked signatures
- checked hashes
- checked release notes
- reviewed the release web PR
- checked the jars in the staging repo
- build and compile the source code locally with jdk8
Best,
Jark
On Wed, 15 May 2024 at 16:05, gongzhongqiang
wrote:
> +1 (non-binding)
>
> - Verified
田元志 created FLINK-35375:
---
Summary: About a question report "Failed to deserialize data of
EventHeaderV4" of flink cdc2.4.2
Key: FLINK-35375
URL: https://issues.apache.org/jira/browse/FLINK-35375
Project: Flink
hongxu han created FLINK-35374:
--
Summary: Flink 1.14 kafka connector Demo Error
Key: FLINK-35374
URL: https://issues.apache.org/jira/browse/FLINK-35374
Project: Flink
Issue Type: Bug
C
JunboWang created FLINK-35373:
-
Summary: Beautify Flink CDC Paimon Sink web ui
Key: FLINK-35373
URL: https://issues.apache.org/jira/browse/FLINK-35373
Project: Flink
Issue Type: Improvement
joeb created FLINK-35372:
Summary: flink-cdc from mysql to doris, gives an error Unsupported
type:TIME(0) when mysql data type is TIME and synchronise table structure or
data.
Key: FLINK-35372
URL: https://issues.apache.
Well, I give my +1 (non-binding), but we need more binding votes :)
Looking forward to see this approved and see the changes.
On May 16, 2024 at 03:37 +0200, Rui Fan <1996fan...@gmail.com>, wrote:
> Thanks Joao Boto for driving the FLIP. We need 3 +1(binding)
> votes according to Flink Bylaws[1] b
Hi Jane,
Thanks for the proposal. +1 from my side.
Best,
Jark
On Thu, 16 May 2024 at 10:28, Xuannan Su wrote:
> Hi Jane,
>
> Thanks for driving this effort! And +1 for the proposed changes.
>
> I have one comment on the migration plan.
>
> For options to be moved to another module/package, I
Also reviewed your PubSub PR, thanks you for the great job!
On May 15, 2024 at 17:28 +0200, Muhammet Orazov
, wrote:
> Thanks Ahmed!
>
> I have reviewed your PubSub and RabbitMQ PRs, please have a look.
>
> Best,
> Muhammet
Hello Piotr and thanks for this proposal!
The idea sounds smart and very well grounded thank you!
Also here, as others, I have some doubts about invoking an external binary
(namely s5cmd):
• concerns about memory and CPU used out of Flink's control
• deployment concerns from the usability perspe
38 matches
Mail list logo
