[jira] [Commented] (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 commented on FLINK-27310: --- It seems that this ITCase is not really executed due to its

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

Biao Geng created FLINK-27309: - Summary: Allow to load default flink configs in the k8s operator dynamically Key: FLINK-27309 URL: https://issues.apache.org/jira/browse/FLINK-27309 Project: Flink

[jira] [Commented] (FLINK-27303) Flink Operator will create a large amount of temp log config files

[ https://issues.apache.org/jira/browse/FLINK-27303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524189#comment-17524189 ] Biao Geng commented on FLINK-27303: --- Hi [~gyfora], big +1 for this jira. And I believe besides log

[jira] [Commented] (FLINK-27303) Flink Operator will create a large amount of temp log config files

[ https://issues.apache.org/jira/browse/FLINK-27303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17524218#comment-17524218 ] Biao Geng commented on FLINK-27303: --- Yeah, it seems that most generated configs are for constructing

[jira] [Commented] (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=17524322#comment-17524322 ] Biao Geng commented on FLINK-27310: --- [~usamj] oh, I tried to find the error in my local machine but

[jira] [Commented] (FLINK-27412) Allow flinkVersion v1_13 in flink-kubernetes-operator

[ https://issues.apache.org/jira/browse/FLINK-27412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17528115#comment-17528115 ] Biao Geng commented on FLINK-27412: --- Big +1 for this ticket. Most users, exspecially those use flink

[jira] [Comment Edited] (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=17535845#comment-17535845 ] Biao Geng edited comment on FLINK-27329 at 5/12/22 3:35 AM: [~wangyang0918]

[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=17535845#comment-17535845 ] Biao Geng commented on FLINK-27329: --- [~wangyang0918] I see your point that if we set default value of

[jira] [Updated] (FLINK-27615) Document how to define namespaceSelector for k8s operator's webhook for different k8s versions

[ https://issues.apache.org/jira/browse/FLINK-27615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-27615: -- Summary: Document how to define namespaceSelector for k8s operator's webhook for different k8s

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

[ https://issues.apache.org/jira/browse/FLINK-27615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-27615: -- Component/s: Kubernetes Operator > Document the minimum supported version of k8s for flink k8s

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

Biao Geng created FLINK-27615: - Summary: Document the minimum supported version of k8s for flink k8s operator Key: FLINK-27615 URL: https://issues.apache.org/jira/browse/FLINK-27615 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-27615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537012#comment-17537012 ] Biao Geng commented on FLINK-27615: --- [~aitozi] I think your proposal makes a lot of sense. I checked

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

[ https://issues.apache.org/jira/browse/FLINK-27615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-27615: -- Description: In our webhook, to support {{{}watchNamespaces{}}}, we rely on the

[jira] [Updated] (FLINK-27615) Document the how to define

[ https://issues.apache.org/jira/browse/FLINK-27615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-27615: -- Summary: Document the how to define (was: Document the minimum supported version of k8s for flink

[jira] [Updated] (FLINK-27615) Document the how to define namespaceSelector for k8s operator's webhook

[ https://issues.apache.org/jira/browse/FLINK-27615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-27615: -- Summary: Document the how to define namespaceSelector for k8s operator's webhook (was: Document the

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

[ https://issues.apache.org/jira/browse/FLINK-27615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-27615: -- Description: In our webhook, to support {{{}watchNamespaces{}}}, we rely on the

[jira] [Comment Edited] (FLINK-27615) Document the how to define namespaceSelector for k8s operator's webhook

[ https://issues.apache.org/jira/browse/FLINK-27615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17537012#comment-17537012 ] Biao Geng edited comment on FLINK-27615 at 5/14/22 10:29 AM: - [~aitozi] I

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

[ https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17543405#comment-17543405 ] Biao Geng commented on FLINK-27009: --- hi [~mbalassi] thanks for paying attention. I have already

[jira] [Commented] (FLINK-27615) Document how to define namespaceSelector for k8s operator's webhook for different k8s versions

[ https://issues.apache.org/jira/browse/FLINK-27615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17538690#comment-17538690 ] Biao Geng commented on FLINK-27615: --- [~wangyang0918] I'd like to take this ticket to alert the k8s

[jira] [Commented] (FLINK-27667) YARNHighAvailabilityITCase fails with "Failed to delete temp directory /tmp/junit1681"

[ https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557287#comment-17557287 ] Biao Geng commented on FLINK-27667: --- Hi [~martijnvisser] , I see [~ferenc-csaky]  has created the PR

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

[ https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17562729#comment-17562729 ] Biao Geng commented on FLINK-27009: --- hi [~gyfora], sorry for the late reply. As Yang said, I had

[jira] [Commented] (FLINK-28364) Python Job support for Kubernetes Operator

[ https://issues.apache.org/jira/browse/FLINK-28364?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564277#comment-17564277 ] Biao Geng commented on FLINK-28364: --- Following the pattern we have adopted for sql job example, I have

[jira] [Comment Edited] (FLINK-24346) Flink on yarn application mode,LinkageError

[ https://issues.apache.org/jira/browse/FLINK-24346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561986#comment-17561986 ] Biao Geng edited comment on FLINK-24346 at 7/4/22 6:47 AM: --- Hi

[jira] [Commented] (FLINK-24346) Flink on yarn application mode,LinkageError

[ https://issues.apache.org/jira/browse/FLINK-24346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17561986#comment-17561986 ] Biao Geng commented on FLINK-24346: --- Hi [~soberchi...@gamil.com] have you ever tried to run the

[jira] [Commented] (FLINK-28443) Provide official Flink image for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-28443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17564520#comment-17564520 ] Biao Geng commented on FLINK-28443: --- This improvement is good for user experience, but one challenge

[jira] [Commented] (FLINK-28199) Failures on YARNHighAvailabilityITCase.testClusterClientRetrieval and YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-28199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557506#comment-17557506 ] Biao Geng commented on FLINK-28199: --- According to the log, the exception is thrown as the yarn

[jira] [Comment Edited] (FLINK-28199) Failures on YARNHighAvailabilityITCase.testClusterClientRetrieval and YARNHighAvailabilityITCase.testKillYarnSessionClusterEntrypoint

[ https://issues.apache.org/jira/browse/FLINK-28199?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17557506#comment-17557506 ] Biao Geng edited comment on FLINK-28199 at 6/22/22 3:03 PM: According to the

[jira] [Created] (FLINK-28503) Fix invalid link in Python FAQ Document

Biao Geng created FLINK-28503: - Summary: Fix invalid link in Python FAQ Document Key: FLINK-28503 URL: https://issues.apache.org/jira/browse/FLINK-28503 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-28495) Fix typos or mistakes of Flink CEP Document in the official website

Biao Geng created FLINK-28495: - Summary: Fix typos or mistakes of Flink CEP Document in the official website Key: FLINK-28495 URL: https://issues.apache.org/jira/browse/FLINK-28495 Project: Flink

[jira] [Updated] (FLINK-28495) Fix typos or mistakes of Flink CEP Document in the official website

[ https://issues.apache.org/jira/browse/FLINK-28495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-28495: -- Component/s: Library / CEP > Fix typos or mistakes of Flink CEP Document in the official website >

[jira] [Updated] (FLINK-28495) Fix typos or mistakes of Flink CEP Document in the official website

[ https://issues.apache.org/jira/browse/FLINK-28495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-28495: -- Description: "how you can migrate your job from an older Flink version to Flink-1.3." -> "how you

[jira] [Updated] (FLINK-28495) Fix typos or mistakes of Flink CEP Document in the official website

[ https://issues.apache.org/jira/browse/FLINK-28495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-28495: -- Description: 1. "how you can migrate your job from an older Flink version to Flink-1.3." -> "how you

[jira] [Updated] (FLINK-28495) Fix typos or mistakes of Flink CEP Document in the official website

[ https://issues.apache.org/jira/browse/FLINK-28495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-28495: -- Description: 1. "how you can migrate your job from an older Flink version to Flink-1.3." -> "how you

[jira] [Created] (FLINK-27894) Build flink-connector-hive failed using Maven@3.8.5

Biao Geng created FLINK-27894: - Summary: Build flink-connector-hive failed using Maven@3.8.5 Key: FLINK-27894 URL: https://issues.apache.org/jira/browse/FLINK-27894 Project: Flink Issue Type:

[jira] [Commented] (FLINK-27894) Build flink-connector-hive failed using Maven@3.8.5

[ https://issues.apache.org/jira/browse/FLINK-27894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17546186#comment-17546186 ] Biao Geng commented on FLINK-27894: --- cc [~luoyuxia]  have you ever met such error? > Build

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

[ https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17550265#comment-17550265 ] Biao Geng commented on FLINK-27009: --- Hi [~mbalassi] , sorry for the late reply. I have finished the

[jira] [Commented] (FLINK-27667) YARNHighAvailabilityITCase fails with "Failed to delete temp directory /tmp/junit1681"

[ https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1732#comment-1732 ] Biao Geng commented on FLINK-27667: --- [~martijnvisser] I will do some investigation >

[jira] [Comment Edited] (FLINK-27667) YARNHighAvailabilityITCase fails with "Failed to delete temp directory /tmp/junit1681"

[ https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1732#comment-1732 ] Biao Geng edited comment on FLINK-27667 at 6/18/22 6:36 AM: hi

[jira] [Comment Edited] (FLINK-27667) YARNHighAvailabilityITCase fails with "Failed to delete temp directory /tmp/junit1681"

[ https://issues.apache.org/jira/browse/FLINK-27667?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1732#comment-1732 ] Biao Geng edited comment on FLINK-27667 at 6/18/22 6:34 AM: hi

[jira] [Created] (FLINK-28025) Document the change of serviceAccount in upgrading doc of k8s opeator

Biao Geng created FLINK-28025: - Summary: Document the change of serviceAccount in upgrading doc of k8s opeator Key: FLINK-28025 URL: https://issues.apache.org/jira/browse/FLINK-28025 Project: Flink

[jira] [Commented] (FLINK-28025) Document the change of serviceAccount in upgrading doc of k8s opeator

[ https://issues.apache.org/jira/browse/FLINK-28025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17553605#comment-17553605 ] Biao Geng commented on FLINK-28025: --- cc [~wangyang0918]  > Document the change of serviceAccount in

[jira] (FLINK-28725) flink-kubernetes-operator taskManager: replicas: 2 error

[ https://issues.apache.org/jira/browse/FLINK-28725 ] Biao Geng deleted comment on FLINK-28725: --- was (Author: bgeng777): Hi [~lizu18xz], the field "replicas" of task manager is introduced into CRD since 1.1.0. If your kube cluster has already

[jira] [Commented] (FLINK-28725) flink-kubernetes-operator taskManager: replicas: 2 error

[ https://issues.apache.org/jira/browse/FLINK-28725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17572257#comment-17572257 ] Biao Geng commented on FLINK-28725: --- Hi [~lizu18xz], the field "replicas" of task manager is

[jira] [Commented] (FLINK-28495) Fix typos or mistakes of Flink CEP Document in the official website

[ https://issues.apache.org/jira/browse/FLINK-28495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17566586#comment-17566586 ] Biao Geng commented on FLINK-28495: --- [~martijnvisser] Sure. I can take this ticket. > Fix typos or

[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=17534341#comment-17534341 ] Biao Geng commented on FLINK-27329: --- Yes, I will create a PR in the next 2 days. Sorry for the

[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=17534972#comment-17534972 ] Biao Geng commented on FLINK-27329: --- Hi [~wangyang0918] [~gyfora], I revisit the default values in our

[jira] [Comment Edited] (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=17534972#comment-17534972 ] Biao Geng edited comment on FLINK-27329 at 5/11/22 3:41 PM: Hi

[jira] [Comment Edited] (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=17534972#comment-17534972 ] Biao Geng edited comment on FLINK-27329 at 5/11/22 3:42 PM: Hi

[jira] [Commented] (FLINK-28643) Job archive file contains too much Job json file on Flink HistoryServer

[ https://issues.apache.org/jira/browse/FLINK-28643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17573852#comment-17573852 ] Biao Geng commented on FLINK-28643: --- I run into this issue as well when running jobs with large

[jira] [Created] (FLINK-28769) Flink History Server show wrong name of batch jobs

Biao Geng created FLINK-28769: - Summary: Flink History Server show wrong name of batch jobs Key: FLINK-28769 URL: https://issues.apache.org/jira/browse/FLINK-28769 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-29277) Flink submits tasks to yarn Federation and throws an exception 'org.apache.commons.lang3.NotImplementedException: Code is not implemented'

[ https://issues.apache.org/jira/browse/FLINK-29277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17607268#comment-17607268 ] Biao Geng commented on FLINK-29277: --- In hadoop3.2.1,

[jira] [Updated] (FLINK-29277) Flink submits tasks to yarn Federation and throws an exception 'org.apache.commons.lang3.NotImplementedException: Code is not implemented'

[ https://issues.apache.org/jira/browse/FLINK-29277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-29277: -- Attachment: screenshot-1.png > Flink submits tasks to yarn Federation and throws an exception >

[jira] [Created] (FLINK-29362) Allow loading dynamic config for kerberos authentication in CliFrontend

Biao Geng created FLINK-29362: - Summary: Allow loading dynamic config for kerberos authentication in CliFrontend Key: FLINK-29362 URL: https://issues.apache.org/jira/browse/FLINK-29362 Project: Flink

[jira] [Created] (FLINK-29529) Update flink version in flink-python-example of flink k8s operator

Biao Geng created FLINK-29529: - Summary: Update flink version in flink-python-example of flink k8s operator Key: FLINK-29529 URL: https://issues.apache.org/jira/browse/FLINK-29529 Project: Flink

[jira] [Updated] (FLINK-29529) Update flink version in flink-python-example of flink k8s operator

[ https://issues.apache.org/jira/browse/FLINK-29529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-29529: -- Description: Currently, we hardcoded the version of both flink image and pyflink pip package as

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652511#comment-17652511 ] Biao Geng commented on FLINK-30518: --- I think [~gyfora] is right that this is not a problem before. I

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17652520#comment-17652520 ] Biao Geng commented on FLINK-30518: --- [~gyfora] I see. Thanks for the information. I misunderstood the

[jira] [Updated] (FLINK-30518) [flink-operator] Kubernetes HA not working due to wrong jobmanager.rpc.address

[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-30518: -- Attachment: screenshot-1.png > [flink-operator] Kubernetes HA not working due to wrong

[jira] [Commented] (FLINK-28554) Kubernetes-Operator allow readOnlyRootFilesystem via operatorSecurityContext

[ https://issues.apache.org/jira/browse/FLINK-28554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17649728#comment-17649728 ] Biao Geng commented on FLINK-28554: --- Want to attach more information: According to k8s'

[jira] [Commented] (FLINK-30562) Patterns are not emitted with parallelism >1 since 1.15.x+

[ https://issues.apache.org/jira/browse/FLINK-30562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17654507#comment-17654507 ] Biao Geng commented on FLINK-30562: --- hi [~Jamalarm], thanks for the report. I tried to reproduce your

[jira] [Commented] (FLINK-31529) Let yarn client exit early before JobManager running

[ https://issues.apache.org/jira/browse/FLINK-31529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702634#comment-17702634 ] Biao Geng commented on FLINK-31529: --- Hi there, I want to share some thoughts/questions about this

[jira] [Created] (FLINK-31964) Improve the document of Autoscaler as 1.17.0 is released

Biao Geng created FLINK-31964: - Summary: Improve the document of Autoscaler as 1.17.0 is released Key: FLINK-31964 URL: https://issues.apache.org/jira/browse/FLINK-31964 Project: Flink Issue

[jira] [Commented] (FLINK-31850) Fix args in JobSpec not being passed through to Flink in Standalone mode - 1.4.0

[ https://issues.apache.org/jira/browse/FLINK-31850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17717434#comment-17717434 ] Biao Geng commented on FLINK-31850: --- hi [~gil_shmaya], I checked relevant codes in the

[jira] [Commented] (FLINK-31509) REST Service missing sessionAffinity causes job run failure with HA cluster

[ https://issues.apache.org/jira/browse/FLINK-31509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17702659#comment-17702659 ] Biao Geng commented on FLINK-31509: --- I believe that it should be a bug to route API requests to all JM

[jira] [Commented] (FLINK-23890) CepOperator may create a large number of timers and cause performance problems

[ https://issues.apache.org/jira/browse/FLINK-23890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17686299#comment-17686299 ] Biao Geng commented on FLINK-23890: --- This improvement is of great value for CEP users when they use

[jira] [Updated] (FLINK-35192) operator oom

[ https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-35192: -- Attachment: screenshot-3.png > operator oom > > > Key: FLINK-35192 >

[jira] [Commented] (FLINK-35192) operator oom

[ https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841129#comment-17841129 ] Biao Geng commented on FLINK-35192: --- !screenshot-3.png! According to the flink k8s op's codes, the

[jira] [Updated] (FLINK-35273) PyFlink's LocalZonedTimestampType should respect timezone set by set_local_timezone

[ https://issues.apache.org/jira/browse/FLINK-35273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-35273: -- Description: The issue is from https://apache-flink.slack.com/archives/C065944F9M2/p1714134880878399

[jira] [Created] (FLINK-35273) PyFlink's LocalZonedTimestampType should respect timezone set by set_local_timezone

Biao Geng created FLINK-35273: - Summary: PyFlink's LocalZonedTimestampType should respect timezone set by set_local_timezone Key: FLINK-35273 URL: https://issues.apache.org/jira/browse/FLINK-35273

[jira] [Updated] (FLINK-35273) PyFlink's LocalZonedTimestampType should respect timezone set by set_local_timezone

[ https://issues.apache.org/jira/browse/FLINK-35273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Geng updated FLINK-35273: -- Component/s: API / Python > PyFlink's LocalZonedTimestampType should respect timezone set by >

[jira] [Commented] (FLINK-35192) operator oom

[ https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842322#comment-17842322 ] Biao Geng commented on FLINK-35192: --- [~stupid_pig], it looks like that pictures of the pmap is broken.

[jira] [Commented] (FLINK-35192) operator oom

[ https://issues.apache.org/jira/browse/FLINK-35192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842294#comment-17842294 ] Biao Geng commented on FLINK-35192: --- Sure, created a

[jira] [Commented] (FLINK-35288) Flink Restart Strategy does not work as documented

[ https://issues.apache.org/jira/browse/FLINK-35288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17844106#comment-17844106 ] Biao Geng commented on FLINK-35288: ---

[jira] [Comment Edited] (FLINK-35212) PyFlink thread mode process just can run once in standalonesession mode

[ https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841934#comment-17841934 ] Biao Geng edited comment on FLINK-35212 at 4/29/24 10:22 AM: - Hi [~vonesec],

[jira] [Commented] (FLINK-35212) PyFlink thread mode process just can run once in standalonesession mode

[ https://issues.apache.org/jira/browse/FLINK-35212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17841934#comment-17841934 ] Biao Geng commented on FLINK-35212: --- Hi [~vonesec], thanks for creating the detailed bug report! I

[jira] [Commented] (FLINK-35036) Flink CDC Job cancel with savepoint failed

[ https://issues.apache.org/jira/browse/FLINK-35036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834749#comment-17834749 ] Biao Geng commented on FLINK-35036: --- Hi [~fly365], according to the attached screenshot, the failure

[jira] [Commented] (FLINK-35035) Reduce job pause time when cluster resources are expanded in adaptive mode

[ https://issues.apache.org/jira/browse/FLINK-35035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834752#comment-17834752 ] Biao Geng commented on FLINK-35035: --- I am not very familiar with adaptive scheduler, maybe others can

[jira] [Commented] (FLINK-35376) When flink submits the job by calling the rest api, the dependent jar package generated to the tmp is not removed

[ https://issues.apache.org/jira/browse/FLINK-35376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847168#comment-17847168 ] Biao Geng commented on FLINK-35376: --- hi [~18380428...@163.com], in the implementation of the

<    1   2