[jira] [Updated] (FLINK-25335) Improvement of task deployment by enable source split asynchronous enumerate

2021-12-27 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Affects Version/s: 1.14.2 > Improvement of task deployment by enable source split asynchronous

[jira] [Updated] (FLINK-25335) Improvement of task deployment by enable source split asynchronous enumerate

2021-12-27 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Component/s: Connectors / Hive > Improvement of task deployment by enable source split asynchronous

[jira] [Updated] (FLINK-25015) job name should not always be `collect` submitted by sql client

2021-11-23 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25015: --- Description: I use flink sql client to submitted different sql query to flink session cluster, 

[jira] [Updated] (FLINK-25015) job name should not always be `collect` submitted by sql client

2021-11-23 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25015: --- Attachment: image-2021-11-23-20-16-21-932.png > job name should not always be `collect` submitted

[jira] [Created] (FLINK-25015) job name should not always be `collect` submitted by sql client

2021-11-23 Thread KevinyhZou (Jira)
KevinyhZou created FLINK-25015: -- Summary: job name should not always be `collect` submitted by sql client Key: FLINK-25015 URL: https://issues.apache.org/jira/browse/FLINK-25015 Project: Flink

[jira] [Commented] (FLINK-25015) job name should not always be `collect` submitted by sql client

2021-11-23 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448370#comment-17448370 ] KevinyhZou commented on FLINK-25015: [~jark] I agree with you. can you assign this issue to me, and

[jira] [Commented] (FLINK-25015) job name should not always be `collect` submitted by sql client

2021-11-26 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17449490#comment-17449490 ] KevinyhZou commented on FLINK-25015: [~jark] I have made a pr, please help review it , thanks. >

[jira] [Updated] (FLINK-25136) the parallelism not appear right when rescale by use scheduler in reactive mode

2021-12-01 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25136: --- Description: As describe in document

[jira] [Updated] (FLINK-25136) the parallelism not appear right when rescale by use scheduler in reactive mode

2021-12-01 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25136: --- Attachment: image-2021-12-01-21-06-03-754.png > the parallelism not appear right when rescale by

[jira] [Created] (FLINK-25136) the parallelism not appear right when rescale by use scheduler in reactive mode

2021-12-01 Thread KevinyhZou (Jira)
KevinyhZou created FLINK-25136: -- Summary: the parallelism not appear right when rescale by use scheduler in reactive mode Key: FLINK-25136 URL: https://issues.apache.org/jira/browse/FLINK-25136 Project:

[jira] [Updated] (FLINK-25136) the parallelism not appear right when rescale by use scheduler in reactive mode

2021-12-01 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25136: --- Description: As describe in document

[jira] [Updated] (FLINK-25335) Improvement of task deployment by enable source split async enumerate

2021-12-15 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Summary: Improvement of task deployment by enable source split async enumerate (was: Improvoment

[jira] [Updated] (FLINK-25335) Improvoment of task deployment by enable source split async enumerate

2021-12-15 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Attachment: image-2021-12-16-11-14-36-030.png > Improvoment of task deployment by enable source

[jira] [Updated] (FLINK-25335) Improvoment of task deployment by enable source split async enumerate

2021-12-15 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Description: When submit olap query by flink client to Flink Session Cluster, the JobMaster will

[jira] [Updated] (FLINK-25335) Improvement of task deployment by enable source split asynchronous enumerate

2021-12-15 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Summary: Improvement of task deployment by enable source split asynchronous enumerate (was:

[jira] [Updated] (FLINK-25335) Improvement of task deployment by enable source split Asynchronous enumerate

2021-12-15 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Summary: Improvement of task deployment by enable source split Asynchronous enumerate (was:

[jira] [Updated] (FLINK-25335) Improvoment of task deployment by enable source split async enumerate

2021-12-15 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-25335: --- Description: When submit olap query by flink client to Flink Session Cluster, the JobMaster will

[jira] [Created] (FLINK-25335) Improvoment of task deployment by enable source split async enumerate

2021-12-15 Thread KevinyhZou (Jira)
KevinyhZou created FLINK-25335: -- Summary: Improvoment of task deployment by enable source split async enumerate Key: FLINK-25335 URL: https://issues.apache.org/jira/browse/FLINK-25335 Project: Flink

[jira] [Created] (FLINK-28604) job failover and not restore from checkpoint in zookeeper HA mode

2022-07-19 Thread KevinyhZou (Jira)
KevinyhZou created FLINK-28604: -- Summary: job failover and not restore from checkpoint in zookeeper HA mode Key: FLINK-28604 URL: https://issues.apache.org/jira/browse/FLINK-28604 Project: Flink

[jira] [Updated] (FLINK-28604) job failover and not restore from checkpoint in zookeeper HA mode

2022-07-19 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou updated FLINK-28604: --- Description: Run a job with flink 1.14.2 by configure the zookeeper ha  {code:java}

[jira] [Closed] (FLINK-28604) job failover and not restore from checkpoint in zookeeper HA mode

2022-07-19 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] KevinyhZou closed FLINK-28604. -- Fix Version/s: 1.14.5 Resolution: Fixed > job failover and not restore from checkpoint in

[jira] [Commented] (FLINK-28604) job failover and not restore from checkpoint in zookeeper HA mode

2022-07-19 Thread KevinyhZou (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17568453#comment-17568453 ] KevinyhZou commented on FLINK-28604: [~martijnvisser] this problem not exist in flink 1.14.5, it