yuanfenghu created FLINK-35823:
--
Summary: Introduce parameters to control the upper limit of
rescale to avoid unlimited shrinkage due to server-side bottlenecks or data
skew.
Key: FLINK-35823
URL: https://issues.apa
[
https://issues.apache.org/jira/browse/FLINK-35823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35823:
---
Summary: Introduce parameters to control the upper limit of rescale to
avoid unlimited 扩容 due to ser
[
https://issues.apache.org/jira/browse/FLINK-35823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35823:
---
Summary: Introduce parameters to control the upper limit of rescale to
avoid unlimited expansion due
[
https://issues.apache.org/jira/browse/FLINK-35823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865280#comment-17865280
]
yuanfenghu commented on FLINK-35823:
I have discussed this issue with [~fanrui] . I
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17865776#comment-17865776
]
yuanfenghu commented on FLINK-35035:
[~ztison]
Thanks, I will look into FLIP in det
[
https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35851:
---
Description: 我们应该使用
> autoscaler standlone mode use `GlobalConfiguration.loadConfiguration` load
>
yuanfenghu created FLINK-35851:
--
Summary: autoscaler standlone mode use
`GlobalConfiguration.loadConfiguration` load config
Key: FLINK-35851
URL: https://issues.apache.org/jira/browse/FLINK-35851
Project
[
https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35851:
---
Description:
We should use GlobalConfiguration.loadConfiguration to load the autocaler
configuratio
[
https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866626#comment-17866626
]
yuanfenghu commented on FLINK-35851:
[~fanrui] Thanks for the reply.
My idea is th
[
https://issues.apache.org/jira/browse/FLINK-35851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866626#comment-17866626
]
yuanfenghu edited comment on FLINK-35851 at 7/17/24 6:05 AM:
-
yuanfenghu created FLINK-35896:
--
Summary: eventHandler in RescaleApiScalingRealizer handle the
event of scaling failure
Key: FLINK-35896
URL: https://issues.apache.org/jira/browse/FLINK-35896
Project: F
[
https://issues.apache.org/jira/browse/FLINK-35896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868629#comment-17868629
]
yuanfenghu commented on FLINK-35896:
[~fanrui]
Can you give me some advice on this
[
https://issues.apache.org/jira/browse/FLINK-35896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868631#comment-17868631
]
yuanfenghu edited comment on FLINK-35896 at 7/25/24 10:23 AM:
[
https://issues.apache.org/jira/browse/FLINK-35896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868631#comment-17868631
]
yuanfenghu commented on FLINK-35896:
When an exception occurs in ScalingRealizer.rea
[
https://issues.apache.org/jira/browse/FLINK-35896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868639#comment-17868639
]
yuanfenghu commented on FLINK-35896:
> RescaleApiScalingRealizer#realizeParallelismO
yuanfenghu created FLINK-35903:
--
Summary: Add CentralizedSlotAssigner support to adaptive scheduler
Key: FLINK-35903
URL: https://issues.apache.org/jira/browse/FLINK-35903
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35903:
---
Affects Version/s: 2.0.0
> Add CentralizedSlotAssigner support to adaptive scheduler
> -
[
https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu closed FLINK-35903.
--
Resolution: Duplicate
> Add CentralizedSlotAssigner support to adaptive scheduler
> --
[
https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868874#comment-17868874
]
yuanfenghu commented on FLINK-35903:
[~Zhanghao Chen] thansk, I closed this issue
[
https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868874#comment-17868874
]
yuanfenghu edited comment on FLINK-35903 at 7/26/24 7:19 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-35903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17868877#comment-17868877
]
yuanfenghu commented on FLINK-35903:
> Instead, all implementations of SlotAssigner
yuanfenghu created FLINK-34535:
--
Summary: Support JobPlanInfo for the explain result
Key: FLINK-34535
URL: https://issues.apache.org/jira/browse/FLINK-34535
Project: Flink
Issue Type: Improvemen
[
https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17821481#comment-17821481
]
yuanfenghu commented on FLINK-34535:
cc [~luoyuxia]
> Support JobPlanInfo for the
[
https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822399#comment-17822399
]
yuanfenghu commented on FLINK-34535:
[~lincoln.86xy]
Thank you for your comment,
>
[
https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822472#comment-17822472
]
yuanfenghu commented on FLINK-34535:
Hi [~jeyhunkarimov]
谢谢你的评论，其实我的想法很简单，我希望在使用 f
[
https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17822472#comment-17822472
]
yuanfenghu edited comment on FLINK-34535 at 3/1/24 9:45 AM:
yuanfenghu created FLINK-35035:
--
Summary: Reduce job pause time when cluster resources are expanded
in adaptive mode
Key: FLINK-35035
URL: https://issues.apache.org/jira/browse/FLINK-35035
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35035:
---
Description:
When 'jobmanager.scheduler = adaptive' , job graph changes triggered by cluster
expans
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35035:
---
Description:
When 'jobmanager.scheduler = adaptive' , job graph changes triggered by cluster
expans
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835106#comment-17835106
]
yuanfenghu commented on FLINK-35035:
[~bgeng777]
Thank you for your comment. As you
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835106#comment-17835106
]
yuanfenghu edited comment on FLINK-35035 at 4/9/24 2:22 AM:
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835564#comment-17835564
]
yuanfenghu commented on FLINK-35035:
[~echauchot]
Thank you for your reply, but I h
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835564#comment-17835564
]
yuanfenghu edited comment on FLINK-35035 at 4/10/24 2:08 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17835564#comment-17835564
]
yuanfenghu edited comment on FLINK-35035 at 4/10/24 2:19 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836395#comment-17836395
]
yuanfenghu commented on FLINK-35035:
[~echauchot]
Thank you for your reply.
You s
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836395#comment-17836395
]
yuanfenghu edited comment on FLINK-35035 at 4/12/24 6:08 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836504#comment-17836504
]
yuanfenghu commented on FLINK-35035:
[~echauchot]
Thank you for your patience in tr
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17836508#comment-17836508
]
yuanfenghu commented on FLINK-35035:
> It is not slot per slot rescale, there will b
yuanfenghu created FLINK-35926:
--
Summary: During rescale, jobmanager has incorrect judgment logic
for the max parallelism.
Key: FLINK-35926
URL: https://issues.apache.org/jira/browse/FLINK-35926
Project:
[
https://issues.apache.org/jira/browse/FLINK-35926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35926:
---
Summary: During rescale, AdaptiveScheduler has incorrect judgment logic for
the max parallelism. (w
[
https://issues.apache.org/jira/browse/FLINK-35926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35926:
---
Description:
When I was using the adaptive scheduler and modified the task in parallel
through the
[
https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872207#comment-17872207
]
yuanfenghu commented on FLINK-36018:
[~fanrui] , It seems like a good change, This i
yuanfenghu created FLINK-36022:
--
Summary: When scaling.enabled =false, adjust the values of
some parameters to provide bette recommendation values.
Key: FLINK-36022
URL: https://issues.apache.org/jira/browse/FLIN
[
https://issues.apache.org/jira/browse/FLINK-36022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872211#comment-17872211
]
yuanfenghu commented on FLINK-36022:
[~gyfora] [~mxm] [~fanrui] ,
Can express opini
[
https://issues.apache.org/jira/browse/FLINK-36192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878458#comment-17878458
]
yuanfenghu commented on FLINK-36192:
[~gyfora]
hi, can you take a look at this ques
yuanfenghu created FLINK-36192:
--
Summary: Optimize the logic to make it the common divisor of the
partition number of the data source when determining the parallelism of the
source task.
Key: FLINK-36192
URL: https:
[
https://issues.apache.org/jira/browse/FLINK-36192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878679#comment-17878679
]
yuanfenghu commented on FLINK-36192:
> To fix the issue, we may have to add an expli
[
https://issues.apache.org/jira/browse/FLINK-36192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878715#comment-17878715
]
yuanfenghu commented on FLINK-36192:
{quote}{color:#172b4d}In addition to the above
[
https://issues.apache.org/jira/browse/FLINK-36192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878747#comment-17878747
]
yuanfenghu commented on FLINK-36192:
{quote}Overall LGTM, could we involve the verte
[
https://issues.apache.org/jira/browse/FLINK-36192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878747#comment-17878747
]
yuanfenghu edited comment on FLINK-36192 at 9/3/24 7:18 AM:
[
https://issues.apache.org/jira/browse/FLINK-36192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17878747#comment-17878747
]
yuanfenghu edited comment on FLINK-36192 at 9/3/24 7:18 AM:
yuanfenghu created FLINK-35462:
--
Summary: Introduce a parameter to control the chaining mode
between a Flink SQL connector sink or source and its adjacent operator.
Key: FLINK-35462
URL: https://issues.apache.org/jir
[
https://issues.apache.org/jira/browse/FLINK-35462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35462:
---
Description:
When using the flinksql connector, we can set the parallelism of the sink.
However, wh
[
https://issues.apache.org/jira/browse/FLINK-35462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-35462:
---
Description:
When using the flinksql connector, we can set the parallelism of the sink.
However, wh
yuanfenghu created FLINK-33087:
--
Summary: FlinkSql unable to parse field annotation information
Key: FLINK-33087
URL: https://issues.apache.org/jira/browse/FLINK-33087
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-33087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-33087:
---
Description:
如果使用flinksql建表，
{code:java}
CREATE TABLE `ods_kafka_stream_taf_report_lakehouse_pipelin
[
https://issues.apache.org/jira/browse/FLINK-33087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-33087:
---
Description:
If use flinksql to create a table:
{code:java}
CREATE TABLE `test_table` (
`id` STR
[
https://issues.apache.org/jira/browse/FLINK-33087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-33087:
---
Description:
If use flinksql to create a table:
{code:java}
CREATE TABLE `test_table` (
`id` STR
[
https://issues.apache.org/jira/browse/FLINK-33087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-33087:
---
Description:
If use flinksql to create a table:
{code:java}
CREATE TABLE `test_table` (
`id` STR
[
https://issues.apache.org/jira/browse/FLINK-33087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-33087:
---
Description:
If use flinksql to create a table:
{code:java}
CREATE TABLE `test_table` (
`id` STR
[
https://issues.apache.org/jira/browse/FLINK-33087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-33087:
---
Summary: FlinkSql unable to parse column comment information (was:
FlinkSql unable to parse column
[
https://issues.apache.org/jira/browse/FLINK-33087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-33087:
---
Summary: FlinkSql unable to parse column annotation information (was:
FlinkSql unable to parse fiel
[
https://issues.apache.org/jira/browse/FLINK-33087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-33087:
---
Summary: FlinkSql unable to parse column comment (was: FlinkSql unable to
parse column comment info
[
https://issues.apache.org/jira/browse/FLINK-33087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu closed FLINK-33087.
--
Resolution: Fixed
> FlinkSql unable to parse column comment
> ---
[
https://issues.apache.org/jira/browse/FLINK-33087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-33087:
---
Affects Version/s: 1.16.2
(was: 1.17.1)
> FlinkSql unable to parse column
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17769033#comment-17769033
]
yuanfenghu commented on FLINK-25373:
我也遇到了同样的问题
> task manager can not free memory
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17769033#comment-17769033
]
yuanfenghu edited comment on FLINK-25373 at 9/26/23 6:58 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17769033#comment-17769033
]
yuanfenghu edited comment on FLINK-25373 at 9/26/23 7:01 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17769033#comment-17769033
]
yuanfenghu edited comment on FLINK-25373 at 9/26/23 7:01 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17769033#comment-17769033
]
yuanfenghu edited comment on FLINK-25373 at 9/26/23 7:04 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17769033#comment-17769033
]
yuanfenghu edited comment on FLINK-25373 at 9/26/23 7:48 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17769033#comment-17769033
]
yuanfenghu edited comment on FLINK-25373 at 9/26/23 8:56 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737623#comment-17737623
]
yuanfenghu commented on FLINK-23190:
[~loyi] 我认为有些缺陷，我之前也做过类似的工作，比如
> Make task-slo
[ https://issues.apache.org/jira/browse/FLINK-23190 ]
yuanfenghu deleted comment on FLINK-23190:
was (Author: JIRAUSER296932):
[~loyi] 我认为有些缺陷，我之前也做过类似的工作，比如
> Make task-slot allocation much more evenly
> ---
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737625#comment-17737625
]
yuanfenghu commented on FLINK-23190:
loyi
I think there are still some problems, m
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737632#comment-17737632
]
yuanfenghu commented on FLINK-23190:
[~loyi] I think there are other issues to cons
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737625#comment-17737625
]
yuanfenghu edited comment on FLINK-23190 at 6/27/23 12:32 PM:
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738089#comment-17738089
]
yuanfenghu commented on FLINK-23190:
[~loyi]
no, i just use
```
private Collecti
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738089#comment-17738089
]
yuanfenghu edited comment on FLINK-23190 at 6/28/23 12:15 PM:
[ https://issues.apache.org/jira/browse/FLINK-23190 ]
yuanfenghu deleted comment on FLINK-23190:
was (Author: JIRAUSER296932):
[~loyi]
no, i just use
```
private Collection sortExecutionSlotSharingGroup(
Collection executionVertexGroups)
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738090#comment-17738090
]
yuanfenghu commented on FLINK-23190:
[~loyi]
no, i just use
```
private Collectio
[ https://issues.apache.org/jira/browse/FLINK-23190 ]
yuanfenghu deleted comment on FLINK-23190:
was (Author: JIRAUSER296932):
[~loyi]
no, i just use
```
private Collection sortExecutionSlotSharingGroup(
Collection executionVertexGroups) {
M
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738092#comment-17738092
]
yuanfenghu commented on FLINK-23190:
[~loyi]
@Overridepublic List allocateSlotsFor(
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738094#comment-17738094
]
yuanfenghu commented on FLINK-23190:
{code:java}
//代码占位符
@Overridepublic List alloca
[ https://issues.apache.org/jira/browse/FLINK-23190 ]
yuanfenghu deleted comment on FLINK-23190:
was (Author: JIRAUSER296932):
{code:java}
//代码占位符
@Overridepublic List allocateSlotsFor(
List executionVertexIds){ // bla bla
Map> executionsByGrou
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738092#comment-17738092
]
yuanfenghu edited comment on FLINK-23190 at 6/28/23 12:21 PM:
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748386#comment-17748386
]
yuanfenghu commented on FLINK-31757:
Is there any progress on this topic? We are als
yuanfenghu created FLINK-30884:
--
Summary: GetTable from Flink catalog should be judged whether it
is a sink table
Key: FLINK-30884
URL: https://issues.apache.org/jira/browse/FLINK-30884
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-30884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-30884:
---
Priority: Major (was: Blocker)
> GetTable from Flink catalog should be judged whether it is a sink
[
https://issues.apache.org/jira/browse/FLINK-30884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683386#comment-17683386
]
yuanfenghu commented on FLINK-30884:
[~fsk119] [~godfrey]
> GetTable from Flink c
[
https://issues.apache.org/jira/browse/FLINK-30884?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17684088#comment-17684088
]
yuanfenghu commented on FLINK-30884:
In one case, we used an external catalog to man
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17736826#comment-17736826
]
yuanfenghu commented on FLINK-23190:
[~loyi] Thank you. In our scenario, there will
[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628708#comment-17628708
]
yuanfenghu commented on FLINK-29881:
The executestatment operation is asynchronous,
[
https://issues.apache.org/jira/browse/FLINK-20184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628834#comment-17628834
]
yuanfenghu commented on FLINK-20184:
hello, Leonard Xu
Our platform is recently int
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-29646:
---
Description:
sql gateway Should return simpler exception information
for example:
If i execute a s
yuanfenghu created FLINK-29646:
--
Summary: SQL Gateway should return a simpler error message
Key: FLINK-29646
URL: https://issues.apache.org/jira/browse/FLINK-29646
Project: Flink
Issue Type: Imp
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-29646:
---
Description:
sql gateway should return simpler exception information
for example:
If i execute a s
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-29646:
---
Description:
sql gateway Should return simpler exception information
for example:
If i execute a s
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-29646:
---
Priority: Critical (was: Minor)
> SQL Gateway should return a simpler error message
> -
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yuanfenghu updated FLINK-29646:
---
Priority: Major (was: Critical)
> SQL Gateway should return a simpler error message
> -
1 - 100 of 123 matches
Mail list logo
