Zhimin Geng created FLINK-31437:
---
Summary: 'lookup.cache.caching-missing-key' change should be
configured as 'lookup.partial-cache.caching-missing-key'
Key: FLINK-31437
URL:
Caizhi Weng created FLINK-31436:
---
Summary: Remove schemaId from constructor of Snapshot and
ManifestFile in Table Store
Key: FLINK-31436
URL: https://issues.apache.org/jira/browse/FLINK-31436
Project:
>
> The RC works on this tested scope. I'll test again on RC2.
Cool, thanks for your validation，Etienne! We'll prepare the RC2 ASAP.
Best,
Leonard
>
> By the way, it seems the apache/flink-benchmarks repo did not checkout a
> branch target for flink-1.17 [1] ?
>
Thanks Yun for reporting this, I'll check apache/flink-benchmarks repo.
Best,
Leonard
Hi all,
Thank you for the feedback. Responses inline.
> we need feedback from a Committer who would review and help maintain it
going forward. Ideally, this Committer would guide one or more contributors
from Google to Committership so that Google could step up and maintain Flink
's PubSub and
Caizhi Weng created FLINK-31435:
---
Summary: Introduce event parser for MySql Debezium JSON format in
Table Store
Key: FLINK-31435
URL: https://issues.apache.org/jira/browse/FLINK-31435
Project: Flink
Caizhi Weng created FLINK-31434:
---
Summary: Introduce CDC sink for Table Store
Key: FLINK-31434
URL: https://issues.apache.org/jira/browse/FLINK-31434
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-31433:
---
Summary: Make SchemaChange serializable
Key: FLINK-31433
URL: https://issues.apache.org/jira/browse/FLINK-31433
Project: Flink
Issue Type: Sub-task
Caizhi Weng created FLINK-31432:
---
Summary: Introduce a special StoreWriteOperator to deal with
schema changes
Key: FLINK-31432
URL: https://issues.apache.org/jira/browse/FLINK-31432
Project: Flink
Caizhi Weng created FLINK-31431:
---
Summary: Support copying a FileStoreTable with latest schema
Key: FLINK-31431
URL: https://issues.apache.org/jira/browse/FLINK-31431
Project: Flink
Issue
+1 (non binding)
Thanks for driving it .
Bests,
Samrat
On Tue, 14 Mar 2023 at 7:41 AM, Jark Wu wrote:
> +1 (binding)
>
> Best,
> Jark
>
> > 2023年3月13日 23:25，Aitozi 写道：
> >
> > +1 (non-binding)
> >
> > Best,
> > Aitozi
> >
> > Jing Ge 于2023年3月13日周一 22:10写道：
> >
> >> +1 (binding)
> >>
> >>
Caizhi Weng created FLINK-31430:
---
Summary: Support migrating states between different instances of
TableWriteImpl and AbstractFileStoreWrite
Key: FLINK-31430
URL: https://issues.apache.org/jira/browse/FLINK-31430
Caizhi Weng created FLINK-31429:
---
Summary: Support CTAS(create table as) streaming job with schema
changes in table store
Key: FLINK-31429
URL: https://issues.apache.org/jira/browse/FLINK-31429
+1 (non binding)
- checked AWS SDKv2 version has been bumped to 2.19.14 through
FLINK-30633 and
all NOTICE files updates
- Checked release notes
- Checked sum and signatures
- Maven clean install from source
- Checked the jars in the staging repo
- Checked website updates
Bests,
Samrat
On
+1 (binding)
Best,
Jark
> 2023年3月13日 23:25，Aitozi 写道：
>
> +1 (non-binding)
>
> Best,
> Aitozi
>
> Jing Ge 于2023年3月13日周一 22:10写道：
>
>> +1 (binding)
>>
>> Best Regards,
>> Jing
>>
>> On Mon, Mar 13, 2023 at 1:57 PM Hang Ruan wrote:
>>
>>> +1 (non-binding)
>>>
>>> Best,
>>> Hang
>>>
+1 (binding)
- Verified the checksum and signature
- Installed PyFlink on MacOS and run a word count example successfully
- The website PR LGTM
Regards,
Dian
On Thu, Mar 9, 2023 at 8:22 PM Danny Cranmer
wrote:
> Hi everyone,
> Please review and vote on the release candidate #2 for the version
Alpha Diallo created FLINK-31428:
Summary: Add user callbacks to PulsarSource and PulsarSink
Key: FLINK-31428
URL: https://issues.apache.org/jira/browse/FLINK-31428
Project: Flink
Issue
Yufan Sheng created FLINK-31427:
---
Summary: Pulsar Catalog support with Schema translation
Key: FLINK-31427
URL: https://issues.apache.org/jira/browse/FLINK-31427
Project: Flink
Issue Type:
Aitozi created FLINK-31426:
--
Summary: Upgrade the deprecated UniqueConstraint to the new one
Key: FLINK-31426
URL: https://issues.apache.org/jira/browse/FLINK-31426
Project: Flink
Issue Type:
Jeff created FLINK-31425:
Summary: Support submitting a job with streamgraph
Key: FLINK-31425
URL: https://issues.apache.org/jira/browse/FLINK-31425
Project: Flink
Issue Type: New Feature
+1 (non-binding)
Best,
Aitozi
Jing Ge 于2023年3月13日周一 22:10写道：
> +1 (binding)
>
> Best Regards,
> Jing
>
> On Mon, Mar 13, 2023 at 1:57 PM Hang Ruan wrote:
>
> > +1 (non-binding)
> >
> > Best,
> > Hang
> >
> > yuxia 于2023年3月13日周一 20:52写道：
> >
> > > +1 (binding)
> > > Thanks Lincoln Lee for
jirawech.s created FLINK-31424:
--
Summary: NullPointer when using StatementSet for multiple sinks
Key: FLINK-31424
URL: https://issues.apache.org/jira/browse/FLINK-31424
Project: Flink
Issue
Thanks Chesnay for your suggestion.
One thing you could potentially look into is integrating the
> TaskExecutorManager into the FIneGrainedSlotManager or find another way
> to move the timeout handling into another component.
After going over the codes. It's hard to make TaskExecutorManager both
Martijn Visser created FLINK-31423:
--
Summary: Update external connector workflow to use Node16 instead
of Node12 actions
Key: FLINK-31423
URL: https://issues.apache.org/jira/browse/FLINK-31423
Thanks for the release managers' work and hope to see the flink-1.17.0 RC2
coming soon.
By the way, it seems the apache/flink-benchmarks repo did not checkout a branch
target for flink-1.17 [1] ?
Best
Yun Tang
From: Etienne Chauchot
Sent: Monday, March 13,
+1 (binding)
Best Regards,
Jing
On Mon, Mar 13, 2023 at 1:57 PM Hang Ruan wrote:
> +1 (non-binding)
>
> Best,
> Hang
>
> yuxia 于2023年3月13日周一 20:52写道：
>
> > +1 (binding)
> > Thanks Lincoln Lee for driving it.
> >
> > Best regards,
> > Yuxia
> >
> > - 原始邮件 -
> > 发件人: "Lincoln Lee"
> >
Hi,
Thanks Martijn and release managers for this RC.
I tested it in a standalone cluster on this (1) benchmark / user code
[1] https://github.com/echauchot/tpcds-benchmark-flink
The RC works on this tested scope. I'll test again on RC2.
Best
Etienne
Le 09/03/2023 à 20:31, Martijn Visser a
+1 (non-binding)
Best,
Hang
yuxia 于2023年3月13日周一 20:52写道：
> +1 (binding)
> Thanks Lincoln Lee for driving it.
>
> Best regards,
> Yuxia
>
> - 原始邮件 -
> 发件人: "Lincoln Lee"
> 收件人: "dev"
> 发送时间: 星期一, 2023年 3 月 13日 下午 8:17:52
> 主题: [VOTE] FLIP-300: Add targetColumns to
+1 (binding)
Thanks Lincoln Lee for driving it.
Best regards,
Yuxia
- 原始邮件 -
发件人: "Lincoln Lee"
收件人: "dev"
发送时间: 星期一, 2023年 3 月 13日 下午 8:17:52
主题: [VOTE] FLIP-300: Add targetColumns to DynamicTableSink#Context to solve the
null overwrite problem of partial-insert
Dear Flink
Jiang Xin created FLINK-31422:
-
Summary: Add Servable for Logistic Regression Model
Key: FLINK-31422
URL: https://issues.apache.org/jira/browse/FLINK-31422
Project: Flink
Issue Type: Bug
Hi everyone,
I started a vote for this FLIP[1], please vote there[2] or ask additional
questions here[3].
[1]
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=240885081
[2] https://lists.apache.org/thread/089glskx8ydphnyx8q1v996s8y83xkn6
[3]
Dear Flink developers,
Thanks for all your feedback for FLIP-300: Add targetColumns to
DynamicTableSink#Context to solve the null overwrite problem of
partial-insert[1] on the discussion thread[2].
I'd like to start a vote for it. The vote will be open for at least 72
hours unless there is an
Hi Yunhong,
Thanks for the message. Technically this is not a release blocker for 1.17,
since the issue already exists in Flink 1.16. The CI isn't passing for the
PR, so it also looks like this won't be fixed soon. I've lowered the
priority to a Critical ticket, but if this isn't merged in the
Hi Qingsheng Ren and other release manager,
Thank you for bringing this up. There is a serious bug in planner rule
#FlinkFilterJoinRule, which will generate a wrong join plan and no result
will output:
https://issues.apache.org/jira/browse/FLINK-31273 (reviewing).
This bug will be triggered by a
+1 (binding)
On Mon, Mar 13, 2023 at 11:33 AM Etienne Chauchot wrote:
>
> +1 (not binding)
>
> Etienne
>
> Le 11/03/2023 à 07:37, Yangze Guo a écrit :
> > +1 (binding)
> >
> > Zhanghao Chen 于 2023年3月10日周五 下午5:07写道：
> >
> >> Thanks Weihua. +1 (non-binding)
> >>
> >> Best,
> >> Zhanghao Chen
> >>
Qingsheng Ren created FLINK-31421:
-
Summary: DataGeneratorSourceITCase.testGatedRateLimiter failed on
CI
Key: FLINK-31421
URL: https://issues.apache.org/jira/browse/FLINK-31421
Project: Flink
+1 (binding)
Best Regards,
JIng
On Mon, Mar 13, 2023 at 8:22 AM Jingsong Li wrote:
> +1 (binding)
>
> Not block voting.
> But comment about `Public Interface` in the FLIP: these classes may
> not be `Public interface`? I think they are just internal
> implementations.
>
> Best,
> Jingsong
>
>
+1 (not binding)
Etienne
Le 11/03/2023 à 07:37, Yangze Guo a écrit :
+1 (binding)
Zhanghao Chen 于 2023年3月10日周五 下午5:07写道：
Thanks Weihua. +1 (non-binding)
Best,
Zhanghao Chen
From: Weihua Hu
Sent: Thursday, March 9, 2023 13:27
To: dev
Subject: [Vote]
Qingsheng Ren created FLINK-31420:
-
Summary: ThreadInfoRequestCoordinatorTest.testShutDown failed on CI
Key: FLINK-31420
URL: https://issues.apache.org/jira/browse/FLINK-31420
Project: Flink
Woong Wen Tat created FLINK-31419:
-
Summary: Flink-JDBC should allow . in field names
Key: FLINK-31419
URL: https://issues.apache.org/jira/browse/FLINK-31419
Project: Flink
Issue Type: Bug
One thing you could potentially look into is integrating the
TaskExecutorManager into the FIneGrainedSlotManager or find another way
to move the timeout handling into another component.
w.r.t. testing, there's the DeclarativeSlotManagerTest that covers some
specific issues that should be
Qingsheng Ren created FLINK-31418:
-
Summary:
SortMergeResultPartitionReadSchedulerTest.testRequestBufferTimeout failed on CI
Key: FLINK-31418
URL: https://issues.apache.org/jira/browse/FLINK-31418
nonggia.liang created FLINK-31417:
-
Summary: Hadoop version unknown when
TrinoPageSourceBase.getNextPage
Key: FLINK-31417
URL: https://issues.apache.org/jira/browse/FLINK-31417
Project: Flink
Thanks everyone for validating the RC!
As there are some patches to be included and signature issues, the RC1 of
1.17.0 is officially canceled. Because the ASF Nexus server is now in
maintenance, we'll build a new RC after the server gets online, which is
hopefully on Tuesday (Mar 14).
Best,
Congratulations Yuxia!
From: Sergey Nuyanzin
Sent: Monday, March 13, 2023 3:42 AM
To: dev@flink.apache.org
Subject: Re: Re: [ANNOUNCE] New Apache Flink Committer - Yuxia Luo
Congratulations, Yuxia!
On Mon, Mar 13, 2023 at 9:24 AM Leonard Xu wrote:
> Congrats Yuxia, impressive work on
Hi Jing
I think your thoughts are interesting. We can consider a flink cluster with
Jdbc-Driver as a warehouse and flink jobs can interact with it by
Flink-Jdbc-Connector. This may have higher requirements for the throughput
and latency of the warehouse (flink cluster), but we can try it after
Hi all,
I agree with Konstantin, mentoring is important especially on this new
connector framework. Long time maintenance is even more important.
I could not mentor you on this topic because I'm not a committer on the
Flink project and because I don't know Pub/Sub tech. That being said I
> Although YARN serves as the platform for Flink, does YARN also operate on
K8s?
YARN is an alternative to k8s and Flink should make no assumptions about
how it's deployed, even though some companies might deploy it as an overlay
RM on top of k8s (I doubt that, but I guess they might do it for
Martijn Visser created FLINK-31416:
--
Summary: Recognize if Github Action workflow is for Push, PR or
Nightly Builds
Key: FLINK-31416
URL: https://issues.apache.org/jira/browse/FLINK-31416
Project:
Congratulations, Yuxia!
On Mon, Mar 13, 2023 at 9:24 AM Leonard Xu wrote:
> Congrats Yuxia, impressive work on hive，well deserved!
>
> Best,
> Leonard
>
> On Mon, Mar 13, 2023 at 3:49 PM Martijn Visser
> wrote:
>
> > Congrats Yuxia, well deserved!
> >
> > On Mon, Mar 13, 2023 at 5:29 AM Jane
Hi Ramkrishna,
I hope this email finds you well. Please accept my apologies for the delay
in responding to your previous message.
I would like to discuss the following matter with you: Although YARN serves
as the platform for Flink, does YARN also operate on K8s? I am curious to
know if this
Congrats Yuxia, impressive work on hive，well deserved!
Best,
Leonard
On Mon, Mar 13, 2023 at 3:49 PM Martijn Visser
wrote:
> Congrats Yuxia, well deserved!
>
> On Mon, Mar 13, 2023 at 5:29 AM Jane Chan wrote:
>
> > Congratulations, Yuxia!
> >
> > Best,
> > Jane
> >
> > On Mon, Mar 13, 2023 at
Congrats, Yuxia!
Best regards,
Jing
On Mon, Mar 13, 2023 at 8:49 AM Martijn Visser
wrote:
> Congrats Yuxia, well deserved!
>
> On Mon, Mar 13, 2023 at 5:29 AM Jane Chan wrote:
>
> > Congratulations, Yuxia!
> >
> > Best,
> > Jane
> >
> > On Mon, Mar 13, 2023 at 12:26 PM Lincoln Lee
> > wrote:
yuzelin created FLINK-31415:
---
Summary: Support target alias and using ddls to create source
Key: FLINK-31415
URL: https://issues.apache.org/jira/browse/FLINK-31415
Project: Flink
Issue Type:
Hi,
@Benchao
you are right, no, the question did not intend to block this FLIP.
@Shammon
It looks quite interesting, if we imagine how the Flink jdbc connector
could work with Flink jdbc driver. It makes "on-the-fly"
cross-flink-applications data consumption possible, i.e. bounded source
scan,
Congrats Yuxia, well deserved!
On Mon, Mar 13, 2023 at 5:29 AM Jane Chan wrote:
> Congratulations, Yuxia!
>
> Best,
> Jane
>
> On Mon, Mar 13, 2023 at 12:26 PM Lincoln Lee
> wrote:
>
> > Congratulations, Yuxia!
> >
> > Best,
> > Lincoln Lee
> >
> >
> > Shammon FY 于2023年3月13日周一 12:16写道：
> >
>
Feifan Wang created FLINK-31414:
---
Summary: exceptions in the alignment timer are ignored
Key: FLINK-31414
URL: https://issues.apache.org/jira/browse/FLINK-31414
Project: Flink
Issue Type: Bug
+1 (binding)
Not block voting.
But comment about `Public Interface` in the FLIP: these classes may
not be `Public interface`? I think they are just internal
implementations.
Best,
Jingsong
On Mon, Mar 13, 2023 at 2:10 PM Benchao Li wrote:
>
> +1 (binding)
>
> Shammon FY 于2023年3月13日周一 13:47写道：
Hi,
Thanks for the feedback and questions from Zhu Zhu, Xia Sun and Yun Tang.
@Zhu Zhu
> 1. I'm a bit concerned about the cost of it.
The Read Client's request to check the existence of a segment in each
storage tier is the netty message, which is similar to the credit updating
messages. It is
luoyuxia created FLINK-31413:
Summary: Remove provided dependency tabl in Hive connector
Key: FLINK-31413
URL: https://issues.apache.org/jira/browse/FLINK-31413
Project: Flink
Issue Type:
Shammon created FLINK-31412:
---
Summary: HiveCatalog rollback schema if alter table failed in
table store
Key: FLINK-31412
URL: https://issues.apache.org/jira/browse/FLINK-31412
Project: Flink
Hi, Max
Thanks for feedback.
SlotManager only releases task managers with no task running on it after an
idle timeout.
IMO, this behavior could support scale down naturally.
There are two ways to trigger scale down:
1. Using adaptive scheduler and release task managers by resource
+1 (binding)
Shammon FY 于2023年3月13日周一 13:47写道：
> Hi Devs,
>
> I'd like to start the vote on FLIP-293: Introduce Flink Jdbc Driver For Sql
> Gateway [1].
>
> The FLIP was discussed in thread [2], and it aims to introduce Flink Jdbc
> Driver module in Flink.
>
> The vote will last for at least 72
Zhimin Geng created FLINK-31411:
---
Summary:
lookup.cache.caching-missing-key变更的配置应为lookup.partial-cache.caching-missing-key
Key: FLINK-31411
URL: https://issues.apache.org/jira/browse/FLINK-31411
64 matches
Mail list logo
