Hi, sorry for late reply.
1: If the exisiting OnCheckpointRollingPolicy can't meet your requirement, you
can customize a RollingPolicy extending CheckpointRollingPolicy.
2: > Why DefaultRollingPolicy don't always roll inProgressParts on checkpoint?
I'm also not the creator of `DefaultRollingPoli
Matthias Pohl created FLINK-31395:
-
Summary: AbstractPartitionDiscoverer.discoverPartitions calls
remove on immutable collection
Key: FLINK-31395
URL: https://issues.apache.org/jira/browse/FLINK-31395
+1 (binding)
Best,
D.
On Fri, Mar 10, 2023 at 4:49 AM Yuxin Tan wrote:
> Thanks, Weihua!
> +1 (non-binding)
>
> Best,
> Yuxin
>
>
> weijie guo 于2023年3月10日周五 11:29写道：
>
> > +1 (binding)
> >
> > Best regards,
> >
> > Weijie
> >
> >
> > Shammon FY 于2023年3月10日周五 11:02写道：
> >
> > > Thanks weihua,
zhuangchong created FLINK-31394:
---
Summary: Fix spark jar name in the create release script for table
store
Key: FLINK-31394
URL: https://issues.apache.org/jira/browse/FLINK-31394
Project: Flink
Weijie Guo created FLINK-31393:
--
Summary: HsFileDataManager use an incorrect default timeout
Key: FLINK-31393
URL: https://issues.apache.org/jira/browse/FLINK-31393
Project: Flink
Issue Type: Bu
Jingsong Lee created FLINK-31392:
Summary: Refactor classes code of full-compaction
Key: FLINK-31392
URL: https://issues.apache.org/jira/browse/FLINK-31392
Project: Flink
Issue Type: Sub-task
Jingsong Lee created FLINK-31391:
Summary: Introduce lookup changelog producer
Key: FLINK-31391
URL: https://issues.apache.org/jira/browse/FLINK-31391
Project: Flink
Issue Type: New Feature
Thanks Yuxin for your explanation.
That sounds reasonable. Looking forward to the new shuffle.
Best,
Weihua
On Fri, Mar 10, 2023 at 11:48 AM Yuxin Tan wrote:
> Hi, Weihua,
> Thanks for the questions and the ideas.
>
> > 1. How many performance regressions would there be if we only
> used rem
Thanks, Weihua!
+1 (non-binding)
Best,
Yuxin
weijie guo 于2023年3月10日周五 11:29写道：
> +1 (binding)
>
> Best regards,
>
> Weijie
>
>
> Shammon FY 于2023年3月10日周五 11:02写道：
>
> > Thanks weihua, +1 (non-binding)
> >
> > Best,
> > Shammon
> >
> > On Fri, Mar 10, 2023 at 10:32 AM Xintong Song
> > wrote:
Hi, Weihua,
Thanks for the questions and the ideas.
> 1. How many performance regressions would there be if we only
used remote storage?
The new architecture can support to use remote storage only, but this
FLIP target is to improve job stability. And the change in the FLIP has
been significantly
+1 (binding)
Best regards,
Weijie
Shammon FY 于2023年3月10日周五 11:02写道：
> Thanks weihua, +1 (non-binding)
>
> Best,
> Shammon
>
> On Fri, Mar 10, 2023 at 10:32 AM Xintong Song
> wrote:
>
> > +1 (binding)
> >
> > Best,
> >
> > Xintong
> >
> >
> >
> > On Thu, Mar 9, 2023 at 1:28 PM Weihua Hu wrot
Thanks, Weihua!
I’m +1 (non-binding)
-John
On Thu, Mar 9, 2023, at 21:02, Shammon FY wrote:
> Thanks weihua, +1 (non-binding)
>
> Best,
> Shammon
>
> On Fri, Mar 10, 2023 at 10:32 AM Xintong Song wrote:
>
>> +1 (binding)
>>
>> Best,
>>
>> Xintong
>>
>>
>>
>> On Thu, Mar 9, 2023 at 1:28 PM Weihu
Aitozi created FLINK-31390:
--
Summary: Optimize the FlinkChangelogModeInferenceProgram by
avoiding unnecessary traversals.
Key: FLINK-31390
URL: https://issues.apache.org/jira/browse/FLINK-31390
Project: Flin
Thanks weihua, +1 (non-binding)
Best,
Shammon
On Fri, Mar 10, 2023 at 10:32 AM Xintong Song wrote:
> +1 (binding)
>
> Best,
>
> Xintong
>
>
>
> On Thu, Mar 9, 2023 at 1:28 PM Weihua Hu wrote:
>
> > Hi Everyone,
> >
> > I would like to start the vote on FLIP-298: Unifying the Implementation
> >
+1 (binding)
Best,
Xintong
On Thu, Mar 9, 2023 at 1:28 PM Weihua Hu wrote:
> Hi Everyone,
>
> I would like to start the vote on FLIP-298: Unifying the Implementation
> of SlotManager [1]. The FLIP was discussed in this thread [2].
>
> This FLIP aims to unify the implementation of SlotManager
zhuangchong created FLINK-31389:
---
Summary: Fix spark jar name in docs for table store
Key: FLINK-31389
URL: https://issues.apache.org/jira/browse/FLINK-31389
Project: Flink
Issue Type: Bug
Hi everyone,
I also think the reporter won't work for my use case, it could work but
then I am trying to modify the placement of operators on taskmanagers
manually based on my some decisions made from metric collection, reporter
makes it harder to do so. Right now, I have REST APIs, but I was thin
Hi all,
Metric reporter may be useful if you only need per component level metrics
like jobmanager and each taskmanager since the metric reporter runs in each
component. However, for an aggregated job level view of metrics, there is
no better out-of-the-box/user-facing way to get metrics than the
David Anderson created FLINK-31388:
--
Summary: restart from savepoint fails with "userVisibleTail should
not be larger than offset. This is a bug."
Key: FLINK-31388
URL: https://issues.apache.org/jira/browse/FLINK
Hi Lincoln,
sounds good to me. Thanks!
Best,
Jing
On Wed, Mar 8, 2023 at 2:01 PM Lincoln Lee wrote:
> Hi Jing,
> Agree with you that using formal terms can be easier to users, I've updated
> the FLIP[1], since this is only one of the application scenarios for
> partial insert, our java doc for
Hi Yingjie,
Thanks for the test and identifying the issue, this is super helpful!
To all others, please continue your testing on this RC so that if there are
more blockers to be found, we can fix them with the next RC and have
(hopefully) a successful vote on it.
Best regards,
Martijn
On Thu,
Matthias Pohl created FLINK-31387:
-
Summary:
StreamTaskCancellationTest.testCancelTaskShouldPreventAdditionalProcessingTimeTimersFromBeingFired
failed with an assertion
Key: FLINK-31387
URL: https://issues.apache
Hi community and release managers:
When testing the release candidate #1 for batch scenario, I found a
potential deadlock issue of blocking shuffle. I have created a ticket [1]
for it and marked it as blocker. I will fix it no later than tomorrow.
[1] https://issues.apache.org/jira/browse/FLINK-3
Yingjie Cao created FLINK-31386:
---
Summary: Fix the potential deadlock issue of blocking shuffle
Key: FLINK-31386
URL: https://issues.apache.org/jira/browse/FLINK-31386
Project: Flink
Issue Type
Thanks for your clarification. I have nothing else to add to the
discussion. +1 from my side to proceed
On Wed, Mar 8, 2023 at 4:16 AM Weihua Hu wrote:
> Thanks Yangze for your attention, this would be a great help.
>
> And thanks Matthias too.
>
> FLIP-156 [1] mentions some incompatibility betw
David Morávek created FLINK-31385:
-
Summary: Introduce extended Assertj Matchers for completable
futures
Key: FLINK-31385
URL: https://issues.apache.org/jira/browse/FLINK-31385
Project: Flink
Nicolas Pocock created FLINK-31384:
--
Summary: If you don't pass a function type to the builders
WithSpec method it doesn't error within the Go SDK but the function isn't
registered within Flink and doesn't run correctly.
Key: FL
David Morávek created FLINK-31383:
-
Summary: Add support for documenting additionProperties of the
REST API payloads.
Key: FLINK-31383
URL: https://issues.apache.org/jira/browse/FLINK-31383
Project: F
Hi Timo,
Thank you for the suggestion, I've updated the java doc (to make it clear
that a statement without specifying a column list will return {@link
Optional#empty()}) in the FLIP[1] and also the poc[2].
[1]
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=240885081
[2] https:/
Hi, Atul,
I think the metric reporter[1] will be helpful for you.
Best,
Hang
[1]
https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/deployment/metric_reporters/
Atul Lal 于2023年3月9日周四 17:49写道：
> Hi everyone,
>
> I am trying to do some experiments with Flink. I am trying to modify
Hi everyone,
Please review and vote on the release candidate #2 for the version 1.15.4,
as follows:
[ ] +1, Approve the release
[ ] -1, Do not approve the release (please provide specific comments)
The complete staging area is available for your review, which includes:
* JIRA release notes [1],
*
jackylau created FLINK-31381:
Summary: UnsupportedOperationException: Unsupported type when
convertTypeToSpec: MAP
Key: FLINK-31381
URL: https://issues.apache.org/jira/browse/FLINK-31381
Project: Flink
Ran Tao created FLINK-31382:
---
Summary: Add select query ILIKE predicate support
Key: FLINK-31382
URL: https://issues.apache.org/jira/browse/FLINK-31382
Project: Flink
Issue Type: Sub-task
Ran Tao created FLINK-31380:
---
Summary: Add filter support for ShowOperations
Key: FLINK-31380
URL: https://issues.apache.org/jira/browse/FLINK-31380
Project: Flink
Issue Type: Sub-task
C
Hi all,
I am happy to announce that FLIP-297: Improve Auxiliary Sql Statements[1]
has been accepted.
There are 8 approving votes, 4 of which are binding:
- ConradJam
- Hang Ruan
- Jacky Lau
- Jing Ge (binding)
- Jark Wu (binding)
- yuxia
- Sergey Nuyanzin (binding)
- Timo Walther (binding)
There
Matthias Pohl created FLINK-31379:
-
Summary:
ZooKeeperMultipleComponentLeaderElectionDriverTest.testLeaderElectionWithMultipleDrivers
runs into timeout
Key: FLINK-31379
URL: https://issues.apache.org/jira/browse/
Thanks, everyone, I'm closing this vote now. I'll follow up with the result
in another email.
Best Regards,
Ran Tao
Ran Tao 于2023年3月7日周二 15:59写道：
> thanks Lau.
>
> The vote will last for at least 72 hours (03/09, 19:30 UTC+8).
> It needs consensus approval, requiring 3 binding +1 votes and no
Hongshun Wang created FLINK-31378:
-
Summary: Documentation fails to build due to lack of package
Key: FLINK-31378
URL: https://issues.apache.org/jira/browse/FLINK-31378
Project: Flink
Issue T
Hi Ram,
You are right, the effect of DefaultRollingPolicy not always rolling on
checkpoint leads to unusable non-latest savepoints.
My question is, should DefaultRollingPolicy be changed so that it always roll
on checkpoint to provide a better user experience?
I'd imagine most StreamingFileSink
Hi everyone,
I am trying to do some experiments with Flink. I am trying to modify the
source code of Flink for this experiment, and I am starting a process
thread from JobMaster.java constructor whenever a new job is started in
Flink. In this thread, I want to monitor a few metrics related to the
> I was wondering why you, exceptionally, suggested 'scan.idle-timeout'
instead of 'scan.watermark.idle-timeout'. I must miss something here.
@Jing: You are right. That was just a copy paste mistake. It should be
`scan.watermark.idle-timeout`.
@Kui: Can you fix that in the FLIP? Sorry, for th
jackylau created FLINK-31377:
Summary: BinaryArrayData getArray/getMap should Handle null
correctly AssertionError: valueArraySize (-6) should >= 0
Key: FLINK-31377
URL: https://issues.apache.org/jira/browse/FLINK-31
Hi Daniel,
I think, it would be great to have a PubSub Lite Connector in Flink. Before
you put this proposal up for a vote, though, 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
Com
Hi Lincoln,
thanks for proposing the FLIP. The general idea to expose the target
columns in DynamicTableSink#Context sounds good to me.
In the FLIP I found the JavaDoc a bit confusing:
```
The column list will be empty for 'insert into target select ...'.
```
This could mean both optional em
+1 (binding)
Thanks,
Timo
On 08.03.23 14:59, Sergey Nuyanzin wrote:
+1
(binding) i guess based on [1], please correct me if i am wrong
[1]
https://cwiki.apache.org/confluence/display/FLINK/Flink+Bylaws#FlinkBylaws-Actions
On Wed, Mar 8, 2023 at 8:04 AM yuxia wrote:
+1 (non-binding)
Thanks
45 matches
Mail list logo
