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
>
{
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-15 23:
+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
-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
xuyang created FLINK-35271:
--
Summary: Add doc for syntax `describe job 'xxx'`
Key: FLINK-35271
URL: https://issues.apache.org/jira/browse/FLINK-35271
Project: Flink
Issue Type: Sub-task
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
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
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
>>
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
At 2024-03
xuyang created FLINK-34381:
--
Summary: `RelDataType#getFullTypeString` should be used to print
in `RelTreeWriterImpl` if `withRowType` is true instead of `Object#toString`
Key: FLINK-34381
URL: https://issues.apache.org
xuyang created FLINK-34380:
--
Summary: Strange RowKind and records about intermediate output
when using minibatch join
Key: FLINK-34380
URL: https://issues.apache.org/jira/browse/FLINK-34380
Project: Flink
xuyang created FLINK-34378:
--
Summary: Minibatch join disrupted the original order of input
records
Key: FLINK-34378
URL: https://issues.apache.org/jira/browse/FLINK-34378
Project: Flink
Issue Type
xuyang created FLINK-34375:
--
Summary: Complete work for syntax `DESCRIBE EXTENDED tableName`
Key: FLINK-34375
URL: https://issues.apache.org/jira/browse/FLINK-34375
Project: Flink
Issue Type: Sub
xuyang created FLINK-34374:
--
Summary: Complete work for syntax `DESCRIBE EXTENDED DATABASE
databaseName`
Key: FLINK-34374
URL: https://issues.apache.org/jira/browse/FLINK-34374
Project: Flink
xuyang created FLINK-34373:
--
Summary: Complete work for syntax `DESCRIBE DATABASE databaseName`
Key: FLINK-34373
URL: https://issues.apache.org/jira/browse/FLINK-34373
Project: Flink
Issue Type
xuyang created FLINK-34372:
--
Summary: Complete work for syntax `DESCRIBE CATALOG catalogName`
Key: FLINK-34372
URL: https://issues.apache.org/jira/browse/FLINK-34372
Project: Flink
Issue Type: Sub
xuyang created FLINK-34370:
--
Summary: [Umbrella] Complete work about enhanced Flink SQL DDL
Key: FLINK-34370
URL: https://issues.apache.org/jira/browse/FLINK-34370
Project: Flink
Issue Type
xuyang created FLINK-34353:
--
Summary: A strange exception will be thrown if minibatch size is
not set while using mini-batch join
Key: FLINK-34353
URL: https://issues.apache.org/jira/browse/FLINK-34353
xuyang created FLINK-34348:
--
Summary: Release Testing: Verify FLINK-20281 Window aggregation
supports changelog stream input
Key: FLINK-34348
URL: https://issues.apache.org/jira/browse/FLINK-34348
Project
xuyang created FLINK-34346:
--
Summary: Release Testing: Verify FLINK-24024 Support session
Window TVF
Key: FLINK-34346
URL: https://issues.apache.org/jira/browse/FLINK-34346
Project: Flink
Issue
xuyang created FLINK-34338:
--
Summary: An exception is thrown when some named params change
order when using window tvf
Key: FLINK-34338
URL: https://issues.apache.org/jira/browse/FLINK-34338
Project: Flink
xuyang created FLINK-34335:
--
Summary: Query hints in RexSubQuery could not be printed
Key: FLINK-34335
URL: https://issues.apache.org/jira/browse/FLINK-34335
Project: Flink
Issue Type: Bug
xuyang created FLINK-34323:
--
Summary: Session window tvf failed when using named params
Key: FLINK-34323
URL: https://issues.apache.org/jira/browse/FLINK-34323
Project: Flink
Issue Type: Bug
xuyang created FLINK-34315:
--
Summary: Forcibly disable window join, window rank and window
deduplicate optimization when using session window tvf
Key: FLINK-34315
URL: https://issues.apache.org/jira/browse/FLINK-34315
xuyang created FLINK-34313:
--
Summary: Update doc about session window tvf
Key: FLINK-34313
URL: https://issues.apache.org/jira/browse/FLINK-34313
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-34271:
--
Summary: Fix the unstable test about
GroupAggregateRestoreTest#AGG_WITH_STATE_TTL_HINT
Key: FLINK-34271
URL: https://issues.apache.org/jira/browse/FLINK-34271
Project: Flink
xuyang created FLINK-34254:
--
Summary: `DESCRIBE` syntaxes like `DESCRIBE CATALOG xxx` throws
strange exceptions
Key: FLINK-34254
URL: https://issues.apache.org/jira/browse/FLINK-34254
Project: Flink
+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
xuyang created FLINK-34238:
--
Summary: In streaming mode, redundant exchange nodes can be
optimally deleted in some cases
Key: FLINK-34238
URL: https://issues.apache.org/jira/browse/FLINK-34238
Project
xuyang created FLINK-34235:
--
Summary: Not using Optional as input arguments in
QueryHintsResolver
Key: FLINK-34235
URL: https://issues.apache.org/jira/browse/FLINK-34235
Project: Flink
Issue Type
xuyang created FLINK-34175:
--
Summary: When meeting WindowedSliceAssigner, slice window agg
registers an wrong timestamp timer
Key: FLINK-34175
URL: https://issues.apache.org/jira/browse/FLINK-34175
Project
+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-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
xuyang created FLINK-34141:
--
Summary: Bash exited with code '143'
Key: FLINK-34141
URL: https://issues.apache.org/jira/browse/FLINK-34141
Project: Flink
Issue Type: Bug
Components: Build
xuyang created FLINK-34140:
--
Summary: Rename WindowContext in window
Key: FLINK-34140
URL: https://issues.apache.org/jira/browse/FLINK-34140
Project: Flink
Issue Type: Improvement
xuyang created FLINK-34139:
--
Summary: The window assigner should not reveal its event time or
process time at the interface level.
Key: FLINK-34139
URL: https://issues.apache.org/jira/browse/FLINK-34139
xuyang created FLINK-34138:
--
Summary: Improve the interface about MergeCallback in window
Key: FLINK-34138
URL: https://issues.apache.org/jira/browse/FLINK-34138
Project: Flink
Issue Type
+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
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, "Kar
xuyang created FLINK-34100:
--
Summary: Support session window table function without pulling up
with window agg
Key: FLINK-34100
URL: https://issues.apache.org/jira/browse/FLINK-34100
Project: Flink
the 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 minibatch join coul
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:19:30，"Benc
/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 impossible t
+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
xuyang created FLINK-34049:
--
Summary: Refactor classes related to window TVF aggregation to
prepare for non-aligned windows
Key: FLINK-34049
URL: https://issues.apache.org/jira/browse/FLINK-34049
Project
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(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
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-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
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
ny 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 FLIP is called &
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
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 Table
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
: 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，"Timo Walther" 写道：
>Hi Xu
...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 FlinkSqlOperatorTable, am
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
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
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 leavi
ase, 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 mention
.
[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
--
Best！
Xuyang
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 ch
will 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 Xuyang
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
在 2023-12
ew 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 from
>FLIP-145[
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，"Shen
quot;. 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.
>
>At first,
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
>&g
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 compatibility across middle versions o
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
for 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.
>
>S
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
://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
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, "Lincoln Lee" wrote:
>Thanks Y
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-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-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-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: Bug
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
+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 enableFi
！
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: Kafka and a database (CDC).
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" wrote
+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 consens
as the 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
xuyang created FLINK-29280:
--
Summary: Hint will not be propagated in subquery
Key: FLINK-29280
URL: https://issues.apache.org/jira/browse/FLINK-29280
Project: Flink
Issue Type: Bug
xuyang created FLINK-29221:
--
Summary: Adding join hint in sql may cause imcompatible state
Key: FLINK-29221
URL: https://issues.apache.org/jira/browse/FLINK-29221
Project: Flink
Issue Type
xuyang created FLINK-29081:
--
Summary: Join Hint cannot be identified by lowercase
Key: FLINK-29081
URL: https://issues.apache.org/jira/browse/FLINK-29081
Project: Flink
Issue Type: Bug
xuyang created FLINK-29074:
--
Summary: use 'add jar' in sql client throws "Could not find any
jdbc dialect factories that implement"
Key: FLINK-29074
URL: https://issues.apache.org/jira/browse/F
xuyang created FLINK-28969:
--
Summary: Release Testing: Verify FLIP-229 Join Hints for Flink SQL
Batch
Key: FLINK-28969
URL: https://issues.apache.org/jira/browse/FLINK-28969
Project: Flink
Issue
xuyang created FLINK-28682:
--
Summary: support join hint in flink batch
Key: FLINK-28682
URL: https://issues.apache.org/jira/browse/FLINK-28682
Project: Flink
Issue Type: Sub-task
xuyang created FLINK-28678:
--
Summary: Support SQL hint for Filter, SetOp, Sort, Window, Values
Key: FLINK-28678
URL: https://issues.apache.org/jira/browse/FLINK-28678
Project: Flink
Issue Type: New
xuyang created FLINK-27876:
--
Summary: Error side is chosen in BatchPhysicalHashJoinRule when
the join is Semi or Anti
Key: FLINK-27876
URL: https://issues.apache.org/jira/browse/FLINK-27876
Project: Flink
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 the ori
xuyang created FLINK-27853:
--
Summary: FLIP-229: Introduces Join Hint for Flink SQL Batch Job
Key: FLINK-27853
URL: https://issues.apache.org/jira/browse/FLINK-27853
Project: Flink
Issue Type: New
xuyang created FLINK-27851:
--
Summary: Join can't access the pk from source table
Key: FLINK-27851
URL: https://issues.apache.org/jira/browse/FLINK-27851
Project: Flink
Issue Type: Bug
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
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.
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]
https
lcite 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！
Xuyang
At 2022-05-09 18:31:40, "cao zou" wrote:
>
of 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? W
1 - 100 of 110 matches
Mail list logo
