[jira] [Commented] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402730#comment-17402730 ] Biao Geng commented on FLINK-23556: --- hi [~xtsong], I think my pull request is ready. I tried 3 times

[jira] [Comment Edited] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401174#comment-17401174 ] Biao Geng edited comment on FLINK-23556 at 8/18/21, 4:09 PM: - Hi, [~xtsong] 

[jira] [Commented] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401174#comment-17401174 ] Biao Geng commented on FLINK-23556: --- Hi, [~xtsong] . I may need one day to verify the PR after today's

[jira] [Commented] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400465#comment-17400465 ] Biao Geng commented on FLINK-23556: --- hi [~xtsong], thanks a lot for your support! I have dived into

[jira] [Comment Edited] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402730#comment-17402730 ] Biao Geng edited comment on FLINK-23556 at 8/24/21, 4:29 AM: - hi [~xtsong],

[jira] [Commented] (FLINK-23556) SQLClientSchemaRegistryITCase fails with " Subject ... not found"

[ https://issues.apache.org/jira/browse/FLINK-23556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17396751#comment-17396751 ] Biao Geng commented on FLINK-23556: --- I have read the test codes and I doubt that the port in the

[jira] [Commented] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446258#comment-17446258 ] Biao Geng commented on FLINK-24897: --- Hi [~trohrmann] , would you mind giving any comments on if we

[jira] [Commented] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17450424#comment-17450424 ] Biao Geng commented on FLINK-24897: --- Thank you very much. I will follow above discussion to create a

[jira] [Updated] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-24897: -- Description: Hi there,  I am working to utilize application mode to submit flink jobs to YARN cluster

[jira] [Commented] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17443680#comment-17443680 ] Biao Geng commented on FLINK-24897: --- Hi, [~trohrmann] [~wangyang0918] [~xtsong], very sorry to bother

[jira] [Created] (FLINK-24897) Enable application mode on YARN to use usrlib

Biao Geng created FLINK-24897: - Summary: Enable application mode on YARN to use usrlib Key: FLINK-24897 URL: https://issues.apache.org/jira/browse/FLINK-24897 Project: Flink Issue Type:

[jira] [Updated] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-24897: -- Description: Hi there,  I am working to utilize application mode to submit flink jobs to YARN cluster

[jira] [Updated] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-24897: -- Description: Hi there,  I am working to utilize application mode to submit flink jobs to YARN cluster

[jira] [Updated] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-24897: -- Description: Hi there,  I am working to utilize application mode to submit flink jobs to YARN cluster

[jira] [Updated] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-24897: -- Description: Hi there,  I am working to utilize application mode to submit flink jobs to YARN cluster

[jira] [Commented] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445748#comment-17445748 ] Biao Geng commented on FLINK-24897: --- [~wangyang0918] Thanks for the reply! I also think about throwing

[jira] [Commented] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445631#comment-17445631 ] Biao Geng commented on FLINK-24897: --- Hi [~trohrmann] and [~wangyang0918] thank you very much for your

[jira] [Commented] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17445605#comment-17445605 ] Biao Geng commented on FLINK-24897: --- [~long jiang] , thanks a lot for your advice. I just focus on the

[jira] [Commented] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437208#comment-17437208 ] Biao Geng commented on FLINK-24494: --- Hi [~mahen], I have met this problem as well. I have implemented

[jira] [Comment Edited] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437208#comment-17437208 ] Biao Geng edited comment on FLINK-24494 at 11/2/21, 9:56 AM: - Hi [~mahen], I

[jira] [Comment Edited] (FLINK-24494) Avro Confluent Registry SQL kafka connector fails to write to the topic with schema

[ https://issues.apache.org/jira/browse/FLINK-24494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17437208#comment-17437208 ] Biao Geng edited comment on FLINK-24494 at 11/2/21, 9:10 AM: - Hi [~mahen], I

[jira] [Created] (FLINK-24682) Unify the -C option behavior in both yarn application and per-job mode

Biao Geng created FLINK-24682: - Summary: Unify the -C option behavior in both yarn application and per-job mode Key: FLINK-24682 URL: https://issues.apache.org/jira/browse/FLINK-24682 Project: Flink

[jira] [Commented] (FLINK-24682) Unify the -C option behavior in both yarn application and per-job mode

[ https://issues.apache.org/jira/browse/FLINK-24682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440335#comment-17440335 ] Biao Geng commented on FLINK-24682: --- Hi, [~trohrmann] [~xtsong], would you mind leaving any comments

[jira] [Commented] (FLINK-26605) JobManagerDeploymentStatus.READY does not correctly reflect the real Flink cluster status

[ https://issues.apache.org/jira/browse/FLINK-26605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17505984#comment-17505984 ] Biao Geng commented on FLINK-26605: --- Hi [~wangyang0918], the simple rest call for the state check of

[jira] [Commented] (FLINK-26702) Sporadic failures in JobObserverTest

[ https://issues.apache.org/jira/browse/FLINK-26702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17508100#comment-17508100 ] Biao Geng commented on FLINK-26702: --- Hi [~mbalassi] you are not alone. I have also seen this failure

[jira] [Created] (FLINK-26671) Update 'Developer Guide' in README

Biao Geng created FLINK-26671: - Summary: Update 'Developer Guide' in README Key: FLINK-26671 URL: https://issues.apache.org/jira/browse/FLINK-26671 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26655) Merge isJobManagerPortReady and isJobManagerServing to check if JM pod can work correctly

Biao Geng created FLINK-26655: - Summary: Merge isJobManagerPortReady and isJobManagerServing to check if JM pod can work correctly Key: FLINK-26655 URL: https://issues.apache.org/jira/browse/FLINK-26655

[jira] [Updated] (FLINK-26605) Check if JM can serve rest api calls every time before reconcile

[ https://issues.apache.org/jira/browse/FLINK-26605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26605: -- Summary: Check if JM can serve rest api calls every time before reconcile (was: Improve the observe

[jira] [Updated] (FLINK-26655) Improve the observe logic in SessionObserver

[ https://issues.apache.org/jira/browse/FLINK-26655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26655: -- Summary: Improve the observe logic in SessionObserver (was: Merge isJobManagerPortReady and

[jira] [Updated] (FLINK-26655) Merge isJobManagerPortReady and isJobManagerServing to check if JM pod can work correctly

[ https://issues.apache.org/jira/browse/FLINK-26655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26655: -- Description: -We now consider that JM pod can have 2 possible states after launching:- # -JM is

[jira] [Updated] (FLINK-26605) Improve the observe logic in SessionObserver

[ https://issues.apache.org/jira/browse/FLINK-26605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26605: -- Summary: Improve the observe logic in SessionObserver (was: JobManagerDeploymentStatus.READY does

[jira] [Updated] (FLINK-26655) Improve the observe logic in SessionObserver

[ https://issues.apache.org/jira/browse/FLINK-26655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26655: -- Description: -We now consider that JM pod can have 2 possible states after launching:- # -JM is

[jira] [Updated] (FLINK-26655) Improve the observe logic in SessionObserver

[ https://issues.apache.org/jira/browse/FLINK-26655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26655: -- Description: -We now consider that JM pod can have 2 possible states after launching:- # -JM is

[jira] [Commented] (FLINK-26655) Improve the observe logic in SessionObserver

[ https://issues.apache.org/jira/browse/FLINK-26655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17509168#comment-17509168 ] Biao Geng commented on FLINK-26655: --- I rewrite this jira after our previous discussion about the check

[jira] [Comment Edited] (FLINK-26163) Refactor FlinkUtils#getEffectiveConfig into smaller pieces

[ https://issues.apache.org/jira/browse/FLINK-26163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493096#comment-17493096 ] Biao Geng edited comment on FLINK-26163 at 2/16/22, 9:18 AM: - hi [~gyfora] ,

[jira] [Commented] (FLINK-26163) Refactor FlinkUtils#getEffectiveConfig into smaller pieces

[ https://issues.apache.org/jira/browse/FLINK-26163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493096#comment-17493096 ] Biao Geng commented on FLINK-26163: --- hi [~gyfora] , I am happy to take this ticket to refactor the

[jira] [Commented] (FLINK-26178) Use the same enum for expected and observed jobstate (JobState / JobStatus.state)

[ https://issues.apache.org/jira/browse/FLINK-26178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497233#comment-17497233 ] Biao Geng commented on FLINK-26178: --- Hi [~gyfora], seems this ticket has been opened for some days. I

[jira] [Comment Edited] (FLINK-26178) Use the same enum for expected and observed jobstate (JobState / JobStatus.state)

[ https://issues.apache.org/jira/browse/FLINK-26178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497521#comment-17497521 ] Biao Geng edited comment on FLINK-26178 at 2/24/22, 4:52 PM: - Some thoughts

[jira] [Comment Edited] (FLINK-26178) Use the same enum for expected and observed jobstate (JobState / JobStatus.state)

[ https://issues.apache.org/jira/browse/FLINK-26178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497521#comment-17497521 ] Biao Geng edited comment on FLINK-26178 at 2/24/22, 4:34 PM: - Some thoughts

[jira] [Commented] (FLINK-26178) Use the same enum for expected and observed jobstate (JobState / JobStatus.state)

[ https://issues.apache.org/jira/browse/FLINK-26178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17497521#comment-17497521 ] Biao Geng commented on FLINK-26178: --- Some thoughts in doing this ticket: As the description of this

[jira] [Commented] (FLINK-26216) Make 'replicas' work in JobManager Spec

[ https://issues.apache.org/jira/browse/FLINK-26216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17494981#comment-17494981 ] Biao Geng commented on FLINK-26216: --- hi [~ConradJam] thanks a lot for your words but I do not have the

[jira] [Updated] (FLINK-26405) Add validation check of num of JM replica

[ https://issues.apache.org/jira/browse/FLINK-26405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26405: -- External issue URL: (was: https://issues.apache.org/jira/browse/FLINK-26216) > Add validation

[jira] [Created] (FLINK-26405) Add validation check of num of JM replica

Biao Geng created FLINK-26405: - Summary: Add validation check of num of JM replica Key: FLINK-26405 URL: https://issues.apache.org/jira/browse/FLINK-26405 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-26405) Add validation check of num of JM replica

[ https://issues.apache.org/jira/browse/FLINK-26405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26405: -- Parent: FLINK-25963 Issue Type: Sub-task (was: Improvement) > Add validation check of num of

[jira] [Updated] (FLINK-26405) Add validation check of num of JM replica

[ https://issues.apache.org/jira/browse/FLINK-26405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26405: -- External issue URL: https://issues.apache.org/jira/browse/FLINK-26216 > Add validation check of num

[jira] [Commented] (FLINK-26405) Add validation check of num of JM replica

[ https://issues.apache.org/jira/browse/FLINK-26405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17499295#comment-17499295 ] Biao Geng commented on FLINK-26405: --- Hi [~wangyang0918] I want to take this Jira to make the support

[jira] [Updated] (FLINK-26405) Add validation check of num of JM replica

[ https://issues.apache.org/jira/browse/FLINK-26405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26405: -- Description: When HA is enabled, the replicas of JM can be 1 or more,  When HA is not set, the

[jira] [Created] (FLINK-26216) Make 'replicas' work in JobManager Spec

Biao Geng created FLINK-26216: - Summary: Make 'replicas' work in JobManager Spec Key: FLINK-26216 URL: https://issues.apache.org/jira/browse/FLINK-26216 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-26216) Make 'replicas' work in JobManager Spec

[ https://issues.apache.org/jira/browse/FLINK-26216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26216: -- Parent: FLINK-25963 Issue Type: Sub-task (was: Bug) > Make 'replicas' work in JobManager

[jira] [Commented] (FLINK-26216) Make 'replicas' work in JobManager Spec

[ https://issues.apache.org/jira/browse/FLINK-26216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495930#comment-17495930 ] Biao Geng commented on FLINK-26216: --- [~gyfora] thanks; I will draft the pr ASAP. > Make 'replicas'

[jira] [Commented] (FLINK-26139) Improve JobStatus tracking and handle different job states

[ https://issues.apache.org/jira/browse/FLINK-26139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17498139#comment-17498139 ] Biao Geng commented on FLINK-26139: --- After checking the job state transition in Flink, I think in this

[jira] [Updated] (FLINK-26139) Improve JobStatus tracking and handle different job states

[ https://issues.apache.org/jira/browse/FLINK-26139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26139: -- Attachment: image-2022-02-25-21-22-08-636.png > Improve JobStatus tracking and handle different job

[jira] [Comment Edited] (FLINK-26216) Make 'replicas' work in JobManager Spec

[ https://issues.apache.org/jira/browse/FLINK-26216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495290#comment-17495290 ] Biao Geng edited comment on FLINK-26216 at 2/21/22, 2:55 AM: - [~ConradJam]

[jira] [Commented] (FLINK-26216) Make 'replicas' work in JobManager Spec

[ https://issues.apache.org/jira/browse/FLINK-26216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17495290#comment-17495290 ] Biao Geng commented on FLINK-26216: --- [~ConradJam] You give a very valuable point and in my opinion,

[jira] [Commented] (FLINK-26825) Document State Machine Graph for JM Deployment

[ https://issues.apache.org/jira/browse/FLINK-26825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17511100#comment-17511100 ] Biao Geng commented on FLINK-26825: --- Hi [~gyfora] would you mind assigning this ticket to me? >

[jira] [Created] (FLINK-26825) Document State Machine Graph for JM Deployment

Biao Geng created FLINK-26825: - Summary: Document State Machine Graph for JM Deployment Key: FLINK-26825 URL: https://issues.apache.org/jira/browse/FLINK-26825 Project: Flink Issue Type:

[jira] [Created] (FLINK-26832) Output more status info for JobObserver

Biao Geng created FLINK-26832: - Summary: Output more status info for JobObserver Key: FLINK-26832 URL: https://issues.apache.org/jira/browse/FLINK-26832 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-26611) Document operator config options

[ https://issues.apache.org/jira/browse/FLINK-26611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17516254#comment-17516254 ] Biao Geng commented on FLINK-26611: --- [~gyfora] I see this jira is open and in the plan of 0.1.0

[jira] [Created] (FLINK-27009) Support SQL job submission in flink kubernetes opeartor

Biao Geng created FLINK-27009: - Summary: Support SQL job submission in flink kubernetes opeartor Key: FLINK-27009 URL: https://issues.apache.org/jira/browse/FLINK-27009 Project: Flink Issue

[jira] [Commented] (FLINK-26892) Observe current status before validating CR changes

[ https://issues.apache.org/jira/browse/FLINK-26892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513858#comment-17513858 ] Biao Geng commented on FLINK-26892: --- Hi [~gyfora], I see your point. The reason for I asking above

[jira] [Commented] (FLINK-26892) Observe current status before validating CR changes

[ https://issues.apache.org/jira/browse/FLINK-26892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513791#comment-17513791 ] Biao Geng commented on FLINK-26892: --- In our current implementation, validation error should only

[jira] [Comment Edited] (FLINK-26892) Observe current status before validating CR changes

[ https://issues.apache.org/jira/browse/FLINK-26892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513791#comment-17513791 ] Biao Geng edited comment on FLINK-26892 at 3/29/22, 4:09 AM: - In our current

[jira] [Comment Edited] (FLINK-26892) Observe current status before validating CR changes

[ https://issues.apache.org/jira/browse/FLINK-26892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513791#comment-17513791 ] Biao Geng edited comment on FLINK-26892 at 3/29/22, 4:10 AM: - In our current

[jira] [Commented] (FLINK-26892) Observe current status before validating CR changes

[ https://issues.apache.org/jira/browse/FLINK-26892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17513971#comment-17513971 ] Biao Geng commented on FLINK-26892: --- I try to summary what we should do for this case: 1. Save latest

[jira] [Commented] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17483689#comment-17483689 ] Biao Geng commented on FLINK-24897: --- hi [~wangyang0918], I have completed the

[jira] [Updated] (FLINK-24897) Make usrlib work for YARN application and per-job

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-24897: -- Summary: Make usrlib work for YARN application and per-job (was: Make usrlib could work for YARN

[jira] [Comment Edited] (FLINK-24897) Make usrlib could work for YARN application and per-job

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446258#comment-17446258 ] Biao Geng edited comment on FLINK-24897 at 2/8/22, 11:01 AM: - Hi

[jira] [Updated] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26030: -- Component/s: Deployment / YARN > Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers >

[jira] [Updated] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26030: -- Summary: Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers (was: Set FLINK_LIB_DIR to

[jira] [Created] (FLINK-26030) Set FLINK_LIB_DIR to lib under working dir in YARN containers

Biao Geng created FLINK-26030: - Summary: Set FLINK_LIB_DIR to lib under working dir in YARN containers Key: FLINK-26030 URL: https://issues.apache.org/jira/browse/FLINK-26030 Project: Flink

[jira] [Updated] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26030: -- Description: Currently, we utilize

[jira] [Updated] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26030: -- Description: Currently, we utilize

[jira] [Created] (FLINK-26047) Support usrlib in HDFS for YARN application mode

Biao Geng created FLINK-26047: - Summary: Support usrlib in HDFS for YARN application mode Key: FLINK-26047 URL: https://issues.apache.org/jira/browse/FLINK-26047 Project: Flink Issue Type:

[jira] [Comment Edited] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17483689#comment-17483689 ] Biao Geng edited comment on FLINK-24897 at 2/7/22, 9:05 AM: hi

[jira] [Comment Edited] (FLINK-24897) Enable application mode on YARN to use usrlib

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17483689#comment-17483689 ] Biao Geng edited comment on FLINK-24897 at 2/7/22, 9:07 AM: hi

[jira] [Commented] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489957#comment-17489957 ] Biao Geng commented on FLINK-26030: --- Yes, it should be a bug. I believe to be consistent with the

[jira] [Updated] (FLINK-26030) Set FLINK_LIB_DIR to 'lib' under working dir in YARN containers

[ https://issues.apache.org/jira/browse/FLINK-26030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-26030: -- Description: Currently, we utilize

[jira] [Comment Edited] (FLINK-24897) Make usrlib work for YARN application and per-job

[ https://issues.apache.org/jira/browse/FLINK-24897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17446258#comment-17446258 ] Biao Geng edited comment on FLINK-24897 at 2/10/22, 2:35 AM: - Hi

[jira] [Commented] (FLINK-26047) Support usrlib in HDFS for YARN application mode

[ https://issues.apache.org/jira/browse/FLINK-26047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489955#comment-17489955 ] Biao Geng commented on FLINK-26047: --- hi [~wangyang0918] Sure. I would take the ticket and start

[jira] [Resolved] (FLINK-24682) Unify the -C option behavior in both yarn application and per-job mode

[ https://issues.apache.org/jira/browse/FLINK-24682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng resolved FLINK-24682. --- Resolution: Won't Do > Unify the -C option behavior in both yarn application and per-job mode >

[jira] [Commented] (FLINK-24682) Unify the -C option behavior in both yarn application and per-job mode

[ https://issues.apache.org/jira/browse/FLINK-24682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17489959#comment-17489959 ] Biao Geng commented on FLINK-24682: --- Per-job mode will be deprecate due to

[jira] [Updated] (FLINK-27109) Improve the creation of ClusterRole in Flink K8s operator

[ https://issues.apache.org/jira/browse/FLINK-27109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-27109: -- Priority: Not a Priority (was: Major) > Improve the creation of ClusterRole in Flink K8s operator >

[jira] [Commented] (FLINK-27109) Improve the creation of ClusterRole in Flink K8s operator

[ https://issues.apache.org/jira/browse/FLINK-27109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518699#comment-17518699 ] Biao Geng commented on FLINK-27109: --- [~wangyang0918]I see your point. It's my bad to ignore the usage

[jira] [Updated] (FLINK-27109) Improve the creation of ClusterRole in Flink K8s operator

[ https://issues.apache.org/jira/browse/FLINK-27109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-27109: -- Description: As the

[jira] [Created] (FLINK-27109) The naming pattern of ClusterRole in Flink K8s operator should consider namespace

Biao Geng created FLINK-27109: - Summary: The naming pattern of ClusterRole in Flink K8s operator should consider namespace Key: FLINK-27109 URL: https://issues.apache.org/jira/browse/FLINK-27109 Project:

[jira] [Updated] (FLINK-27109) Improve the creation of ClusterRole in Flink K8s operator

[ https://issues.apache.org/jira/browse/FLINK-27109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-27109: -- Description: As the

[jira] [Closed] (FLINK-27109) Improve the creation of ClusterRole in Flink K8s operator

[ https://issues.apache.org/jira/browse/FLINK-27109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng closed FLINK-27109. - Resolution: Won't Fix > Improve the creation of ClusterRole in Flink K8s operator >

[jira] [Updated] (FLINK-27109) Improve the creation of ClusterRole in Flink K8s operator

[ https://issues.apache.org/jira/browse/FLINK-27109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-27109: -- Summary: Improve the creation of ClusterRole in Flink K8s operator (was: The naming pattern of

[jira] [Commented] (FLINK-27109) Improve the creation of ClusterRole in Flink K8s operator

[ https://issues.apache.org/jira/browse/FLINK-27109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17518673#comment-17518673 ] Biao Geng commented on FLINK-27109: --- cc [~morhidi] [~mbalassi] Do you have any suggestion? > Improve

[jira] [Created] (FLINK-27329) Add default value of replica of JM pod and remove declaring it in example yamls

Biao Geng created FLINK-27329: - Summary: Add default value of replica of JM pod and remove declaring it in example yamls Key: FLINK-27329 URL: https://issues.apache.org/jira/browse/FLINK-27329 Project:

[jira] [Updated] (FLINK-27329) Add default value of replica of JM pod and not declare it in example yamls

[ https://issues.apache.org/jira/browse/FLINK-27329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-27329: -- Description: Currently, we do not explicitly set the default value of `replica` in `JobManagerSpec`.

[jira] [Updated] (FLINK-27329) Add default value of replica of JM pod and not declare it in example yamls

[ https://issues.apache.org/jira/browse/FLINK-27329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-27329: -- Summary: Add default value of replica of JM pod and not declare it in example yamls (was: Add

[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=17525012#comment-17525012 ] Biao Geng commented on FLINK-27309: --- Thanks [~gyfora]! Besides [~aitozi]'s valuable point, I also

[jira] [Commented] (FLINK-27329) Add default value of replica of JM pod and remove declaring it in example yamls

[ https://issues.apache.org/jira/browse/FLINK-27329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525020#comment-17525020 ] Biao Geng commented on FLINK-27329: --- cc [~wangyang0918]  I can take this ticket~ > Add default value

[jira] [Commented] (FLINK-24960) YARNSessionCapacitySchedulerITCase.testVCoresAreSetCorrectlyAndJobManagerHostnameAreShownInWebInterfaceAndDynamicPropertiesAndYarnApplicationNameAndTaskManagerSlots ha

[ https://issues.apache.org/jira/browse/FLINK-24960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524860#comment-17524860 ] Biao Geng commented on FLINK-24960: --- Hi [~mapohl], I tried to do some research but in latest

[jira] [Commented] (FLINK-27329) Add default value of replica of JM pod and not declare it in example yamls

[ https://issues.apache.org/jira/browse/FLINK-27329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17525432#comment-17525432 ] Biao Geng commented on FLINK-27329: --- [~wangyang0918] Reviewing all default values makes sense to me. I

[jira] [Comment Edited] (FLINK-27310) FlinkOperatorITCase failure due to JobManager replicas less than one

[ https://issues.apache.org/jira/browse/FLINK-27310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524291#comment-17524291 ] Biao Geng edited comment on FLINK-27310 at 4/19/22 1:00 PM: It seems that

[jira] [Comment Edited] (FLINK-27310) FlinkOperatorITCase failure due to JobManager replicas less than one

[ https://issues.apache.org/jira/browse/FLINK-27310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524291#comment-17524291 ] Biao Geng edited comment on FLINK-27310 at 4/19/22 1:00 PM: It seems that

[jira] [Comment Edited] (FLINK-27310) FlinkOperatorITCase failure due to JobManager replicas less than one

[ https://issues.apache.org/jira/browse/FLINK-27310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524291#comment-17524291 ] Biao Geng edited comment on FLINK-27310 at 4/19/22 1:01 PM: It seems that

[jira] [Comment Edited] (FLINK-27310) FlinkOperatorITCase failure due to JobManager replicas less than one

[ https://issues.apache.org/jira/browse/FLINK-27310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524291#comment-17524291 ] Biao Geng edited comment on FLINK-27310 at 4/19/22 1:01 PM: It seems that

  1   2   >