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

Aitozi created FLINK-27612: -- Summary: Generate waring events when deleting the session cluster Key: FLINK-27612 URL: https://issues.apache.org/jira/browse/FLINK-27612 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-27576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534934#comment-17534934 ] Aitozi edited comment on FLINK-27576 at 5/11/22 2:37 PM: - Hi [~zhisheng] there

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

[ https://issues.apache.org/jira/browse/FLINK-27576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534934#comment-17534934 ] Aitozi commented on FLINK-27576: Hi [~zhisheng] there is a ticket tracking this

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

[ https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534696#comment-17534696 ] Aitozi commented on FLINK-27483: Yes, I have not seen you have an initial PR just now, you can continue

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

[ https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17534645#comment-17534645 ] Aitozi commented on FLINK-27483: +1 for this solution, I will open a PR for it this week > Support

[jira] [Closed] (FLINK-26915) Extend the Reconciler and Observer interface

[ https://issues.apache.org/jira/browse/FLINK-26915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-26915. -- Resolution: Won't Fix > Extend the Reconciler and Observer interface >

[jira] [Commented] (FLINK-26915) Extend the Reconciler and Observer interface

[ https://issues.apache.org/jira/browse/FLINK-26915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533425#comment-17533425 ] Aitozi commented on FLINK-26915: I have the same sense not to do this now, The main reason is that we

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

[ https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533420#comment-17533420 ] Aitozi commented on FLINK-27483: [~wangyang0918] I check the code again I found I mess them up, also

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

[ https://issues.apache.org/jira/browse/FLINK-27497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533416#comment-17533416 ] Aitozi commented on FLINK-27497: I think it will be very useful improvements, I would like to give a try

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

[ https://issues.apache.org/jira/browse/FLINK-27497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533416#comment-17533416 ] Aitozi edited comment on FLINK-27497 at 5/8/22 6:39 AM: I think it will be a

[jira] [Commented] (FLINK-24633) JobManager pod may stuck in containerCreating status during failover

[ https://issues.apache.org/jira/browse/FLINK-24633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17533411#comment-17533411 ] Aitozi commented on FLINK-24633: I figured out that it's caused by our internal k8s cluster behavior,

[jira] [Closed] (FLINK-24633) JobManager pod may stuck in containerCreating status during failover

[ https://issues.apache.org/jira/browse/FLINK-24633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-24633. -- Resolution: Not A Problem > JobManager pod may stuck in containerCreating status during failover >

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

[ https://issues.apache.org/jira/browse/FLINK-17232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495844#comment-17495844 ] Aitozi edited comment on FLINK-17232 at 5/8/22 4:00 AM: [~wangyang0918] Could

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

[ https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532585#comment-17532585 ] Aitozi commented on FLINK-27483: The difference is whether we need to support the authentication

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

[ https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532234#comment-17532234 ] Aitozi commented on FLINK-27483: I think the reconciliation interval, timeout can be set per

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

[ https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531528#comment-17531528 ] Aitozi commented on FLINK-27483: The config type can be listed as below: * The session

[jira] [Comment Edited] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

[ https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531506#comment-17531506 ] Aitozi edited comment on FLINK-27483 at 5/4/22 6:29 AM: I think supporting the

[jira] [Commented] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

[ https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531506#comment-17531506 ] Aitozi commented on FLINK-27483: I think the custom headers is reasonable, but I'm not tend add a

[jira] [Comment Edited] (FLINK-27483) Support adding custom HTTP header for HTTP based Jar fetch

[ https://issues.apache.org/jira/browse/FLINK-27483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531506#comment-17531506 ] Aitozi edited comment on FLINK-27483 at 5/4/22 6:28 AM: I think the custom

[jira] [Commented] (FLINK-25865) Support to set restart policy of TaskManager pod for native K8s integration

[ https://issues.apache.org/jira/browse/FLINK-25865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531499#comment-17531499 ] Aitozi commented on FLINK-25865: Hi [~wangyang0918] are you working on this now ? If not, I would like

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

[ https://issues.apache.org/jira/browse/FLINK-26647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531498#comment-17531498 ] Aitozi commented on FLINK-26647: I think it will bring convenience to add a way to add config files to

[jira] [Commented] (FLINK-27461) Add a convenient way to set userAgent for the kubeclient

[ https://issues.apache.org/jira/browse/FLINK-27461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530390#comment-17530390 ] Aitozi commented on FLINK-27461: cc [~wangyang0918] WDYT ?  > Add a convenient way to set userAgent for

[jira] [Created] (FLINK-27461) Add a convenient way to set userAgent for the kubeclient

Aitozi created FLINK-27461: -- Summary: Add a convenient way to set userAgent for the kubeclient Key: FLINK-27461 URL: https://issues.apache.org/jira/browse/FLINK-27461 Project: Flink Issue Type:

[jira] [Commented] (FLINK-27337) Prevent session cluster to be deleted when there are running jobs

[ https://issues.apache.org/jira/browse/FLINK-27337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530384#comment-17530384 ] Aitozi commented on FLINK-27337: OK, I will implement the deletions logic first, and will think about

[jira] [Commented] (FLINK-27458) Expose allowNonRestoredState flag in JobSpec

[ https://issues.apache.org/jira/browse/FLINK-27458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530382#comment-17530382 ] Aitozi commented on FLINK-27458: I am willing to work on this > Expose allowNonRestoredState flag in

[jira] [Commented] (FLINK-27458) Expose allowNonRestoredState flag in JobSpec

[ https://issues.apache.org/jira/browse/FLINK-27458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17530381#comment-17530381 ] Aitozi commented on FLINK-27458: The application job can set

[jira] [Comment Edited] (FLINK-27337) Prevent session cluster to be deleted when there are running jobs

[ https://issues.apache.org/jira/browse/FLINK-27337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529879#comment-17529879 ] Aitozi edited comment on FLINK-27337 at 4/29/22 9:13 AM: - I want to solve this

[jira] [Commented] (FLINK-27337) Prevent session cluster to be deleted when there are running jobs

[ https://issues.apache.org/jira/browse/FLINK-27337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529879#comment-17529879 ] Aitozi commented on FLINK-27337:   I want to solve this in the following way # In webhook we can

[jira] [Commented] (FLINK-27451) Enable the validator plugin in webhook

[ https://issues.apache.org/jira/browse/FLINK-27451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17529852#comment-17529852 ] Aitozi commented on FLINK-27451: I will give a quick fix for this. > Enable the validator plugin in

[jira] [Created] (FLINK-27451) Enable the validator plugin in webhook

Aitozi created FLINK-27451: -- Summary: Enable the validator plugin in webhook Key: FLINK-27451 URL: https://issues.apache.org/jira/browse/FLINK-27451 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-27262) Enrich validator for FlinkSessionJob

[ https://issues.apache.org/jira/browse/FLINK-27262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27262: --- Summary: Enrich validator for FlinkSessionJob (was: Enrich validator for FlinkSesionJob) > Enrich

[jira] [Commented] (FLINK-27370) Add a new SessionJobState - Failed

[ https://issues.apache.org/jira/browse/FLINK-27370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528217#comment-17528217 ] Aitozi commented on FLINK-27370: Get it, I think we can add the {{success}} field here as a direct

[jira] [Commented] (FLINK-27370) Add a new SessionJobState - Failed

[ https://issues.apache.org/jira/browse/FLINK-27370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528104#comment-17528104 ] Aitozi commented on FLINK-27370: This field will only reflect whether last reconcile succeed not the

[jira] [Commented] (FLINK-27262) Enrich validator for FlinkSesionJob

[ https://issues.apache.org/jira/browse/FLINK-27262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527928#comment-17527928 ] Aitozi commented on FLINK-27262: I have one thing to discuss here: do we need to support user create a

[jira] [Commented] (FLINK-27370) Add a new SessionJobState - Failed

[ https://issues.apache.org/jira/browse/FLINK-27370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527908#comment-17527908 ] Aitozi commented on FLINK-27370: It previously have a {{success=true/false}} field do you mean that ?

[jira] [Created] (FLINK-27397) Improve the CrdReferenceDoclet generator to handle the abstract class

Aitozi created FLINK-27397: -- Summary: Improve the CrdReferenceDoclet generator to handle the abstract class Key: FLINK-27397 URL: https://issues.apache.org/jira/browse/FLINK-27397 Project: Flink

[jira] [Commented] (FLINK-27358) Kubernetes operator throws NPE when testing with Flink 1.15

[ https://issues.apache.org/jira/browse/FLINK-27358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17527147#comment-17527147 ] Aitozi commented on FLINK-27358: Do we need to link the related upstream ticket here ?  > Kubernetes

[jira] [Created] (FLINK-27362) Support restartNonce semantics in session job

Aitozi created FLINK-27362: -- Summary: Support restartNonce semantics in session job Key: FLINK-27362 URL: https://issues.apache.org/jira/browse/FLINK-27362 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-27262) Enrich validator for FlinkSesionJob

[ https://issues.apache.org/jira/browse/FLINK-27262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526985#comment-17526985 ] Aitozi commented on FLINK-27262: FYI, I'm working on this now. > Enrich validator for FlinkSesionJob >

[jira] [Commented] (FLINK-27360) Rename clusterId field of FlinkSessionJobSpec to deploymentName

[ https://issues.apache.org/jira/browse/FLINK-27360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17526951#comment-17526951 ] Aitozi commented on FLINK-27360: Make sense to me, It's a minor change, I will open a PR for it. >

[jira] [Commented] (FLINK-27337) Prevent session cluster to be deleted when there are running jobs

[ https://issues.apache.org/jira/browse/FLINK-27337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525579#comment-17525579 ] Aitozi commented on FLINK-27337: As discussed in the [mailing

[jira] [Created] (FLINK-27334) Support auto generate the doc for the KubernetesOperatorConfigOptions

Aitozi created FLINK-27334: -- Summary: Support auto generate the doc for the KubernetesOperatorConfigOptions Key: FLINK-27334 URL: https://issues.apache.org/jira/browse/FLINK-27334 Project: Flink

[jira] [Updated] (FLINK-27270) Add document of session job operations

[ https://issues.apache.org/jira/browse/FLINK-27270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-27270: --- Description: # Basic operations # How to support different source jars > Add document of session job

[jira] [Commented] (FLINK-27309) Allow to load default flink configs in the k8s operator dynamically

[ https://issues.apache.org/jira/browse/FLINK-27309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524250#comment-17524250 ] Aitozi commented on FLINK-27309: I think it's a very useful feature in production. But do we need to

[jira] [Commented] (FLINK-27279) Extract common status interfaces

[ https://issues.apache.org/jira/browse/FLINK-27279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524248#comment-17524248 ] Aitozi commented on FLINK-27279: [~gyfora] FYI, I'm working on this now.  > Extract common status

[jira] [Commented] (FLINK-27279) Extract common status interfaces

[ https://issues.apache.org/jira/browse/FLINK-27279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523590#comment-17523590 ] Aitozi commented on FLINK-27279: Get it > Extract common status interfaces >

[jira] [Commented] (FLINK-27279) Extract common status interfaces

[ https://issues.apache.org/jira/browse/FLINK-27279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523573#comment-17523573 ] Aitozi commented on FLINK-27279: hah, I'm willing to take this ticket. Does this also means that we can

[jira] [Commented] (FLINK-27261) Disable web.cancel.enable for session cluster

[ https://issues.apache.org/jira/browse/FLINK-27261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523273#comment-17523273 ] Aitozi commented on FLINK-27261: There is a bit different between the session job and application

[jira] [Comment Edited] (FLINK-27261) Disable web.cancel.enable for session cluster

[ https://issues.apache.org/jira/browse/FLINK-27261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523273#comment-17523273 ] Aitozi edited comment on FLINK-27261 at 4/17/22 4:03 AM: - There is a bit

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

Aitozi created FLINK-27273: -- Summary: Support both configMap and zookeeper based HA data clean up Key: FLINK-27273 URL: https://issues.apache.org/jira/browse/FLINK-27273 Project: Flink Issue Type:

[jira] [Commented] (FLINK-27160) Add e2e tests for FlinkSessionJob type

[ https://issues.apache.org/jira/browse/FLINK-27160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523110#comment-17523110 ] Aitozi commented on FLINK-27160: I'm working on this now > Add e2e tests for FlinkSessionJob type >

[jira] [Commented] (FLINK-27262) Enrich validator for FlinkSesionJob

[ https://issues.apache.org/jira/browse/FLINK-27262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523109#comment-17523109 ] Aitozi commented on FLINK-27262: BTW, I think the webhook have not handle the validation of the

[jira] [Commented] (FLINK-27257) Flink kubernetes operator triggers savepoint failed because of not all tasks running

[ https://issues.apache.org/jira/browse/FLINK-27257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523105#comment-17523105 ] Aitozi commented on FLINK-27257: I also encountered this problem, I think it is caused by the

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

[ https://issues.apache.org/jira/browse/FLINK-26870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523099#comment-17523099 ] Aitozi commented on FLINK-26870: I think this is already include in the

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

[ https://issues.apache.org/jira/browse/FLINK-26870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-26870. -- Resolution: Fixed > Implement session job observer > -- > > Key:

[jira] [Created] (FLINK-27270) Add document of session job operations

Aitozi created FLINK-27270: -- Summary: Add document of session job operations Key: FLINK-27270 URL: https://issues.apache.org/jira/browse/FLINK-27270 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27269) Clean up the jar file after submitting the job

Aitozi created FLINK-27269: -- Summary: Clean up the jar file after submitting the job Key: FLINK-27269 URL: https://issues.apache.org/jira/browse/FLINK-27269 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-27262) Enrich validator for FlinkSesionJob

[ https://issues.apache.org/jira/browse/FLINK-27262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17523078#comment-17523078 ] Aitozi commented on FLINK-27262: Agree, the validator for session job is not complete now. I will work

[jira] [Commented] (FLINK-27203) Add supports for uploading jars from object storage (s3, gcs, oss)

[ https://issues.apache.org/jira/browse/FLINK-27203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17522186#comment-17522186 ] Aitozi commented on FLINK-27203: Hi [~haoxin] , do you mean for uploading the session jobs jars ? There

[jira] [Commented] (FLINK-27161) Support user jar from different type of filesystems

[ https://issues.apache.org/jira/browse/FLINK-27161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520316#comment-17520316 ] Aitozi commented on FLINK-27161: I'm working on this now. > Support user jar from different type of

[jira] [Created] (FLINK-27161) Support user jar from different type of filesystems

Aitozi created FLINK-27161: -- Summary: Support user jar from different type of filesystems Key: FLINK-27161 URL: https://issues.apache.org/jira/browse/FLINK-27161 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-27160) Add e2e tests for FlinkSessionJob type

Aitozi created FLINK-27160: -- Summary: Add e2e tests for FlinkSessionJob type Key: FLINK-27160 URL: https://issues.apache.org/jira/browse/FLINK-27160 Project: Flink Issue Type: Sub-task

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

[ https://issues.apache.org/jira/browse/FLINK-27001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-27001. -- Resolution: Fixed > Support to specify the resource of the operator >

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

[ https://issues.apache.org/jira/browse/FLINK-27001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17519298#comment-17519298 ] Aitozi commented on FLINK-27001: Yes, closing it. > Support to specify the resource of the operator >

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

[ 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 a

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

[ 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

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-27001) Support to specify the resource of the operator

[ 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

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

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

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] [Updated] (FLINK-20808) Remove redundant checkstyle rules

[ 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 rules >

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

[ 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-20808) Remove redundant checkstyle rules

[ 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 rules >

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

[ 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 rules >

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

[ 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] [Created] (FLINK-26996) Break the reconcile after first create session cluster

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] [Comment Edited] (FLINK-26989) Fix the potential lost of secondary resource when watching a namespace

[ https://issues.apache.org/jira/browse/FLINK-26989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17515886#comment-17515886 ] Aitozi edited comment on FLINK-26989 at 4/1/22 12:03 PM: - If there's one

[jira] [Closed] (FLINK-26989) Fix the potential lost of secondary resource when watching a namespace

[ https://issues.apache.org/jira/browse/FLINK-26989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi closed FLINK-26989. -- Resolution: Not A Problem If there's a namespace, the eventsource do not duplicated for the same type, so

[jira] [Created] (FLINK-26989) Fix the potential lost of secondary resource when watching a namespace

Aitozi created FLINK-26989: -- Summary: Fix the potential lost of secondary resource when watching a namespace Key: FLINK-26989 URL: https://issues.apache.org/jira/browse/FLINK-26989 Project: Flink

[jira] [Commented] (FLINK-26915) Extend the Reconciler and Observer interface

[ https://issues.apache.org/jira/browse/FLINK-26915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17514154#comment-17514154 ] Aitozi commented on FLINK-26915: cc [~gyfora] [~wangyang0918]  > Extend the Reconciler and Observer

[jira] [Updated] (FLINK-26915) Extend the Reconciler and Observer interface

[ https://issues.apache.org/jira/browse/FLINK-26915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26915: --- Parent: FLINK-26784 Issue Type: Sub-task (was: Improvement) > Extend the Reconciler and Observer

[jira] [Updated] (FLINK-26915) Extend the Reconciler and Observer interface

[ https://issues.apache.org/jira/browse/FLINK-26915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26915: --- Description: As discussed in

[jira] [Created] (FLINK-26915) Extend the Reconciler and Observer interface

Aitozi created FLINK-26915: -- Summary: Extend the Reconciler and Observer interface Key: FLINK-26915 URL: https://issues.apache.org/jira/browse/FLINK-26915 Project: Flink Issue Type: Improvement

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

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513799#comment-17513799 ] Aitozi commented on FLINK-18356: [~martijnvisser] Thanks for your information, I have addressed the OOM

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

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

[ 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] [Commented] (FLINK-26676) Set ClusterIP service type when watching specific namespaces

[ https://issues.apache.org/jira/browse/FLINK-26676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17512832#comment-17512832 ] Aitozi commented on FLINK-26676: Hi, what error we will get if we not set to ClusterIP?  > Set

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

[ 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 operator >

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

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:

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

[ 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 operator >

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

[ 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 change >

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

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

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

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

[ 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 Operator > -

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

[ 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 as

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

[ https://issues.apache.org/jira/browse/FLINK-26807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aitozi updated FLINK-26807: --- Description: When I test the batch job or finite streaming job, the flinkdep will be an orphaned resource

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

Aitozi created FLINK-26807: -- Summary: The batch job not work well with Operator Key: FLINK-26807 URL: https://issues.apache.org/jira/browse/FLINK-26807 Project: Flink Issue Type: Sub-task

[jira] [Comment Edited] (FLINK-25480) Create dashboard/monitoring to see resource usage per E2E test

[ https://issues.apache.org/jira/browse/FLINK-25480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510448#comment-17510448 ] Aitozi edited comment on FLINK-25480 at 3/22/22, 12:16 PM: --- FYI, I encounter

[jira] [Comment Edited] (FLINK-25480) Create dashboard/monitoring to see resource usage per E2E test

[ https://issues.apache.org/jira/browse/FLINK-25480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510448#comment-17510448 ] Aitozi edited comment on FLINK-25480 at 3/22/22, 12:15 PM: --- FYI, I encounter

[jira] [Comment Edited] (FLINK-25480) Create dashboard/monitoring to see resource usage per E2E test

[ https://issues.apache.org/jira/browse/FLINK-25480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17510448#comment-17510448 ] Aitozi edited comment on FLINK-25480 at 3/22/22, 12:14 PM: --- FYI, I encounter

<    1   2   3   4   5   6   7   8   9   >