chosen side, a validation exception
will be thrown.
Maybe we should distinguish which exceptions need to be thrown explicitly.
--
Best！
Xuyang
At 2023-10-10 18:23:55, "Jane Chan" wrote:
>Hi Feng,
>
>Thank you for your valuable comments. The reason for not inclu
+1(non-binding)
--
Best！
Xuyang
At 2023-10-23 11:38:15, "Jane Chan" wrote:
>Hi developers,
>
>Thanks for all the feedback on FLIP-373: Support Configuring Different
>State TTLs using SQL Hint [1].
>Based on the discussion [2], we have reached a consensus
Hi, the existant configuration
'table.optimizer.source.predicate-pushdown-enabled' seems to do what you want.
Can you describe more clearly the difference between what you want and this
configuration ?
--
Best！
Xuyang
At 2023-10-24 14:12:14, "Jiabao Sun&qu
m wrong.
--
Best！
Xuyang
在 2023-10-24 14:34:15，"Jiabao Sun" 写道：
>Thanks Xuyang,
>
>The table.optimizer.source.predicate-pushdown-enabled options do not provide
>fine-grained configuration for each source.
>
>Suppose we have an SQL query with two sources: Ka
+1. How to set the configuration value so that the specific source can be
perceived needs to be considered.
--
Best！
Xuyang
At 2023-10-24 15:05:03, "Jiabao Sun" wrote:
>Thanks Xuyang,
>
>If we only add configuration without adding the enableFilterPushD
Just like our discussion in thread
https://lists.apache.org/thread/whh75f6rtwdyqxt47gb39j6m6m0cpphq , +1 for this
Flip.
--
Best！
Xuyang
在 2023-10-24 18:03:36，"Jiabao Sun" 写道：
>Thanks Jane,
>
>I believe that the configuration "table.optimizer.source.p
y the one below can pass the
validation and others maybe
need throw an exception clearly.
```
CREATE TABLE foo (
f0 VARCHAR(20)
) WITH ('connector' = 'datagen', 'fields.f0.length' = '10');
```
--
Best！
Xuyang
At 2023-11-21 23:37:32, "L
https://github.com/xuyangzhong/flink/tree/poc_legacy_group_window_agg_cumulate
[5] https://github.com/xuyangzhong/flink/tree/poc_window_agg_consumes_cdc_stream
--
Best！
Xuyang
your thoughs.
--
Best！
Xuyang
At 2023-12-05 09:17:49, "David Anderson" wrote:
>The current situation (where we have both the legacy windows and the
>TVF-based windows) is confusing for users, and I'd like to see us move
>forward as rapidly as possible.
>
ve one or two versions of this
rewrite, and allows users to roll back when problems arise.
> If we remove the legacy window operator in the future, how users upgrade
> their jobs? Do you have any plan to support state migration from the legacy
> window to Windows TVF?
IIRC, currently compat
Big +1 for this exciting work.
--
Best！
Xuyang
在 2023-12-07 12:06:07，"Samrat Deb" 写道：
>That's really cool :)
>+1 for the great addition
>
>Bests,
>Samrat
>
>On Thu, 7 Dec 2023 at 9:20 AM, Jingsong Li wrote:
>
>> Wow, Cool, Nice
&
be deprecated". So as a work to follow Flip-145, this Flip officially
deprecates the legacy window syntax at this time. WDTK?
--
Best！
Xuyang
At 2023-12-07 16:51:44, "Martijn Visser" wrote:
>Hi Xuyang,
>
>Thanks a lot for starting this discussion.
>
Hi, Shengkai.
> I think we shouldn't remove the operator if we can not give a solution to
> help users upgrade their jobs. But I think we can delay the discussion until
> we need to remove the operator.
+1 for it.
--
Best！
Xuyang
在 2023-12-08 19:22:40，"
o new operators. Will these tests be affected about this rewritten?
[1] https://issues.apache.org/jira/browse/FLINK-24204
--
Best！
Xuyang
At 2023-12-09 06:25:30, "Jim Hughes" wrote:
>Hi Xuyang,
>
>As a clarification, since FLINK-24204 is finishing up work
xecNode level for the
>session window TVF with other TVFs?
You're right, thanks for your reminder. I'll move the logic about fallback to
legacy legacy group window agg inside the exec node instead of physical node.
--
Best！
Xuyang
At 2023-12-11 20:38:25, "Jane Chan
ould not be impacted. Depending on what order our work lands
>in, one of the tests you've added/updated would likely move to the
>RestoreTests that Bonnie and I are working on. Just mentioning that ahead
>of time
Got it! I will pay attention to it.
--
Best！
Xuyang
ill not and should not expose these experimental
flink conf to users. I list them in this flip just aims to show the
misalignments about these two window syntaxes.
Look for your thought.
--
Best！
Xuyang
At 2023-12-13 15:40:16, "Lincoln Lee" wrote:
>Thanks Xu
the old group window agg syntax
in the release note.
WDYT?
--
Best！
Xuyang
At 2023-12-14 17:51:01, "Timo Walther" wrote:
>Hi Xuyang,
>
> > I'm not spliting this flip is that all of these subtasks like session
>window tvf and cdc support do not chang
nal actual job graph.
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-234%3A+Support+Retryable+Lookup+Join+To+Solve+Delayed+Updates+Issue+In+External+Systems
[2]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-313%3A+Add+support+of+User+Defined+AsyncTableFunction
--
In this case, we need to ensure that
the sink-based pk is in order actually.
--
Best！
Xuyang
At 2023-12-16 03:33:55, "Alan Sheinberg"
wrote:
>Thanks for the replies everyone. My responses are inline:
>
>About the configs, what do you think using hints as me
Hi, Timo. Sorry for this noise.
What do you think about splitting the flip like this?
--
Best！
Xuyang
At 2023-12-15 10:05:32, "Xuyang" wrote:
>Hi, Timo, thanks for your advice.
>
>
>I am considering splitting the existing flip into two while leaving t
Thanks for driving this FLIP, +1 for it (non binding)
--
Best！
Xuyang
在 2023-12-21 06:08:02，"Natea Eshetu Beshada" 写道：
>Thanks for the FLIP Alan, this will be a great addition +1 (non binding)
>
>On Wed, Dec 20, 2023 at 11:41 AM Alan Sheinberg
> w
/compare/master...hackergin:flink:poc_named_argument
--
Best！
Xuyang
在 2023-12-20 13:31:26，"Benchao Li" 写道：
>I didn't see your POC code, so I assumed that you'll need to add
>SqlStdOperatorTable#DEFAULT and
>SqlStdOperatorTable#ARGUMENT_ASSIGNMENT to FlinkSq
plan rewriting.
title: FLIP-392: Automatically rewrite the old syntax's agg to the window TVF
agg
part 1: automatic plan rewriting
part 2: alignment subtasks the rewriting work depends on
I'm looking forward to your reply.
--
Best！
Xuyang
在 2023-12-19 22:30:27，"Ti
cause a relatively large impact. We may also need to check the
code part in SQL.
[1] https://issues.apache.org/jira/browse/FLINK-33217
--
Best！
Xuyang
在 2023-12-25 10:16:28，"Shengkai Fang" 写道：
>Thanks for Jane and Sergey's proposal!
>
>+1 to correct the
you have any better ideas, let’s discuss it together.
--
Best！
Xuyang
At 2023-12-27 23:20:06, "Martijn Visser" wrote:
>Hi Xuyang,
>
>It's currently the holiday season in Europe so do expect some slow responses.
>
>> The key reason the original F
this is an
unfinished work.
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-145%3A+Support+SQL+windowing+table-valued+function#FLIP145:SupportSQLwindowingtablevaluedfunction-SessionWindows
--
Best！
Xuyang
At 2024-01-02 09:37:15, "Xuyang" wrote:
>Hi, Ma
+1(non-binding)--
Best！
Xuyang
在 2024-01-08 00:34:55，"Feng Jin" 写道：
>Hi Alexey
>
>Thank you for the reminder, the link has been updated.
>
>Best,
>Feng Jin
>
>On Sat, Jan 6, 2024 at 12:55 AM Alexey Leonov-Vendrovskiy <
>vendrov...@gmail.com&g
+1 (non-binding)--
Best！
Xuyang
在 2024-01-11 10:00:11，"Yang Wang" 写道：
>+1 (binding)
>
>
>Best,
>Yang
>
>On Thu, Jan 11, 2024 at 9:53 AM liu ron wrote:
>
>> +1 non-binding
>>
>> Best
>> Ron
>>
>> Matthias Pohl
graph/OperatorID.java#L40C27-L40C27
--
Best！
Xuyang
At 2024-01-12 04:20:03, "Mason Chen" wrote:
>Hi Devs,
>
>I'm opening this thread to discuss a short FLIP for exposing
>JobManagerOperatorMetrics via REST API [1].
>
>The current set of REST APIs make it im
gure it out why does the
'table.exec.deduplicate.mini-batch.compact-changes-enabled' option need to
be added to deduplicate operator? I think this is the same reason as adding a
separate parameter to join to control CDC message folding.
--
Best！
Xuyang
在 2024-01-11 16:1
data with the same
upsert key. For the latter the new option
''table.exec.mini-batch.compact-changes-enabled'' looks pretty good.
--
Best！
Xuyang
At 2024-01-12 18:13:12, "shuai xu" wrote:
>Hi all.
>
>The point I want to highlight is that
e job graph is skewed.
2. Can you tell me that you prefer to unify Data Skew Score and Exception tab?
In my opinion, Data Skew Score is in
the same category as the existing Backpressured and Busy metrics.
Looking forward to your reply.
--
Best！
Xuyang
At 2024-01-16 00:59:57, &quo
+1 (non-binding)
--
Best！
Xuyang
在 2024-01-16 17:52:38，"Leonard Xu" 写道：
>+1 (binding)
>
>Best,
>Leonard
>
>> 2024年1月16日 下午5:40，Hang Ruan 写道：
>>
>> +1 (non-binding)
>>
>> Best,
>> Hang
>>
>> Jiabao Sun 于2
+1 (non-binding)--
Best！
Xuyang
在 2024-01-19 13:28:52，"Lincoln Lee" 写道：
>+1 (binding)
>
>Best,
>Lincoln Lee
>
>
>Benchao Li 于2024年1月19日周五 13:15写道：
>
>> +1 (binding)
>>
>> shuai xu 于2024年1月19日周五 12:58写道：
>>
>>> Dear
+1 (non-binding)
--
Best！
Xuyang
在 2024-01-19 10:16:23，"Qingsheng Ren" 写道：
>+1 (binding)
>
>Thanks for the work, Hongshun!
>
>Best,
>Qingsheng
>
>On Tue, Jan 16, 2024 at 11:21 AM Leonard Xu wrote:
>
>> Thanks Hongshun for driving this
+1 (non-binding)
--
Best！
Xuyang
在 2024-01-26 10:12:34，"Hang Ruan" 写道：
>Thanks for the FLIP.
>
>+1 (non-binding)
>
>Best,
>Hang
>
>Mason Chen 于2024年1月26日周五 04:51写道：
>
>> Hi Devs,
>>
>> I would like to start a vote on FLIP-4
rence regarding the restart discussion. It seems
that there is no difference on this syntax
in FLIP-436, so maybe it would be best to refer back to FLIP-69 in this FLIP.
WDYT?
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-69%3A+Flink+SQL+DDL+Enhancement
--
Best！
Xuyang
Cheers!
--
Best！
Xuyang
在 2024-03-21 10:28:45，"Rui Fan" <1996fan...@gmail.com> 写道：
>Congratulations!
>
>Best,
>Rui
>
>On Thu, Mar 21, 2024 at 10:25 AM Hang Ruan wrote:
>
>> Congrattulations!
>>
>> Best,
>> Hang
>>
Congratulations, Lincoln.
--
Best！
Xuyang
在 2024-04-14 21:49:53，"Benchao Li" 写道：
>Congratulations, Lincoln. Well deserved!
>
>Leonard Xu 于2024年4月14日周日 21:19写道：
>>
>> Congratulations, Lincoln~
>>
>> Best,
>> Leonar
Congratulations, Jing!
--
Best！
Xuyang
在 2024-04-15 08:53:32，"yuxia" 写道：
>Congratulations, Jing.
>
>Best regards,
>Yuxia
>
>- 原始邮件 -
>发件人: "Leonard Xu"
>收件人: "dev"
>发送时间: 星期日, 2024年 4 月 14日 下午 9:17:58
-scheduler.type has no default value; should it be set to CRON
by default?
4. It appears that in the section on `public interfaces`, within
`WorkflowOperation`, `CreatePeriodicWorkflowOperation` should be changed to
`CreateWorkflowOperation`, right?
--
Best！
Xuyang
At 2024-04
+1 (non-binding)
--
Best！
Xuyang
At 2024-05-09 13:57:07, "Ron Liu" wrote:
>Sorry for the re-post, just to format this email content.
>
>Hi Dev
>
>Thank you to everyone for the feedback on FLIP-448: Introduce Pluggable
>Workflow Scheduler Interface
ction {
transient Function f;
@Override
public void open(FunctionContext context) throws Exception {
f = str -> str + ":test";
}
public String eval(String s) {
return f.apply(s);
}
}
```
--
Best！
Xuyang
在 2024-05-1
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 cas
in
Flink SQL for Batch job.
I'm look forward to your feedback about FLIP-229.
--
Best！
Xuyang
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-229%3A+Introduces+Join+Hint+for+Flink+SQL+Batch+Job
[2]
https://docs.google.com/docum
our
design docs into the wiki?Thanks for your reminder, I have moved the
content from doc to the wiki.
At 2022-05-07 12:46:18, "Jark Wu" wrote:
>Hi Xuyang,
>
>Thanks for starting this discussion. Join Hint is a long-time requested
>feature.
>I have briefly gone through t
recorded in this Flip because I think Flip is mainly used to describe
the changes about api. You can focus on the specific PRs below this Flip later.
—— "I think the inherit info should also be used to check, not only using the
table name."
I don't understand this and could you add an example to explain this question?
--
Best！
Xuyang
f the table or view could not
be found.
What do you think about this.
--
Best！
Xuyang
At 2022-05-09 12:50:28, "Jingsong Li" wrote:
>Thanks Xuyang for driving.
>
>zoucao also mentioned alias.
>
>Can you explain in the FLIP why alias is not supported?
o use a internel information to tag alias. I
open an issue in Calcite https://issues.apache.org/jira/browse/CALCITE-5144 and
you can follow it if necessary. But for the initial version, we can temporarily
not support it. And we can support it as a improvement work.
--
Best！
Xuy
Hi, everyone.
Thanks for your feedback for FLIP-229: Introduces Join Hint for Flink SQL Batch
Job[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 objection or not enough votes.
--
Best！
Xuyang
[1]
concerns on this FLIP.
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-229%3A+Introduces+Join+Hint+for+Flink+SQL+Batch+Job
[2] https://lists.apache.org/thread/s70cjbbr5565m44f4mfqo9w7xdq09cf1
--
Best！
Xuyang
Hi, everyone can reply the issue but contributors also could not assign the
issue to themselves. You can reply to the discussion in the issue where you
what to fix the bug, and if a committer sees it, he will assign to you.
--
Best！
Xuyang
At 2022-05-22 18:58:02, "Dav
is Flip, I aggree that in the
initial version we can support HTTP Sink in DataStream Api only ; )
* IMO, a simple example added in the end of the flip is necessary.
WDYT?
--
Best！
Xuyang
在 2022-06-01 23:32:50，"Krzysztof Chmielewski"
写道：
>Hello Jeremy,
>I'm th
nested? For example, can another
finished
declared chain1 be used within a declared chain2?
--
Best！
Xuyang
At 2024-07-30 14:06:08, "Zakelly Lan" wrote:
>Hi devs,
>
>I would like to initiate a discussion about FLIP-455: Declare async state
>processing
aging the new asynchronous state architecture
in Flink SQL jobs.
For more details, please refer to the FLIP-473[1]. Welcome any feedback and
suggestions for improvement.
There has been POC code[3] related to the Join operator.
Best！
Xuyang
[1]
https://cwiki.apache.org/confl
ch between asynchronous and
synchronous state operators.
--
Best！
Xuyang
At 2024-08-06 18:54:24, "Zakelly Lan" wrote:
>Hi Xuyang,
>
>Thanks for driving this! I'm happy to see operator implementation on top of
>the async state. Overall it looks good, I hav
that after the
SQL AsyncStateOperator supports in-flight checkpoints in FLIP-455[2], switching
back and forth between
aligned and unaligned checkpoints is not compatible, which is an expected
behavior.
--
Best！
Xuyang
在 2024-08-07 19:05:57，"Xuyang" 写道：
&g
harness tests to validate data
correctness, and there will also be
dedicated harness tests for asynchronous operators. Using a parameterized test
suite for both harnesses is indeed feasible.
--
Best！
Xuyang
在 2024-08-09 20:49:49，"David Morávek" 写道：
>Hi Xuyang,
>
&g
+1 (non-binding)
--
Best！
Xuyang
在 2024-08-14 11:04:18，"Yuepeng Pan" 写道：
>
>
>
>+1 (non-binding)
>Thanks for driving it !
>
>
>Best regards,
>
>Yuepeng Pan
>
>
>
>
>
>
>
>
>
>
>
>在 2024-08-14 10:32:03，&q
the APIs `thenCombine` and `combineAll`, I have also
added a
concluding note that there is no significant performance difference between
these two,
so either one can be used interchangeably.
--
Best！
Xuyang
At 2024-08-13 17:10:32, "Feng Jin" wrote:
>Hi, Xuyang
Hi everyone.
Thank you for all the insights and suggestions from those who participated in
the discussion.
If there are no further comments, I will initiate the voting on August 21, 2024.
--
Best！
Xuyang
在 2024-08-19 10:26:01，"ron" 写道：
>Hi, Xuyang
>
>Thank
://cwiki.apache.org/confluence/display/FLINK/FLIP-473+Introduce+New+SQL+Operators+Based+on+Asynchronous+State+APIs
[2] https://lists.apache.org/thread/k6x03x7vjtn3gl1vrknkx8zvyn319bk9
--
Best！
Xuyang
e.org/confluence/display/FLINK/FLIP-473+Introduce+New+SQL+Operators+Based+on+Asynchronous+State+APIs
--
Best！
Xuyang
Thank you to everyone who participated. The voting is now closed.
--
Best！
Xuyang
在 2024-08-23 22:12:04，"David Radley" 写道：
>+1 (non-binding)
>
>Kind regards, David.
>
>From: Lincoln Lee
>Date: Thursday, 22 August 2024 at 03:35
>To: dev@flink.apac
Hi, Yang Li.
IIUC, Your issue is similar to the one described in this JIRA[1], right?
[1] https://issues.apache.org/jira/browse/FLINK-33936
--
Best！
Xuyang
At 2024-10-29 15:16:14, "李阳" wrote:
>Hello devs,
>
>I would like to initiate a discussion about the
Hi, Shegnkai.
Thank you for your answer. I have no further questions.
--
Best！
Xuyang
At 2024-11-04 10:00:32, "Shengkai Fang" wrote:
>Hi, Xuyang. Thanks a lot for your response!
>
>> Does that means we will support multi DMLs, multi DQLs, mixed DMLs &am
+1 (non-binding)
--
Best！
Xuyang
在 2024-11-12 03:42:33，"Jim Hughes" 写道：
>Hi Timo,
>
>I'm +1 (non-binding) on the FLIP.
>
>As a point of order, is the vote supposed to happen in a new thread?
>
>Cheers,
>
>Jim
>
>On Mon, Nov 11,
+1 (non-binding)
--
Best！
Xuyang
在 2024-11-12 10:02:27，"Ron Liu" 写道：
>+1(binding)
>
>Best,
>Ron
>
>Gyula Fóra 于2024年11月12日周二 01:27写道：
>
>> + 1(binding)
>>
>> Thanks for answering my concerns/questions.
>>
>>
lain
a little about how do they work?
[1]
https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/overview/#application-mode
--
Best！
Xuyang
在 2024-10-31 10:18:13，"Ron Liu" 写道：
>Hi, Shengkai
>
>Thanks for your quick response. It looks g
the input data (Row
input), while other times it only consists of the input data. Are we allowing
users to define both styles simultaneously？
[1]
https://cwiki.apache.org/confluence/display/FLINK/FLIP-387%3A+Support+named+parameters+for+functions+and+call+procedures
--
Best！
Xu
Congratulations, Junrui!
--
Best！
Xuyang
在 2024-11-06 14:34:36，"Yuepeng Pan" 写道：
>Congratulations!
>
>
>Best,
>Yuepeng Pan
>
>
>
>At 2024-11-06 14:08:41, "Xia Sun" wrote:
>>Congratulations Junrui!
>>
>>
>>Best
to other window-related operators
in the future.
3. You need to modify the FlinkChangelogModeInferenceProgram to ensure that
downstream nodes of interval joins with
early firing enabled are aware of retract or upsert messages.
--
Best！
Xuyang
At 2025-01-07 06:35:51, "Xi
+1 (non-binding)
--
Best！
Xuyang
在 2025-01-02 10:51:07，"Shengkai Fang" 写道：
>+1(binding)
>
>Best,
>Shengkai Fang
>
>Yuepeng Pan 于2024年12月31日周二 15:58写道：
>
>> +1 (non-binding)
>>
>>
>> Best,
>> Yuepeng Pan
>>
>&
+1 (non-binding)
--
Best！
Xuyang
在 2024-12-31 16:48:15，"Dawid Wysakowicz" 写道：
>+1(binding)
>Best,
>Dawid
>
>On Tue, 24 Dec 2024 at 08:27, Feng Jin wrote:
>
>> +1 (non-binding)
>>
>> Best,
>> Feng Jin
>>
>>
>&
Hi, all.
Given that there have been no objections or additional comments, we will
proceed to remove
the default implementation classes of the affected classes. Thank you to
everyone who was
involved.
--
Best！
Xuyang
在 2025-01-03 13:41:16，"Ron Liu" 写道：
&
.
- Nevertheless, whether early firing is enabled or disabled, the IntervalJoin
should always require its input to keep
ModifyKind with INSERT_ONLY and UpdateKind with NONE.
--
Best！
Xuyang
At 2025-01-09 15:30:44, "Weiqing Yang" wrote:
>Hi Xingcan and Xuyang,
>
>Thanks so mu
The discuss will be open for at least 72 hours to collect dicisions.--
Best！
Xuyang
At 2025-01-03 12:06:38, "Xuyang" wrote:
>Hi, all.
>
>Feng Jing, Ron Liu and I are are currently working on removing deprecated
>public APIs from the table module and hav
+1 to delete the overrided default methods that throw exceptions.
--
Best！
Xuyang
在 2025-01-03 12:55:38，"Xuyang" 写道：
The discuss will be open for at least 72 hours to collect dicisions.
--
Best！
Xuyang
At 2025-01-03 12:06:38, "Xuyang" wrot
--
Best！
Xuyang
LGTM overall. Thanks for updating. I have no problem and +1 for this feature.
--
Best！
Xuyang
在 2025-01-15 12:33:16，"Weiqing Yang" 写道：
>Hi Xuyang,
>
>Thank you for your detailed feedback! I’ve updated the proposal doc
>accordingly. Please feel free to tak
Hi, Sergey.
Thanks for driving this. +1 for this great work.
--
Best！
Xuyang
At 2025-01-16 22:40:33, "Ahmed Hamdy" wrote:
>Hi Sergey,
>
>+1 for restarting this.
>
>Best Regards
>Ahmed Hamdy
>
>
>On Thu, 16 Jan 2025 at 14:02, David Radley w
+1 (non-binding)--
Best！
Xuyang
在 2025-01-30 00:18:47，"Xingcan Cui" 写道：
>+1 (binding)
>
>Best,
>Xingcan
>
>On Mon, Jan 27, 2025 at 8:50 PM Venkatakrishnan Sowrirajan
>wrote:
>
>> +1 (non-binding)
>>
>> Regards
>> Venkata
Congratulations, Feng Jin ;)--
Best！
Xuyang
在 2025-02-21 11:16:14，"Wei Zuo" <1015766...@qq.com.INVALID> 写道：
>Congratulations!
>
>Best,
>Zuo Wei
>
>
>--
emain unchanged?
Looking forward your reply.
--
Best！
Xuyang
At 2025-02-28 19:16:12, "Dawid Wysakowicz" wrote:
>Hey Xuyang,
>Ad. 1
>Yes, you're right, but we already do that for determining if we need
>UPDATE_BEFORE or not. FlinkChangelogModeInferen
right?
4. Regarding supportsDeleteByKey, as part of a complete ChangelogMode entity,
should we also store the specific key information?
--
Best！
Xuyang
在 2025-02-28 04:27:19，"Martijn Visser" 写道：
>Hi Dawid,
>
>Thanks for the FLIP, looks like a good improvement for
I have no other questions. +1 for it.
--
Best！
Xuyang
At 2025-03-07 19:37:09, "Dawid Wysakowicz" wrote:
>>
>> From my understanding, for a sink, if its schema includes a primary key,
>> we can assume it has
>> the ability to process delet
+1(binding)
--
Best！
Xuyang
在 2025-03-11 19:12:05，"Leonard Xu" 写道：
>+1(binding)
>
>Best,
>Leonard
>
>> 2025年3月11日 18:42，Timo Walther 写道：
>>
>> +1 (binding)
>>
>> Thanks for working on this!
>>
>> Timo
>>
xuyang created FLINK-33395:
--
Summary: The join hint doesn't work when appears in subquery
Key: FLINK-33395
URL: https://issues.apache.org/jira/browse/FLINK-33395
Project: Flink
Issue Type
xuyang created FLINK-33396:
--
Summary: The table alias when using join hints should be removed
in the final plan
Key: FLINK-33396
URL: https://issues.apache.org/jira/browse/FLINK-33396
Project: Flink
xuyang created FLINK-33489:
--
Summary: LISTAGG with generating partial-final agg will case wrong
result
Key: FLINK-33489
URL: https://issues.apache.org/jira/browse/FLINK-33489
Project: Flink
Issue
xuyang created FLINK-33583:
--
Summary: Support state ttl hint for join
Key: FLINK-33583
URL: https://issues.apache.org/jira/browse/FLINK-33583
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-33740:
--
Summary: Introduce a flip to list the supported sql patterns
Key: FLINK-33740
URL: https://issues.apache.org/jira/browse/FLINK-33740
Project: Flink
Issue Type
xuyang created FLINK-33760:
--
Summary: Group Window agg has different result when only consuming
-D records while using or not using minibatch
Key: FLINK-33760
URL: https://issues.apache.org/jira/browse/FLINK-33760
xuyang created FLINK-33878:
--
Summary: Many Keyed Operator extends `TableStreamOperator` which
is marked without key.
Key: FLINK-33878
URL: https://issues.apache.org/jira/browse/FLINK-33878
Project: Flink
xuyang created FLINK-33928:
--
Summary: Should not throw exception while creating view with
specify field names even if the query conflicts in field names
Key: FLINK-33928
URL: https://issues.apache.org/jira/browse/FLINK
xuyang created FLINK-33941:
--
Summary: Use field index instead of field name about window time
column
Key: FLINK-33941
URL: https://issues.apache.org/jira/browse/FLINK-33941
Project: Flink
Issue
xuyang created FLINK-34034:
--
Summary: When kv hint and list hint handle duplicate query hints,
the results are different.
Key: FLINK-34034
URL: https://issues.apache.org/jira/browse/FLINK-34034
Project
xuyang created FLINK-34039:
--
Summary: The session group window agg operator does not split the
session window when processing retrace records.
Key: FLINK-34039
URL: https://issues.apache.org/jira/browse/FLINK-34039
xuyang created FLINK-34048:
--
Summary: Support Session Window Aggregate in table runtime
Key: FLINK-34048
URL: https://issues.apache.org/jira/browse/FLINK-34048
Project: Flink
Issue Type: Sub-task
1 - 100 of 231 matches
Mail list logo
