[jira] [Updated] (FLINK-28751) Poor performance of the built in json_value function

2022-07-30 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-28751: --- Description: When I use the JSON_VALUE function, I found the performance is very poor. It's mainly

[jira] [Created] (FLINK-28751) Poor performance of the built in json_value function

2022-07-30 Thread Aitozi (Jira)
Aitozi created FLINK-28751: -- Summary: Poor performance of the built in json_value function Key: FLINK-28751 URL: https://issues.apache.org/jira/browse/FLINK-28751 Project: Flink Issue Type:

[jira] [Commented] (FLINK-27576) Flink will request new pod when jm pod is delete, but will remove when TaskExecutor exceeded the idle timeout

2022-07-25 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17571152#comment-17571152 ] Aitozi commented on FLINK-27576: Hi [~zhisheng], I think this problem have been fixed via

[jira] [Commented] (FLINK-28531) Shutdown cluster after history server archive finished

2022-07-13 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566188#comment-17566188 ] Aitozi commented on FLINK-28531: [~xtsong] Thanks for your information. It seems a duplicated issue :).

[jira] [Commented] (FLINK-28531) Shutdown cluster after history server archive finished

2022-07-12 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566124#comment-17566124 ] Aitozi commented on FLINK-28531: cc [~wangyang0918] [~xtsong] > Shutdown cluster after history server

[jira] [Commented] (FLINK-28531) Shutdown cluster after history server archive finished

2022-07-12 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566123#comment-17566123 ] Aitozi commented on FLINK-28531: I propose to fix this in two way: First, in the Dispatcher, we also

[jira] [Created] (FLINK-28531) Shutdown cluster after history server archive finished

2022-07-12 Thread Aitozi (Jira)
Aitozi created FLINK-28531: -- Summary: Shutdown cluster after history server archive finished Key: FLINK-28531 URL: https://issues.apache.org/jira/browse/FLINK-28531 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-28477) Support to scan the history server dir with max depth

2022-07-10 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-28477. -- Resolution: Won't Fix > Support to scan the history server dir with max depth >

[jira] [Commented] (FLINK-28477) Support to scan the history server dir with max depth

2022-07-10 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564777#comment-17564777 ] Aitozi commented on FLINK-28477: Got it, closed. > Support to scan the history server dir with max

[jira] [Updated] (FLINK-28478) Session Cluster will lost if it failed between status recorded and deploy

2022-07-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-28478: --- Description: When I test case with https://issues.apache.org/jira/browse/FLINK-28187 I hit that the

[jira] [Commented] (FLINK-28478) Session Cluster will lost if it failed between status recorded and deploy

2022-07-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564641#comment-17564641 ] Aitozi commented on FLINK-28478: cc [~gyfora] > Session Cluster will lost if it failed between status

[jira] [Updated] (FLINK-28478) Session Cluster will lost if it failed between status recorded and deploy

2022-07-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-28478: --- Description: When I test case with https://issues.apache.org/jira/browse/FLINK-28187 I hit that the

[jira] [Updated] (FLINK-28478) Session Cluster will lost if it failed between status recorded and deploy

2022-07-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-28478: --- Description: When I test case with https://issues.apache.org/jira/browse/FLINK-28187 I found that the

[jira] [Created] (FLINK-28478) Session Cluster will lost if it failed between status recorded and deploy

2022-07-09 Thread Aitozi (Jira)
Aitozi created FLINK-28478: -- Summary: Session Cluster will lost if it failed between status recorded and deploy Key: FLINK-28478 URL: https://issues.apache.org/jira/browse/FLINK-28478 Project: Flink

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-07-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564637#comment-17564637 ] Aitozi commented on FLINK-28187: [~gyfora] Thanks for your hint, I take a look on it > Duplicate job

[jira] [Updated] (FLINK-28477) Support to scan the history server dir with max depth

2022-07-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-28477: --- Description: In the {{HistoryServerArchiveFetcher}}, we only list the archives specified by the

[jira] [Updated] (FLINK-28477) Support to scan the history server dir with max depth

2022-07-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-28477: --- Description: In the {{HistoryServerArchiveFetcher}}, we only list the archives specified by the

[jira] [Commented] (FLINK-28477) Support to scan the history server dir with max depth

2022-07-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564636#comment-17564636 ] Aitozi commented on FLINK-28477: cc [~guoyangze] [~xtsong] > Support to scan the history server dir

[jira] [Updated] (FLINK-28477) Support to scan the history server dir with max depth

2022-07-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-28477: --- Issue Type: Improvement (was: Bug) > Support to scan the history server dir with max depth >

[jira] [Created] (FLINK-28477) Support to scan the history server dir with max depth

2022-07-09 Thread Aitozi (Jira)
Aitozi created FLINK-28477: -- Summary: Support to scan the history server dir with max depth Key: FLINK-28477 URL: https://issues.apache.org/jira/browse/FLINK-28477 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-27 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17559170#comment-17559170 ] Aitozi commented on FLINK-28187: FYI, I'm working on this now, please help assign the ticket [~gyfora]

[jira] [Commented] (FLINK-27979) Support to upgrade session cluster in a more fine grained way

2022-06-27 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27979?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17559169#comment-17559169 ] Aitozi commented on FLINK-27979: This issue is mean to support the upgrade session cluster in a more

[jira] [Commented] (FLINK-27921) Introduce the checkResourceRequirementsWithDelay in DeclarativeSlotManager

2022-06-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557982#comment-17557982 ] Aitozi commented on FLINK-27921: I think the reason behind here may be the affected benchmark will run

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557837#comment-17557837 ] Aitozi commented on FLINK-28187: OK, I will work on it in this way > Duplicate job submission for

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557828#comment-17557828 ] Aitozi commented on FLINK-28187: I think it over again the generation will make check whether the

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557824#comment-17557824 ] Aitozi commented on FLINK-28187: > For sessionjobs we need to cover both using the jobid magic somehow 

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557782#comment-17557782 ] Aitozi commented on FLINK-28187: [~gyfora] I add one comment here:

[jira] [Commented] (FLINK-28207) Disabling webhook should also disable mutator

2022-06-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557763#comment-17557763 ] Aitozi commented on FLINK-28207: The option is introduced to let user can choose to enable/disable the

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557518#comment-17557518 ] Aitozi commented on FLINK-28187: IMO, there is one and only one job for one FlinkSessionJob, so I think

[jira] [Comment Edited] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557513#comment-17557513 ] Aitozi edited comment on FLINK-28187 at 6/22/22 3:19 PM: - I'm afraid of not

[jira] [Comment Edited] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557513#comment-17557513 ] Aitozi edited comment on FLINK-28187 at 6/22/22 3:16 PM: - I'm afraid of not

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557513#comment-17557513 ] Aitozi commented on FLINK-28187: I'm afraid of not clearly expressing my meaning. I will try to give an

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557404#comment-17557404 ] Aitozi commented on FLINK-28187: I get your meaning now, but I think the case is a bit different from

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557387#comment-17557387 ] Aitozi commented on FLINK-28187: thanks, I will check it now > Duplicate job submission for

[jira] [Comment Edited] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557379#comment-17557379 ] Aitozi edited comment on FLINK-28187 at 6/22/22 11:26 AM: -- Currently, it

[jira] [Commented] (FLINK-28187) Duplicate job submission for FlinkSessionJob

2022-06-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557379#comment-17557379 ] Aitozi commented on FLINK-28187: Yes, I generate the JobId in advance to help duplicate the job

[jira] [Commented] (FLINK-27925) Avoid to create watcher without the resourceVersion

2022-06-13 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553414#comment-17553414 ] Aitozi commented on FLINK-27925: Get your meaning, I will try to test for it > Avoid to create watcher

[jira] [Commented] (FLINK-28008) Can not get secondary resource from context after operator restart

2022-06-13 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553408#comment-17553408 ] Aitozi commented on FLINK-28008: I think so, but I have not make sure > Can not get secondary resource

[jira] [Commented] (FLINK-28012) Add built-in support for fetching jar from GCS (Google Cloud Storage)

2022-06-13 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553407#comment-17553407 ] Aitozi commented on FLINK-28012: [~haoxin] there is a link to the flink filesystem now, you could refer

[jira] [Commented] (FLINK-27862) FLIP-235: Hybrid Shuffle Mode

2022-06-13 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553406#comment-17553406 ] Aitozi commented on FLINK-27862: Hi [~xtsong] , I have an offline discussion with [~Weijie Guo]. And I

[jira] [Commented] (FLINK-28012) Add built-in support for fetching jar from GCS (Google Cloud Storage)

2022-06-12 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553249#comment-17553249 ] Aitozi commented on FLINK-28012: I think the gcs should work with the filesystem based fetcher, have you

[jira] [Commented] (FLINK-28008) Can not get secondary resource from context after operator restart

2022-06-10 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553018#comment-17553018 ] Aitozi commented on FLINK-28008: I don't know if there any trick with the new sdk version. cc

[jira] [Commented] (FLINK-28008) Can not get secondary resource from context after operator restart

2022-06-10 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553014#comment-17553014 ] Aitozi commented on FLINK-28008: I test with the last release version with    {code:java} helm install

[jira] [Comment Edited] (FLINK-28008) Can not get secondary resource from context after operator restart

2022-06-10 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553014#comment-17553014 ] Aitozi edited comment on FLINK-28008 at 6/11/22 3:01 AM: - I test with the last

[jira] [Updated] (FLINK-28008) Can not get secondary resource from context after operator restart

2022-06-10 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-28008: --- Summary: Can not get secondary resource from context after operator restart (was: Can not get secondary

[jira] [Updated] (FLINK-28008) Can not get secondary resource from after operator restart

2022-06-10 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-28008: --- Description: how to reproduce: * create session and submit session job * delete session job * restart

[jira] [Created] (FLINK-28008) Can not get secondary resource from after operator restart

2022-06-10 Thread Aitozi (Jira)
Aitozi created FLINK-28008: -- Summary: Can not get secondary resource from after operator restart Key: FLINK-28008 URL: https://issues.apache.org/jira/browse/FLINK-28008 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-27925) Avoid to create watcher without the resourceVersion

2022-06-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552554#comment-17552554 ] Aitozi edited comment on FLINK-27925 at 6/10/22 5:14 AM: - I think it will only

[jira] [Commented] (FLINK-27925) Avoid to create watcher without the resourceVersion

2022-06-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552554#comment-17552554 ] Aitozi commented on FLINK-27925: Will it cache extra pods of other jobs if we specify the current job

[jira] [Created] (FLINK-27979) Support to upgrade session cluster in a more fine grained way

2022-06-09 Thread Aitozi (Jira)
Aitozi created FLINK-27979: -- Summary: Support to upgrade session cluster in a more fine grained way Key: FLINK-27979 URL: https://issues.apache.org/jira/browse/FLINK-27979 Project: Flink Issue

[jira] [Commented] (FLINK-27960) Make the apt-get updating optional

2022-06-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552253#comment-17552253 ] Aitozi commented on FLINK-27960: For convenient, I think we could include it in the main branch like the

[jira] [Commented] (FLINK-27273) Support both configMap and zookeeper based HA data clean up

2022-06-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552240#comment-17552240 ] Aitozi commented on FLINK-27273: I think it's a valid concern. But we could support other case first. I

[jira] [Comment Edited] (FLINK-27273) Support both configMap and zookeeper based HA data clean up

2022-06-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552240#comment-17552240 ] Aitozi edited comment on FLINK-27273 at 6/9/22 2:09 PM: I think it's a valid

[jira] [Commented] (FLINK-27960) Make the apt-get updating optional

2022-06-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552221#comment-17552221 ] Aitozi commented on FLINK-27960: Maybe it's due to the network limit > Make the apt-get updating

[jira] [Commented] (FLINK-27960) Make the apt-get updating optional

2022-06-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17552219#comment-17552219 ] Aitozi commented on FLINK-27960: >From my log it don't finish in 8min, I do not know the root cause. If

[jira] [Commented] (FLINK-26493) Use state machine based mechanism to simply the reconciler

2022-06-08 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551864#comment-17551864 ] Aitozi commented on FLINK-26493: [~gyfora] I have not invest time to start this work, but I still think

[jira] [Commented] (FLINK-27273) Support both configMap and zookeeper based HA data clean up

2022-06-08 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17551661#comment-17551661 ] Aitozi commented on FLINK-27273: What do you think of this cc [~gyfora] [~wangyang0918] > Support both

[jira] [Updated] (FLINK-26493) Use state machine based mechanism to simply the reconciler

2022-06-08 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26493: --- Component/s: Kubernetes Operator > Use state machine based mechanism to simply the reconciler >

[jira] [Created] (FLINK-27961) The EventUtils generate event name should take the resource's uid into account

2022-06-08 Thread Aitozi (Jira)
Aitozi created FLINK-27961: -- Summary: The EventUtils generate event name should take the resource's uid into account Key: FLINK-27961 URL: https://issues.apache.org/jira/browse/FLINK-27961 Project: Flink

[jira] [Updated] (FLINK-27960) Make the apt-get updating optional

2022-06-08 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27960: --- Attachment: screenshot-1.png > Make the apt-get updating optional > --- >

[jira] [Updated] (FLINK-27960) Make the apt-get updating optional

2022-06-08 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27960: --- Attachment: (was: image-2022-06-08-22-06-44-586.png) > Make the apt-get updating optional >

[jira] [Updated] (FLINK-27960) Make the apt-get updating optional

2022-06-08 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27960: --- Description: I notice that it cost much time to do the apt-get updating, it's not necessary during

[jira] [Updated] (FLINK-27960) Make the apt-get updating optional

2022-06-08 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27960: --- Description: I notice that it cost much time to do the apt-get updating, it's not necessary during

[jira] [Updated] (FLINK-27960) Make the apt-get updating optional

2022-06-08 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27960: --- Attachment: image-2022-06-08-22-06-44-586.png > Make the apt-get updating optional >

[jira] [Created] (FLINK-27960) Make the apt-get updating optional

2022-06-08 Thread Aitozi (Jira)
Aitozi created FLINK-27960: -- Summary: Make the apt-get updating optional Key: FLINK-27960 URL: https://issues.apache.org/jira/browse/FLINK-27960 Project: Flink Issue Type: Improvement

[jira] [Closed] (FLINK-27930) Format the timestamp in status to make it readable

2022-06-07 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-27930. -- Resolution: Won't Fix > Format the timestamp in status to make it readable >

[jira] [Commented] (FLINK-27930) Format the timestamp in status to make it readable

2022-06-07 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550872#comment-17550872 ] Aitozi commented on FLINK-27930: Get it > Format the timestamp in status to make it readable >

[jira] [Comment Edited] (FLINK-27930) Format the timestamp in status to make it readable

2022-06-07 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550844#comment-17550844 ] Aitozi edited comment on FLINK-27930 at 6/7/22 7:24 AM: It's in string type now,

[jira] [Commented] (FLINK-27930) Format the timestamp in status to make it readable

2022-06-07 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550844#comment-17550844 ] Aitozi commented on FLINK-27930: It's in string type now, but store the unix timestamp value. Will this

[jira] [Updated] (FLINK-27930) Format the timestamp in status to make it readable

2022-06-07 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27930: --- Description: Currently, the timestamp in status show the unix timestamp, I think we could improve it to an

[jira] [Updated] (FLINK-27930) Format the timestamp in status to make it readable

2022-06-07 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27930: --- Summary: Format the timestamp in status to make it readable (was: Format the timestamp in status to make

[jira] [Updated] (FLINK-27930) Format the timestamp in status to make it explicit

2022-06-07 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27930: --- Description: Currently, the timestamp in status show the unix timestamp, I think we could improve it to a

[jira] [Created] (FLINK-27930) Format the timestamp in status to make it explicit

2022-06-07 Thread Aitozi (Jira)
Aitozi created FLINK-27930: -- Summary: Format the timestamp in status to make it explicit Key: FLINK-27930 URL: https://issues.apache.org/jira/browse/FLINK-27930 Project: Flink Issue Type:

[jira] [Commented] (FLINK-27862) FLIP-235: Hybrid Shuffle Mode

2022-06-07 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550832#comment-17550832 ] Aitozi commented on FLINK-27862: Thanks [~Weijie Guo] , [~xtsong] for your kindness guide, I will take a

[jira] [Commented] (FLINK-27497) Track terminal job states in the observer

2022-06-06 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550799#comment-17550799 ] Aitozi commented on FLINK-27497: continue this work now > Track terminal job states in the observer >

[jira] [Updated] (FLINK-27921) Introduce the checkResourceRequirementsWithDelay in DeclarativeSlotManager

2022-06-06 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27921: --- Description: As discussed in [https://github.com/apache/flink/pull/19840#discussion_r884242067] .This

[jira] [Commented] (FLINK-27925) Avoid to create watcher without the resourceVersion

2022-06-06 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550749#comment-17550749 ] Aitozi commented on FLINK-27925: cc [~wangyang0918]  > Avoid to create watcher without the

[jira] [Updated] (FLINK-27925) Avoid to create watcher without the resourceVersion

2022-06-06 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27925: --- Description: Currently, we create the watcher in KubernetesResourceManager. But it do not pass the

[jira] [Created] (FLINK-27925) Avoid to create watcher without the resourceVersion

2022-06-06 Thread Aitozi (Jira)
Aitozi created FLINK-27925: -- Summary: Avoid to create watcher without the resourceVersion Key: FLINK-27925 URL: https://issues.apache.org/jira/browse/FLINK-27925 Project: Flink Issue Type:

[jira] [Commented] (FLINK-27868) Harden running job check before triggering savepoints or savepoint upgrades

2022-06-06 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550716#comment-17550716 ] Aitozi commented on FLINK-27868: I think it will be a good improvement to savepoint with the work of

[jira] [Commented] (FLINK-27862) FLIP-235: Hybrid Shuffle Mode

2022-06-06 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550507#comment-17550507 ] Aitozi commented on FLINK-27862: Hi [~Weijie Guo] Thanks for starting this work. I'm interested in this

[jira] [Created] (FLINK-27921) Introduce the checkResourceRequirementsWithDelay in DeclarativeSlotManager

2022-06-06 Thread Aitozi (Jira)
Aitozi created FLINK-27921: -- Summary: Introduce the checkResourceRequirementsWithDelay in DeclarativeSlotManager Key: FLINK-27921 URL: https://issues.apache.org/jira/browse/FLINK-27921 Project: Flink

[jira] [Commented] (FLINK-27821) Cannot delete flinkdeployment when the pod and deployment deleted manually

2022-05-27 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17542961#comment-17542961 ] Aitozi commented on FLINK-27821: [~Miuler] The deletion of the session cluster's flinkdeployment object

[jira] [Commented] (FLINK-27737) Remove legacy support for unfenced executor in FencedRpcEndpoint

2022-05-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540781#comment-17540781 ] Aitozi commented on FLINK-27737: Yes, I'd like to work on this. > Remove legacy support for unfenced

[jira] [Created] (FLINK-27737) Clean the outdated comments and unfencedMainExecutor

2022-05-22 Thread Aitozi (Jira)
Aitozi created FLINK-27737: -- Summary: Clean the outdated comments and unfencedMainExecutor Key: FLINK-27737 URL: https://issues.apache.org/jira/browse/FLINK-27737 Project: Flink Issue Type:

[jira] [Commented] (FLINK-27576) Flink will request new pod when jm pod is delete, but will remove when TaskExecutor exceeded the idle timeout

2022-05-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17540608#comment-17540608 ] Aitozi commented on FLINK-27576: Hi [~zhisheng] I have opened a PR for this, please let me know if you

[jira] [Commented] (FLINK-27666) Cover manual savepoint triggering in E2E tests

2022-05-17 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17538567#comment-17538567 ] Aitozi commented on FLINK-27666: I could work on this.  please assign this to me, I will try to push a

[jira] [Commented] (FLINK-27576) Flink will request new pod when jm pod is delete, but will remove when TaskExecutor exceeded the idle timeout

2022-05-16 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537871#comment-17537871 ] Aitozi commented on FLINK-27576: I have not started, I will prepare the PR this week. > Flink will

[jira] [Commented] (FLINK-27497) Track terminal job states in the observer

2022-05-15 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537304#comment-17537304 ] Aitozi commented on FLINK-27497: [~gyfora] Thanks for your remind. Besides I have question when I test

[jira] [Commented] (FLINK-27613) Add label for the session job to help list the session jobs in the same session cluster

2022-05-15 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27613?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537177#comment-17537177 ] Aitozi commented on FLINK-27613: Yes, especially when we have to do operation on all the jobs of a

[jira] [Commented] (FLINK-27497) Track terminal job states in the observer

2022-05-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537140#comment-17537140 ] Aitozi commented on FLINK-27497: working on this now > Track terminal job states in the observer >

[jira] [Commented] (FLINK-17232) Rethink the implicit behavior to use the Service externalIP as the address of the Endpoint

2022-05-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537136#comment-17537136 ] Aitozi commented on FLINK-17232: I have pushed a PR to remove the implicit behavior to fallback to

[jira] [Comment Edited] (FLINK-27615) Document the minimum supported version of k8s for flink k8s operator

2022-05-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537011#comment-17537011 ] Aitozi edited comment on FLINK-27615 at 5/14/22 10:12 AM: -- what about

[jira] [Commented] (FLINK-27615) Document the minimum supported version of k8s for flink k8s operator

2022-05-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537011#comment-17537011 ] Aitozi commented on FLINK-27615: what about supporting user to define their own namespace selector

[jira] [Updated] (FLINK-27613) Add label for the session job to help list the session jobs in the same session cluster

2022-05-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27613: --- Description: The custorm resource do not supported list by field selector, So I think add a label to get

[jira] [Created] (FLINK-27614) Use informer in webhook to avoid query apiserver at each update

2022-05-14 Thread Aitozi (Jira)
Aitozi created FLINK-27614: -- Summary: Use informer in webhook to avoid query apiserver at each update Key: FLINK-27614 URL: https://issues.apache.org/jira/browse/FLINK-27614 Project: Flink Issue

[jira] [Commented] (FLINK-26784) FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator

2022-05-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536992#comment-17536992 ] Aitozi commented on FLINK-26784: The {{{}FlinkSessionJob{}}}'s functionality are basically completed.

[jira] [Comment Edited] (FLINK-26784) FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator

2022-05-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26784?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17536992#comment-17536992 ] Aitozi edited comment on FLINK-26784 at 5/14/22 8:21 AM: - The

[jira] [Created] (FLINK-27613) Add label for the session job to help list the session jobs in the same session cluster

2022-05-14 Thread Aitozi (Jira)
Aitozi created FLINK-27613: -- Summary: Add label for the session job to help list the session jobs in the same session cluster Key: FLINK-27613 URL: https://issues.apache.org/jira/browse/FLINK-27613 Project:

[jira] [Updated] (FLINK-27612) Generate waring events when deleting the session cluster

2022-05-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27612: --- Parent: FLINK-26784 Issue Type: Sub-task (was: Improvement) > Generate waring events when deleting

<    1   2   3   4   5   6   7   8   9   >