[
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`
[
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
[
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
[
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:
---
Affects Version/s: 1.16.2
(was: 1.17.1)
> FlinkSql unable to parse
[
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:
---
Description:
如果使用flinksql建表，
{code:java}
CREATE TABLE
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
[
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`
[
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`
[
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`
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769033#comment-17769033
]
yuanfenghu commented on FLINK-25373:
我也遇到了同样的问题
> task manager can not free memory when jobs are
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769033#comment-17769033
]
yuanfenghu edited comment on FLINK-25373 at 9/26/23 6:58 AM:
-
I also
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769033#comment-17769033
]
yuanfenghu edited comment on FLINK-25373 at 9/26/23 8:56 AM:
-
I also
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769033#comment-17769033
]
yuanfenghu edited comment on FLINK-25373 at 9/26/23 7:04 AM:
-
I also
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769033#comment-17769033
]
yuanfenghu edited comment on FLINK-25373 at 9/26/23 7:01 AM:
-
I also
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769033#comment-17769033
]
yuanfenghu edited comment on FLINK-25373 at 9/26/23 7:01 AM:
-
I also
[
https://issues.apache.org/jira/browse/FLINK-25373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17769033#comment-17769033
]
yuanfenghu edited comment on FLINK-25373 at 9/26/23 7:48 AM:
-
I also
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618367#comment-17618367
]
yuanfenghu commented on FLINK-29646:
There is no problem in reporting a complete exception. The
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618395#comment-17618395
]
yuanfenghu commented on FLINK-29646:
I would like to explain the scenario where we use the gateway.
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618382#comment-17618382
]
yuanfenghu commented on FLINK-29646:
Maybe you can add a parameter to the client, whether you need
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618413#comment-17618413
]
yuanfenghu commented on FLINK-29646:
Thank [~xtsong] . It is really not the best way to use root
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618413#comment-17618413
]
yuanfenghu edited comment on FLINK-29646 at 10/17/22 4:46 AM:
--
Thank
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618413#comment-17618413
]
yuanfenghu edited comment on FLINK-29646 at 10/17/22 4:46 AM:
--
Thank
[
https://issues.apache.org/jira/browse/FLINK-29646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17618773#comment-17618773
]
yuanfenghu commented on FLINK-29646:
I think this is a good solution
> SQL Gateway should return
[
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
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:
[
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
[
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
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-29881?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628708#comment-17628708
]
yuanfenghu commented on FLINK-29881:
The executestatment operation is asynchronous, you have to get
[
https://issues.apache.org/jira/browse/FLINK-20184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17628834#comment-17628834
]
yuanfenghu commented on FLINK-20184:
hello, Leonard Xu
Our platform is recently integrating with
[
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=17683386#comment-17683386
]
yuanfenghu commented on FLINK-30884:
[~fsk119] [~godfrey]
> GetTable from Flink catalog should be
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:comment-tabpanel=17684088#comment-17684088
]
yuanfenghu commented on FLINK-30884:
In one case, we used an external catalog to manage my kafka
[
https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17748386#comment-17748386
]
yuanfenghu commented on FLINK-31757:
Is there any progress on this topic? We are also facing this
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17736826#comment-17736826
]
yuanfenghu commented on FLINK-23190:
[~loyi] Thank you. In our scenario, there will also be
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738089#comment-17738089
]
yuanfenghu commented on FLINK-23190:
[~loyi]
no, i just use
```
private Collection
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738089#comment-17738089
]
yuanfenghu edited comment on FLINK-23190 at 6/28/23 12:15 PM:
--
[~loyi]
[ 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 ]
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=17738090#comment-17738090
]
yuanfenghu commented on FLINK-23190:
[~loyi]
no, i just use
```
private Collection
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738092#comment-17738092
]
yuanfenghu edited comment on FLINK-23190 at 6/28/23 12:21 PM:
--
[~loyi]
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738092#comment-17738092
]
yuanfenghu commented on FLINK-23190:
[~loyi]
@Overridepublic List allocateSlotsFor(
List
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17738094#comment-17738094
]
yuanfenghu commented on FLINK-23190:
{code:java}
//代码占位符
@Overridepublic List allocateSlotsFor(
List
[ 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>
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17737632#comment-17737632
]
yuanfenghu commented on FLINK-23190:
[~loyi] I think there are other issues to consider
# Flink
[ 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=17737623#comment-17737623
]
yuanfenghu commented on FLINK-23190:
[~loyi] 我认为有些缺陷，我之前也做过类似的工作，比如
> Make task-slot allocation
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17737625#comment-17737625
]
yuanfenghu commented on FLINK-23190:
loyi
I think there are still some problems, my test
[
https://issues.apache.org/jira/browse/FLINK-23190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17737625#comment-17737625
]
yuanfenghu edited comment on FLINK-23190 at 6/27/23 12:32 PM:
--
[~loyi]
I
[
https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822472#comment-17822472
]
yuanfenghu commented on FLINK-34535:
Hi [~jeyhunkarimov]
谢谢你的评论，其实我的想法很简单，我希望在使用 flink sql 时,
[
https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822399#comment-17822399
]
yuanfenghu commented on FLINK-34535:
[~lincoln.86xy]
Thank you for your comment,
> Regarding to
[
https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17822472#comment-17822472
]
yuanfenghu edited comment on FLINK-34535 at 3/1/24 9:45 AM:
Hi
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:
[
https://issues.apache.org/jira/browse/FLINK-34535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821481#comment-17821481
]
yuanfenghu commented on FLINK-34535:
cc [~luoyuxia]
> Support JobPlanInfo for the explain result
>
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:
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835106#comment-17835106
]
yuanfenghu commented on FLINK-35035:
[~bgeng777]
Thank you for your comment. As you understand, I
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835106#comment-17835106
]
yuanfenghu edited comment on FLINK-35035 at 4/9/24 2:22 AM:
[~bgeng777]
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835564#comment-17835564
]
yuanfenghu edited comment on FLINK-35035 at 4/10/24 2:08 AM:
-
[~echauchot]
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835564#comment-17835564
]
yuanfenghu commented on FLINK-35035:
[~echauchot]
Thank you for your reply, but I have some
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835564#comment-17835564
]
yuanfenghu edited comment on FLINK-35035 at 4/10/24 2:19 AM:
-
[~echauchot]
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836395#comment-17836395
]
yuanfenghu commented on FLINK-35035:
[~echauchot]
Thank you for your reply.
You should look at
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836395#comment-17836395
]
yuanfenghu edited comment on FLINK-35035 at 4/12/24 6:08 AM:
-
[~echauchot]
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836504#comment-17836504
]
yuanfenghu commented on FLINK-35035:
[~echauchot]
Thank you for your patience in tracking this
[
https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17836508#comment-17836508
]
yuanfenghu commented on FLINK-35035:
> It is not slot per slot rescale, there will be only one
70 matches
Mail list logo
