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

2022-03-04 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501381#comment-17501381 ] Aitozi commented on FLINK-26493: I will try to define a initial state machine transfer flow we

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

2022-03-04 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501379#comment-17501379 ] Aitozi edited comment on FLINK-26493 at 3/4/22, 3:22 PM: - Do you have some

[jira] [Updated] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-07 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26528: --- Description: If the CR has not changed since last reconcile, we could create a UpdateControl

[jira] [Created] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-07 Thread Aitozi (Jira)
Aitozi created FLINK-26528: -- Summary: Trigger the updateControl when the FlinkDeployment have changed Key: FLINK-26528 URL: https://issues.apache.org/jira/browse/FLINK-26528 Project: Flink Issue

[jira] [Commented] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-08 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503027#comment-17503027 ] Aitozi commented on FLINK-26528: I proposal to provide a {{ReconcileResult}} which will generate

[jira] [Commented] (FLINK-26538) Ability to restart deployment w/o spec change

2022-03-13 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505983#comment-17505983 ] Aitozi commented on FLINK-26538: [~thw] Are you planning to work on this, If not, Maybe I can do you

[jira] [Commented] (FLINK-26647) Can not add extra config files on native Kubernetes

2022-03-15 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507022#comment-17507022 ] Aitozi commented on FLINK-26647: It looks like the way 2 can meet your requirements, may be it caused

[jira] [Commented] (FLINK-26647) Can not add extra config files on native Kubernetes

2022-03-15 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17507026#comment-17507026 ] Aitozi commented on FLINK-26647: I think we may could provide the tool to ship the client config files

[jira] [Commented] (FLINK-26538) Ability to restart deployment w/o spec change

2022-03-08 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503228#comment-17503228 ] Aitozi commented on FLINK-26538: Can this achieved by setting JobState to {{SUSPENDED}} and then set

[jira] [Commented] (FLINK-26546) Extract Observer Interface

2022-03-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503535#comment-17503535 ] Aitozi commented on FLINK-26546: Get it. > Extract Observer Interf

[jira] [Commented] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503534#comment-17503534 ] Aitozi commented on FLINK-26528: Yes, I can take this work, I have done some poc code locally, I

[jira] [Commented] (FLINK-26719) Rethink the default reschedule reconcile loop

2022-03-18 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508597#comment-17508597 ] Aitozi commented on FLINK-26719: cc [~wangyang0918] [~gyfora]  > Rethink the default resched

[jira] [Commented] (FLINK-26719) Rethink the default reschedule reconcile loop

2022-03-18 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508658#comment-17508658 ] Aitozi commented on FLINK-26719: [~matyas] Thanks for your inputs, It seems we have done the same thing

[jira] [Comment Edited] (FLINK-26719) Rethink the default reschedule reconcile loop

2022-03-18 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508658#comment-17508658 ] Aitozi edited comment on FLINK-26719 at 3/18/22, 8:55 AM: -- [~matyas] Thanks

[jira] [Created] (FLINK-26719) Rethink the default reschedule reconcile loop

2022-03-18 Thread Aitozi (Jira)
Aitozi created FLINK-26719: -- Summary: Rethink the default reschedule reconcile loop Key: FLINK-26719 URL: https://issues.apache.org/jira/browse/FLINK-26719 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-26538) Ability to restart deployment w/o spec change

2022-03-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503428#comment-17503428 ] Aitozi commented on FLINK-26538: For the convenient purpose, I'm +1 for this.  It looks like

[jira] [Commented] (FLINK-26546) Extract Observer Interface

2022-03-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503438#comment-17503438 ] Aitozi commented on FLINK-26546: +1. I'm willing to take the work > Extract Observer Interf

[jira] [Commented] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503409#comment-17503409 ] Aitozi commented on FLINK-26528: It's not the same question, this ticket is want to solve that we should

[jira] [Comment Edited] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503631#comment-17503631 ] Aitozi edited comment on FLINK-26528 at 3/9/22, 3:07 PM: - Yes, my meaning

[jira] [Commented] (FLINK-26528) Trigger the updateControl when the FlinkDeployment have changed

2022-03-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17503631#comment-17503631 ] Aitozi commented on FLINK-26528: Yes, my meaning is to eliminate the unchanged update to toward

[jira] [Commented] (FLINK-26136) Implement shared validation logic for FlinkDeployment objects

2022-02-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497202#comment-17497202 ] Aitozi commented on FLINK-26136: Got it, thanks. > Implement shared validation lo

[jira] [Closed] (FLINK-26339) Introduce the webhook config to free the environment options

2022-02-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-26339. -- Resolution: Not A Problem > Introduce the webhook config to free the environment opti

[jira] [Commented] (FLINK-26339) Introduce the webhook config to free the environment options

2022-02-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497158#comment-17497158 ] Aitozi commented on FLINK-26339: I mixed it up, there is no need to do this now, sorry for bother

[jira] [Commented] (FLINK-26136) Implement shared validation logic for FlinkDeployment objects

2022-02-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497184#comment-17497184 ] Aitozi commented on FLINK-26136: Hi [~gyfora], I have a doubt for this issue. I think the webhook

[jira] [Created] (FLINK-26356) Revisit the create of RestClusterClient

2022-02-24 Thread Aitozi (Jira)
Aitozi created FLINK-26356: -- Summary: Revisit the create of RestClusterClient Key: FLINK-26356 URL: https://issues.apache.org/jira/browse/FLINK-26356 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-26356) Revisit the create of RestClusterClient

2022-02-24 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497848#comment-17497848 ] Aitozi commented on FLINK-26356: I have not make it very clear yet, I will do more investigation first

[jira] [Updated] (FLINK-26356) Revisit the create of RestClusterClient

2022-02-24 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26356: --- Description: The clusterClient is built as below. The config is mixed up with the FlinkDeploymentSpec

[jira] [Created] (FLINK-26399) Make some option of operator configurable

2022-02-28 Thread Aitozi (Jira)
Aitozi created FLINK-26399: -- Summary: Make some option of operator configurable Key: FLINK-26399 URL: https://issues.apache.org/jira/browse/FLINK-26399 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-26377) Extract Reconciler interface

2022-02-25 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498393#comment-17498393 ] Aitozi commented on FLINK-26377: I have the same sense to extract common reconciler interface. We can

[jira] [Commented] (FLINK-26356) Revisit the create of RestClusterClient

2022-02-25 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498402#comment-17498402 ] Aitozi commented on FLINK-26356: I have some misunderstand before, since the operator will always

[jira] [Comment Edited] (FLINK-26377) Extract Reconciler interface

2022-02-25 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498393#comment-17498393 ] Aitozi edited comment on FLINK-26377 at 2/26/22, 7:01 AM: -- I have the same

[jira] [Comment Edited] (FLINK-26377) Extract Reconciler interface

2022-02-25 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498393#comment-17498393 ] Aitozi edited comment on FLINK-26377 at 2/26/22, 7:01 AM: -- I have the same

[jira] [Commented] (FLINK-26377) Extract Reconciler interface

2022-02-25 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498408#comment-17498408 ] Aitozi commented on FLINK-26377: Get it ! > Extract Reconciler interf

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

2022-02-21 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495844#comment-17495844 ] Aitozi commented on FLINK-17232: [~wangyang0918] Could you help review [PR|https://github.com/apache

[jira] [Created] (FLINK-26332) Move the Operator Env to the common Utils

2022-02-23 Thread Aitozi (Jira)
Aitozi created FLINK-26332: -- Summary: Move the Operator Env to the common Utils Key: FLINK-26332 URL: https://issues.apache.org/jira/browse/FLINK-26332 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-26332) Move the Operator Env to the common Utils

2022-02-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496680#comment-17496680 ] Aitozi commented on FLINK-26332: I want to work on this :D > Move the Operator Env to the common Ut

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

2022-02-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496678#comment-17496678 ] Aitozi commented on FLINK-17232: Get it, thanks  > Rethink the implicit behavior to use the Serv

[jira] [Created] (FLINK-26337) Avoid load flink conf each reconcile loop

2022-02-23 Thread Aitozi (Jira)
Aitozi created FLINK-26337: -- Summary: Avoid load flink conf each reconcile loop Key: FLINK-26337 URL: https://issues.apache.org/jira/browse/FLINK-26337 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-26337) Avoid load flink conf each reconcile loop

2022-02-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496791#comment-17496791 ] Aitozi commented on FLINK-26337: cc [~gyfora]  [~wangyang0918]  > Avoid load flink conf each reconc

[jira] [Updated] (FLINK-26332) Move the Operator Env to the common Utils

2022-02-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26332: --- Parent: FLINK-25963 Issue Type: Sub-task (was: Improvement) > Move the Operator Env to the com

[jira] [Created] (FLINK-26339) Introduce the webhook config to free the environment options

2022-02-23 Thread Aitozi (Jira)
Aitozi created FLINK-26339: -- Summary: Introduce the webhook config to free the environment options Key: FLINK-26339 URL: https://issues.apache.org/jira/browse/FLINK-26339 Project: Flink Issue Type

[jira] [Commented] (FLINK-26339) Introduce the webhook config to free the environment options

2022-02-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496827#comment-17496827 ] Aitozi commented on FLINK-26339: cc [~gyfora]  [~wangyang0918], I can work on this ticket

[jira] [Commented] (FLINK-26337) Avoid load flink conf each reconcile loop

2022-02-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17496813#comment-17496813 ] Aitozi commented on FLINK-26337: Yes, I can take this ticket.  > Avoid load flink conf each reconc

[jira] [Updated] (FLINK-26337) Avoid load flink conf each reconcile loop

2022-02-23 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26337: --- Component/s: Kubernetes Operator > Avoid load flink conf each reconcile l

[jira] [Created] (FLINK-26435) Provide the container name for CI debug log

2022-03-01 Thread Aitozi (Jira)
Aitozi created FLINK-26435: -- Summary: Provide the container name for CI debug log Key: FLINK-26435 URL: https://issues.apache.org/jira/browse/FLINK-26435 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-26435) Provide the container name for CI debug log

2022-03-01 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26435: --- Description: Current kubectl log for the CI have not specified the container name as below   {code:java

[jira] [Commented] (FLINK-26435) Provide the container name for CI debug log

2022-03-02 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500052#comment-17500052 ] Aitozi commented on FLINK-26435: Hmm.. It's come from the {{flink-kubernetes-operator}} project's ci

[jira] [Commented] (FLINK-26435) Provide the container name for CI debug log

2022-03-02 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17500086#comment-17500086 ] Aitozi commented on FLINK-26435: Get it, Done.  > Provide the container name for CI debug

[jira] [Updated] (FLINK-26435) Provide the container name for CI debug log

2022-03-02 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26435: --- Parent: (was: FLINK-25963) Issue Type: Bug (was: Sub-task) > Provide the container name for

[jira] [Commented] (FLINK-26377) Extract Reconciler interface

2022-03-04 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17501360#comment-17501360 ] Aitozi commented on FLINK-26377: [~gyfora] I have finished it, and just submit the pull request, please

[jira] [Updated] (FLINK-26112) Port getEndpoint method to the specific service type subclass

2022-02-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26112: --- Description: In the [FLINK-20830|https://issues.apache.org/jira/projects/FLINK/issues/FLINK-20830]we

[jira] [Updated] (FLINK-26112) Port getEndpoint method to the specific service type subclass

2022-02-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26112: --- Parent: FLINK-17196 Issue Type: Sub-task (was: Improvement) > Port getEndpoint met

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

2022-02-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491971#comment-17491971 ] Aitozi commented on FLINK-17232: Hi, when i do some work to refactor the code

[jira] [Commented] (FLINK-26112) Port getEndpoint method to the specific service type subclass

2022-02-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17491973#comment-17491973 ] Aitozi commented on FLINK-26112: I found it's also an improvement of the implementation

[jira] [Created] (FLINK-26112) Port getEndpoint method to the specific service type subclass

2022-02-13 Thread Aitozi (Jira)
Aitozi created FLINK-26112: -- Summary: Port getEndpoint method to the specific service type subclass Key: FLINK-26112 URL: https://issues.apache.org/jira/browse/FLINK-26112 Project: Flink Issue

[jira] [Updated] (FLINK-26112) Port getEndpoint method to the specific service type subclass

2022-02-13 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26112: --- Description: In the [FLINK-20830 |https://issues.apache.org/jira/projects/FLINK/issues/FLINK-20830]we

[jira] [Updated] (FLINK-26112) Port getEndpoint method to the specific service type subclass

2022-02-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26112: --- Description: In the [FLINK-20830|https://issues.apache.org/jira/browse/FLINK-20830]we introduce serval

[jira] [Updated] (FLINK-26112) Port getEndpoint method to the specific service type subclass

2022-02-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26112: --- Description: In the [FLINK-20830|https://issues.apache.org/jira/browse/FLINK-20830], we introduce serval

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

2022-02-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492049#comment-17492049 ] Aitozi commented on FLINK-17232: After some dig for the [external IPs|https://kubernetes.io/docs

[jira] [Commented] (FLINK-16601) Correct the way to get Endpoint address for NodePort rest Service

2022-02-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16601?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492038#comment-17492038 ] Aitozi commented on FLINK-16601: Hi [~felixzheng], I think this issue have already been solved

[jira] [Updated] (FLINK-26112) Port getRestEndpoint method to the specific service type subclass

2022-02-14 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26112: --- Summary: Port getRestEndpoint method to the specific service type subclass (was: Port getEndpoint method

[jira] [Comment Edited] (FLINK-26377) Extract Reconciler interface

2022-02-25 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498393#comment-17498393 ] Aitozi edited comment on FLINK-26377 at 2/26/22, 6:35 AM: -- I have the same

[jira] [Commented] (FLINK-26377) Extract Reconciler interface

2022-02-27 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498687#comment-17498687 ] Aitozi commented on FLINK-26377: ok, i will take a look first before work on it. > Extract Reconci

[jira] [Comment Edited] (FLINK-26719) Rethink the default reschedule reconcile loop

2022-03-19 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509231#comment-17509231 ] Aitozi edited comment on FLINK-26719 at 3/19/22, 9:35 AM: -- {quote}If we do

[jira] [Comment Edited] (FLINK-26719) Rethink the default reschedule reconcile loop

2022-03-19 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509231#comment-17509231 ] Aitozi edited comment on FLINK-26719 at 3/19/22, 9:35 AM: -- {quote} If we do

[jira] [Commented] (FLINK-26719) Rethink the default reschedule reconcile loop

2022-03-19 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509231#comment-17509231 ] Aitozi commented on FLINK-26719: > If we do not want to provide stronger resiliency/guarantees t

[jira] [Commented] (FLINK-26737) Add CRD management in development doc

2022-03-19 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509237#comment-17509237 ] Aitozi commented on FLINK-26737: I will work on it, Please help assign this to me :). > Add

[jira] [Comment Edited] (FLINK-26719) Rethink the default reschedule reconcile loop

2022-03-19 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509231#comment-17509231 ] Aitozi edited comment on FLINK-26719 at 3/19/22, 9:36 AM: -- {quote}If we do

[jira] [Comment Edited] (FLINK-26719) Rethink the default reschedule reconcile loop

2022-03-19 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509231#comment-17509231 ] Aitozi edited comment on FLINK-26719 at 3/19/22, 9:37 AM: -- {quote} If we do

[jira] [Closed] (FLINK-26719) Rethink the default reschedule reconcile loop

2022-03-19 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-26719. -- Resolution: Not A Problem > Rethink the default reschedule reconcile l

[jira] [Created] (FLINK-26737) Add CRD management in development doc

2022-03-19 Thread Aitozi (Jira)
Aitozi created FLINK-26737: -- Summary: Add CRD management in development doc Key: FLINK-26737 URL: https://issues.apache.org/jira/browse/FLINK-26737 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-26737) Add CRD management in development doc

2022-03-19 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26737: --- Description: Add the crd operation in the development doc, such as generate, upgrade and so on. (was: Add

[jira] [Commented] (FLINK-26776) The LocalBufferPoolDestroyTest#isInBlockingBufferRequest is fragile in different JDK environment

2022-03-21 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509806#comment-17509806 ] Aitozi commented on FLINK-26776: Then I found it has been solved by https://issues.apache.org/jira

[jira] [Closed] (FLINK-26776) The LocalBufferPoolDestroyTest#isInBlockingBufferRequest is fragile in different JDK environment

2022-03-21 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-26776. -- Resolution: Duplicate > The LocalBufferPoolDestroyTest#isInBlockingBufferRequest is fragile in > dif

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

2022-03-21 Thread Aitozi (Jira)
Aitozi created FLINK-26784: -- Summary: FLIP-215: Introduce FlinkSessionJob CRD in the kubernetes operator Key: FLINK-26784 URL: https://issues.apache.org/jira/browse/FLINK-26784 Project: Flink

[jira] [Updated] (FLINK-26776) The LocalBufferPoolDestroyTest#isInBlockingBufferRequest is fragile in different JDK environment

2022-03-21 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26776: --- Affects Version/s: 1.14.4 (was: 1.15.0) > The LocalBufferPoolDestroyT

[jira] [Created] (FLINK-26785) Add FlinkSessionJob CRD

2022-03-21 Thread Aitozi (Jira)
Aitozi created FLINK-26785: -- Summary: Add FlinkSessionJob CRD Key: FLINK-26785 URL: https://issues.apache.org/jira/browse/FLINK-26785 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-26787) Implement FlinkSessionJobController and Reconciler

2022-03-21 Thread Aitozi (Jira)
Aitozi created FLINK-26787: -- Summary: Implement FlinkSessionJobController and Reconciler Key: FLINK-26787 URL: https://issues.apache.org/jira/browse/FLINK-26787 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-26807) The batch job not work well with Operator

2022-03-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26807?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510991#comment-17510991 ] Aitozi commented on FLINK-26807: Get it, I will look over that discussion, Closing this one

[jira] [Closed] (FLINK-26807) The batch job not work well with Operator

2022-03-22 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-26807. -- Resolution: Duplicate > The batch job not work well with Opera

[jira] [Created] (FLINK-26871) Handle Session job spec change

2022-03-26 Thread Aitozi (Jira)
Aitozi created FLINK-26871: -- Summary: Handle Session job spec change Key: FLINK-26871 URL: https://issues.apache.org/jira/browse/FLINK-26871 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26870) Implement session job observer

2022-03-26 Thread Aitozi (Jira)
Aitozi created FLINK-26870: -- Summary: Implement session job observer Key: FLINK-26870 URL: https://issues.apache.org/jira/browse/FLINK-26870 Project: Flink Issue Type: Sub-task Reporter

[jira] [Commented] (FLINK-26871) Handle Session job spec change

2022-03-26 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512747#comment-17512747 ] Aitozi commented on FLINK-26871: I will work on this > Handle Session job spec cha

[jira] [Updated] (FLINK-26873) Align the helm chart version with the flink operator

2022-03-26 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26873: --- Component/s: Kubernetes Operator > Align the helm chart version with the flink opera

[jira] [Created] (FLINK-26873) Align the helm chart version with the flink operator

2022-03-26 Thread Aitozi (Jira)
Aitozi created FLINK-26873: -- Summary: Align the helm chart version with the flink operator Key: FLINK-26873 URL: https://issues.apache.org/jira/browse/FLINK-26873 Project: Flink Issue Type: Sub

[jira] [Commented] (FLINK-26873) Align the helm chart version with the flink operator

2022-03-26 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512748#comment-17512748 ] Aitozi commented on FLINK-26873: cc [~gyfora]  > Align the helm chart version with the flink opera

[jira] [Created] (FLINK-26889) Eliminate the duplicated construct for FlinkOperatorConfiguration in test

2022-03-28 Thread Aitozi (Jira)
Aitozi created FLINK-26889: -- Summary: Eliminate the duplicated construct for FlinkOperatorConfiguration in test Key: FLINK-26889 URL: https://issues.apache.org/jira/browse/FLINK-26889 Project: Flink

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2022-03-28 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513286#comment-17513286 ] Aitozi commented on FLINK-18356: Hi, I'm running testing CI against release-1.14 locally and still meet

[jira] [Created] (FLINK-26996) Break the reconcile after first create session cluster

2022-04-01 Thread Aitozi (Jira)
Aitozi created FLINK-26996: -- Summary: Break the reconcile after first create session cluster Key: FLINK-26996 URL: https://issues.apache.org/jira/browse/FLINK-26996 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-20808) Remove redundant checkstyle rules

2022-04-01 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516211#comment-17516211 ] Aitozi commented on FLINK-20808: Hi [~chesnay]  sorry to bother you here, I run into a case that: I

[jira] [Updated] (FLINK-20808) Remove redundant checkstyle rules

2022-04-01 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-20808: --- Attachment: image-2022-04-02-12-46-28-065.png > Remove redundant checkstyle ru

[jira] [Updated] (FLINK-20808) Remove redundant checkstyle rules

2022-04-01 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-20808: --- Attachment: image-2022-04-02-12-46-11-005.png > Remove redundant checkstyle ru

[jira] [Updated] (FLINK-20808) Remove redundant checkstyle rules

2022-04-01 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-20808: --- Attachment: (was: image-2022-04-02-12-46-11-005.png) > Remove redundant checkstyle ru

[jira] [Created] (FLINK-27001) Support to specify the resource of the operator

2022-04-01 Thread Aitozi (Jira)
Aitozi created FLINK-27001: -- Summary: Support to specify the resource of the operator Key: FLINK-27001 URL: https://issues.apache.org/jira/browse/FLINK-27001 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-27000) Support to set JVM args for operator

2022-04-01 Thread Aitozi (Jira)
Aitozi created FLINK-27000: -- Summary: Support to set JVM args for operator Key: FLINK-27000 URL: https://issues.apache.org/jira/browse/FLINK-27000 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-20808) Remove redundant checkstyle rules

2022-04-01 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516216#comment-17516216 ] Aitozi commented on FLINK-20808: No need to answer, after some search, I found it can be solved by set

[jira] [Updated] (FLINK-27028) Support to upload jar and run jar in RestClusterClient

2022-04-02 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27028: --- Description: The {{flink-kubernetes-operator}} is using the JarUpload + JarRun to support the session job

[jira] [Created] (FLINK-27028) Support to upload jar and run jar in RestClusterClient

2022-04-02 Thread Aitozi (Jira)
Aitozi created FLINK-27028: -- Summary: Support to upload jar and run jar in RestClusterClient Key: FLINK-27028 URL: https://issues.apache.org/jira/browse/FLINK-27028 Project: Flink Issue Type

[jira] [Commented] (FLINK-27028) Support to upload jar and run jar in RestClusterClient

2022-04-02 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27028?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516448#comment-17516448 ] Aitozi commented on FLINK-27028: cc [~wangyang0918]  [~chesnay]   If no objection, I'm willing to open

[jira] [Commented] (FLINK-27001) Support to specify the resource of the operator

2022-04-02 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516445#comment-17516445 ] Aitozi commented on FLINK-27001: It seems this can also implement by https://issues.apache.org/jira

<    1   2   3   4   5   6   7   8   9   >