[jira] [Commented] (FLINK-34333) Fix FLINK-34007 LeaderElector bug in 1.18

[ https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813604#comment-17813604 ] Yang Wang commented on FLINK-34333: --- +1 for what Chesnay said. We already shade the fa

[jira] [Commented] (FLINK-34333) Fix FLINK-34007 LeaderElector bug in 1.18

[ https://issues.apache.org/jira/browse/FLINK-34333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17813603#comment-17813603 ] Yang Wang commented on FLINK-34333: --- I am not aware of other potential issues and in f

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17809858#comment-17809858 ] Yang Wang commented on FLINK-34007: --- It seems that the fabric8 K8s client community le

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808441#comment-17808441 ] Yang Wang commented on FLINK-34007: --- I also remember that the fabric8 kubernetes-clien

[jira] [Commented] (FLINK-34135) A number of ci failures with Access to the path '.../_work/_temp/containerHandlerInvoker.js' is denied.

[ https://issues.apache.org/jira/browse/FLINK-34135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17808420#comment-17808420 ] Yang Wang commented on FLINK-34135: --- The CI should work since the {{containerHandlerIn

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807700#comment-17807700 ] Yang Wang commented on FLINK-34007: --- I agree with you that we could enable {{{}isRelea

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807538#comment-17807538 ] Yang Wang commented on FLINK-34007: --- I think you are right that {{stopped}} flag in {{

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17807009#comment-17807009 ] Yang Wang commented on FLINK-34007: --- {quote}At least based on the reports of this Jira

[jira] [Commented] (FLINK-24332) Support to mount a dynamically-created persistent volume claim per TaskManager

[ https://issues.apache.org/jira/browse/FLINK-24332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806763#comment-17806763 ] Yang Wang commented on FLINK-24332: --- We do not need this feature now since Kubernetes

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806714#comment-17806714 ] Yang Wang commented on FLINK-34007: --- Maybe this issue is related with fabric8 K8s clie

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806600#comment-17806600 ] Yang Wang commented on FLINK-34007: --- Maybe I did not make myself clear. I mean the old

[jira] [Commented] (FLINK-33728) do not rewatch when KubernetesResourceManagerDriver watch fail

[ https://issues.apache.org/jira/browse/FLINK-33728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806592#comment-17806592 ] Yang Wang commented on FLINK-33728: --- Not only the {{KubernetesResourceManagerDriver}}

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805871#comment-17805871 ] Yang Wang commented on FLINK-34007: --- [~mapohl] Could you please confirm that whether "

[jira] [Commented] (FLINK-34007) Flink Job stuck in suspend state after losing leadership in HA Mode

[ https://issues.apache.org/jira/browse/FLINK-34007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805487#comment-17805487 ] Yang Wang commented on FLINK-34007: --- Do you mean the {{KubernetesLeaderElector}} could

[jira] [Commented] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17768679#comment-17768679 ] Yang Wang commented on FLINK-33155: --- Thanks for your comments.   > Changing the defa

[jira] [Updated] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-33155: -- Description: When Kerberos enabled(with key tab) and after one day(the container token expired), Flin

[jira] [Updated] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-33155: -- Description: When Kerberos enabled(with key tab) and after one day(the container token expired), Flin

[jira] [Updated] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

[ https://issues.apache.org/jira/browse/FLINK-33155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-33155: -- Component/s: Deployment / YARN > Flink ResourceManager continuously fails to start TM container on YAR

[jira] [Created] (FLINK-33155) Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled

Yang Wang created FLINK-33155: - Summary: Flink ResourceManager continuously fails to start TM container on YARN when Kerberos enabled Key: FLINK-33155 URL: https://issues.apache.org/jira/browse/FLINK-33155

[jira] [Commented] (FLINK-32775) Support yarn.provided.lib.dirs to add parent directory to classpath

[ https://issues.apache.org/jira/browse/FLINK-32775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764937#comment-17764937 ] Yang Wang commented on FLINK-32775: --- Thanks [~argoyal]  for your contribution. > Supp

[jira] [Closed] (FLINK-32775) Support yarn.provided.lib.dirs to add parent directory to classpath

[ https://issues.apache.org/jira/browse/FLINK-32775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-32775. - Resolution: Fixed > Support yarn.provided.lib.dirs to add parent directory to classpath > --

[jira] [Updated] (FLINK-32775) Support yarn.provided.lib.dirs to add parent directory to classpath

[ https://issues.apache.org/jira/browse/FLINK-32775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32775: -- Fix Version/s: 1.19.0 > Support yarn.provided.lib.dirs to add parent directory to classpath >

[jira] [Commented] (FLINK-32775) Support yarn.provided.lib.dirs to add parent directory to classpath

[ https://issues.apache.org/jira/browse/FLINK-32775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764936#comment-17764936 ] Yang Wang commented on FLINK-32775: --- Merged in master via 1f9621806451411af26ccbab5c53

[jira] [Commented] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760194#comment-17760194 ] Yang Wang commented on FLINK-32678: --- I just remember we have a {{toString}} in the {{

[jira] [Comment Edited] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759570#comment-17759570 ] Yang Wang edited comment on FLINK-32678 at 8/29/23 6:13 AM:

[jira] [Comment Edited] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759570#comment-17759570 ] Yang Wang edited comment on FLINK-32678 at 8/29/23 5:20 AM:

[jira] [Comment Edited] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759570#comment-17759570 ] Yang Wang edited comment on FLINK-32678 at 8/29/23 5:20 AM:

[jira] [Comment Edited] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759570#comment-17759570 ] Yang Wang edited comment on FLINK-32678 at 8/29/23 5:15 AM:

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: (was: qos-configmap-get-115.png) > Release Testing: Stress-Test to cover multiple low-

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: (was: qos-configmap-put-115.png) > Release Testing: Stress-Test to cover multiple low-

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: qps-configmap-get-118.png qps-configmap-get-115.png qps-con

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: (was: qos-configmap-patch-118.png) > Release Testing: Stress-Test to cover multiple lo

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: (was: qos-configmap-get-118.png) > Release Testing: Stress-Test to cover multiple low-

[jira] [Commented] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759571#comment-17759571 ] Yang Wang commented on FLINK-32678: --- [~mapohl] Please ping me if you believe we still

[jira] [Commented] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759570#comment-17759570 ] Yang Wang commented on FLINK-32678: --- *Stress Test* Run 1000 Flink Jobs with 1 JM and 1

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: qos-configmap-put-115.png > Release Testing: Stress-Test to cover multiple low-level chang

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: qos-configmap-get-118.png > Release Testing: Stress-Test to cover multiple low-level chang

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: (was: qos-configmap-get-115-1.png) > Release Testing: Stress-Test to cover multiple lo

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: qos-configmap-get-115-1.png > Release Testing: Stress-Test to cover multiple low-level cha

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: qos-configmap-patch-118.png > Release Testing: Stress-Test to cover multiple low-level cha

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: qos-configmap-get-115.png > Release Testing: Stress-Test to cover multiple low-level chang

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: (was: image (1).png) > Release Testing: Stress-Test to cover multiple low-level change

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: (was: image (2).png) > Release Testing: Stress-Test to cover multiple low-level change

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: (was: image.png) > Release Testing: Stress-Test to cover multiple low-level changes in

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: (was: image (3).png) > Release Testing: Stress-Test to cover multiple low-level change

[jira] [Updated] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-32678: -- Attachment: image.png image (1).png image (2).png image

[jira] [Comment Edited] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759429#comment-17759429 ] Yang Wang edited comment on FLINK-32678 at 8/28/23 4:04 AM:

[jira] [Commented] (FLINK-32678) Release Testing: Stress-Test to cover multiple low-level changes in Flink

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17759429#comment-17759429 ] Yang Wang commented on FLINK-32678: --- # Functionality Test 1. [SUCCEED] Build the docke

[jira] [Commented] (FLINK-32678) Test FLIP-285 LeaderElection

[ https://issues.apache.org/jira/browse/FLINK-32678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749096#comment-17749096 ] Yang Wang commented on FLINK-32678: --- I believe it is reasonable. I would also keep an

[jira] [Closed] (FLINK-31947) Enable stdout redirect in flink-console.sh

[ https://issues.apache.org/jira/browse/FLINK-31947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-31947. - Resolution: Won't Fix > Enable stdout redirect in flink-console.sh > ---

[jira] [Commented] (FLINK-31947) Enable stdout redirect in flink-console.sh

[ https://issues.apache.org/jira/browse/FLINK-31947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738539#comment-17738539 ] Yang Wang commented on FLINK-31947: --- Already covered by FLINK-31234. > Enable stdout

[jira] [Commented] (FLINK-31234) Add an option to redirect stdout/stderr for flink on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-31234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738537#comment-17738537 ] Yang Wang commented on FLINK-31234: --- Thanks [~huwh] for your contribution. > Add an o

[jira] [Commented] (FLINK-31234) Add an option to redirect stdout/stderr for flink on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-31234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17738532#comment-17738532 ] Yang Wang commented on FLINK-31234: --- Fixed via: master: dfe6bdad0b9493eb35b98ac8326a0

[jira] [Closed] (FLINK-31234) Add an option to redirect stdout/stderr for flink on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-31234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-31234. - Resolution: Fixed > Add an option to redirect stdout/stderr for flink on kubernetes > --

[jira] [Closed] (FLINK-31983) Add yarn acls capability to flink containers

[ https://issues.apache.org/jira/browse/FLINK-31983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-31983. - Resolution: Fixed > Add yarn acls capability to flink containers > -

[jira] [Commented] (FLINK-31983) Add yarn acls capability to flink containers

[ https://issues.apache.org/jira/browse/FLINK-31983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737929#comment-17737929 ] Yang Wang commented on FLINK-31983: --- Fixed via: master: c5acd8dd800dfcd2c8873c569d002

[jira] [Updated] (FLINK-31983) Add yarn acls capability to flink containers

[ https://issues.apache.org/jira/browse/FLINK-31983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-31983: -- Fix Version/s: 1.18.0 > Add yarn acls capability to flink containers > ---

[jira] [Assigned] (FLINK-31983) Add yarn acls capability to flink containers

[ https://issues.apache.org/jira/browse/FLINK-31983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-31983: - Assignee: Archit Goyal > Add yarn acls capability to flink containers > ---

[jira] (FLINK-31673) Add E2E tests for flink jdbc driver

[ https://issues.apache.org/jira/browse/FLINK-31673 ] Yang Wang deleted comment on FLINK-31673: --- was (Author: fly_in_gis): The new introduced e2e test is failing. Could you please have a look?   https://dev.azure.com/apache-flink/98463496-1af2-4

[jira] [Commented] (FLINK-31673) Add E2E tests for flink jdbc driver

[ https://issues.apache.org/jira/browse/FLINK-31673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17737560#comment-17737560 ] Yang Wang commented on FLINK-31673: --- The new introduced e2e test is failing. Could you

[jira] [Commented] (FLINK-31234) Add an option to redirect stdout/stderr for flink on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-31234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17735182#comment-17735182 ] Yang Wang commented on FLINK-31234: --- Given that the YARN/Standalone mode could access

[jira] [Assigned] (FLINK-31234) Add an option to redirect stdout/stderr for flink on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-31234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-31234: - Assignee: Weihua Hu > Add an option to redirect stdout/stderr for flink on kubernetes > ---

[jira] [Updated] (FLINK-28915) Make application mode could support remote DFS schema(e.g. S3, OSS, HDFS, etc.)

[ https://issues.apache.org/jira/browse/FLINK-28915?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-28915: -- Summary: Make application mode could support remote DFS schema(e.g. S3, OSS, HDFS, etc.) (was: Flink

[jira] [Comment Edited] (FLINK-31730) Support Ephemeral Storage in KubernetesConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-31730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710855#comment-17710855 ] Yang Wang edited comment on FLINK-31730 at 4/11/23 9:55 AM:

[jira] [Commented] (FLINK-31730) Support Ephemeral Storage in KubernetesConfigOptions

[ https://issues.apache.org/jira/browse/FLINK-31730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17710855#comment-17710855 ] Yang Wang commented on FLINK-31730: --- Do you think using the pod template to configure

[jira] [Commented] (FLINK-31188) Expose kubernetes scheduler configOption when running flink on kubernetes

[ https://issues.apache.org/jira/browse/FLINK-31188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692454#comment-17692454 ] Yang Wang commented on FLINK-31188: --- This might be a duplicate of FLINK-28825. > Expo

[jira] [Commented] (FLINK-30908) Fatal error in ResourceManager caused YARNSessionFIFOSecuredITCase.testDetachedMode to fail

[ https://issues.apache.org/jira/browse/FLINK-30908?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685045#comment-17685045 ] Yang Wang commented on FLINK-30908: --- +1 for Xintong's analysis and proposal. YARN-599

[jira] [Commented] (FLINK-29671) Kubernetes e2e test fails during test initialization

[ https://issues.apache.org/jira/browse/FLINK-29671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17683325#comment-17683325 ] Yang Wang commented on FLINK-29671: --- It seems that the minikube in the azure pipeline

[jira] [Commented] (FLINK-30813) Residual zk data when using the kubernetes session mode

[ https://issues.apache.org/jira/browse/FLINK-30813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682372#comment-17682372 ] Yang Wang commented on FLINK-30813: --- This might be a duplicate of FLINK-20219. > Resi

[jira] [Commented] (FLINK-30513) HA storage dir leaks on cluster termination

[ https://issues.apache.org/jira/browse/FLINK-30513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675967#comment-17675967 ] Yang Wang commented on FLINK-30513: --- Given that the cluster-id is configured to k8s-ap

[jira] [Assigned] (FLINK-29705) Document the least access with RBAC setting for native K8s integration

[ https://issues.apache.org/jira/browse/FLINK-29705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-29705: - Assignee: ouyangwulin > Document the least access with RBAC setting for native K8s integration

[jira] [Commented] (FLINK-30518) [flink-operator] Kubernetes HA Service not working with standalone mode

[ https://issues.apache.org/jira/browse/FLINK-30518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675907#comment-17675907 ] Yang Wang commented on FLINK-30518: --- Really sorry for the late response. For native K8

[jira] [Commented] (FLINK-30108) ZooKeeperLeaderElectionConnectionHandlingTest.testLoseLeadershipOnLostConnectionIfTolerateSuspendedConnectionsIsEnabled times out

[ https://issues.apache.org/jira/browse/FLINK-30108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1767#comment-1767 ] Yang Wang commented on FLINK-30108: --- It is a little strange that leaderLatch did not r

[jira] [Commented] (FLINK-30540) DataSinkTaskTest failed with a 143 exit code

[ https://issues.apache.org/jira/browse/FLINK-30540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17675408#comment-17675408 ] Yang Wang commented on FLINK-30540: --- [~renqs] Could you please help on this? I think y

[jira] [Commented] (FLINK-30540) DataSinkTaskTest failed with a 143 exit code

[ https://issues.apache.org/jira/browse/FLINK-30540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17674724#comment-17674724 ] Yang Wang commented on FLINK-30540: --- [~mapohl] So do you want me to get the heap dump

[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&focusedCommentId=17649699#comment-17649699 ] Yang Wang commented on FLINK-28554: --- After this PR is merged, it seems that we could n

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

[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-27925: - Assignee: ouyangwulin > Avoid to create watcher without the resourceVersion > -

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

[ https://issues.apache.org/jira/browse/FLINK-27925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17649317#comment-17649317 ] Yang Wang commented on FLINK-27925: --- Thanks [~ouyangwuli] for sharing the investigatio

[jira] [Commented] (FLINK-30184) Save TM/JM thread stack periodically

[ https://issues.apache.org/jira/browse/FLINK-30184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17638310#comment-17638310 ] Yang Wang commented on FLINK-30184: --- I lean towards to make this be done outside of Fl

[jira] [Commented] (FLINK-30036) Force delete pod when k8s node is not ready

[ https://issues.apache.org/jira/browse/FLINK-30036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17635064#comment-17635064 ] Yang Wang commented on FLINK-30036: --- After more investigation, it seems that the termi

[jira] [Commented] (FLINK-30036) Force delete pod when k8s node is not ready

[ https://issues.apache.org/jira/browse/FLINK-30036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17634766#comment-17634766 ] Yang Wang commented on FLINK-30036: --- I prefer to believe the terminating pod should no

[jira] [Comment Edited] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629585#comment-17629585 ] Yang Wang edited comment on FLINK-22262 at 11/7/22 7:25 AM:

[jira] [Commented] (FLINK-14937) Flink WebUI could not display

[ https://issues.apache.org/jira/browse/FLINK-14937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629593#comment-17629593 ] Yang Wang commented on FLINK-14937: --- I am not aware of any issues of Flink webui. Mayb

[jira] [Commented] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629591#comment-17629591 ] Yang Wang commented on FLINK-29315: --- Maybe I could upgrade the kernel version of all t

[jira] [Commented] (FLINK-22262) Flink on Kubernetes ConfigMaps are created without OwnerReference

[ https://issues.apache.org/jira/browse/FLINK-22262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629585#comment-17629585 ] Yang Wang commented on FLINK-22262: --- Thanks [~yunta] for sharing your problem. I think

[jira] [Commented] (FLINK-29871) Upgrade operator Flink version and examples to 1.16

[ https://issues.apache.org/jira/browse/FLINK-29871?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629581#comment-17629581 ] Yang Wang commented on FLINK-29871: --- +1 for using the X.Y.1 in operator for stability.

[jira] [Commented] (FLINK-29892) flink-conf.yaml does not accept hash (#) in the env.java.opts property

[ https://issues.apache.org/jira/browse/FLINK-29892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629577#comment-17629577 ] Yang Wang commented on FLINK-29892: --- This is a known limit for current Flink options p

[jira] [Commented] (FLINK-29898) ClusterEntrypointTest.testCloseAsyncShouldBeExecutedInShutdownHook fails on CI

[ https://issues.apache.org/jira/browse/FLINK-29898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17629575#comment-17629575 ] Yang Wang commented on FLINK-29898: --- >From the current implementation, this issue coul

[jira] [Commented] (FLINK-29539) dnsPolicy in FlinkPod is not overridable

[ https://issues.apache.org/jira/browse/FLINK-29539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625565#comment-17625565 ] Yang Wang commented on FLINK-29539: --- Thanks [~carloscastro] for your contribution. >

[jira] [Closed] (FLINK-29539) dnsPolicy in FlinkPod is not overridable

[ https://issues.apache.org/jira/browse/FLINK-29539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-29539. - Resolution: Fixed Fixed via: master: bb9f2525e6e16d00ef2f0739d9cb96c2e47e35e7 release-1.16: 6325adf40a

[jira] [Updated] (FLINK-29539) dnsPolicy in FlinkPod is not overridable

[ https://issues.apache.org/jira/browse/FLINK-29539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-29539: -- Fix Version/s: 1.17.0 1.15.3 1.16.1 > dnsPolicy in FlinkPod is n

[jira] [Commented] (FLINK-29749) flink info command support dynamic properties

[ https://issues.apache.org/jira/browse/FLINK-29749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625374#comment-17625374 ] Yang Wang commented on FLINK-29749: --- Thanks [~jackylau] for your contribution. > flin

[jira] [Closed] (FLINK-29749) flink info command support dynamic properties

[ https://issues.apache.org/jira/browse/FLINK-29749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang closed FLINK-29749. - Resolution: Fixed Fixed via: master: f8c6a668cd2b887f33a0cf4608de2d6b95c71f03 release-1.16: 38e90428bf

[jira] [Commented] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17625129#comment-17625129 ] Yang Wang commented on FLINK-29315: --- Yes. All the CI machines have the same kernel ver

[jira] [Updated] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-27579: -- Fix Version/s: 1.15.3 > The param client.timeout can not be set by dynamic properties when stopping >

[jira] [Updated] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang updated FLINK-27579: -- Issue Type: Bug (was: Improvement) > The param client.timeout can not be set by dynamic properties wh

[jira] [Commented] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624967#comment-17624967 ] Yang Wang commented on FLINK-29315: --- I have upgrade the kernel version of Alibaba001 t

[jira] [Commented] (FLINK-29315) HDFSTest#testBlobServerRecovery fails on CI

[ https://issues.apache.org/jira/browse/FLINK-29315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624861#comment-17624861 ] Yang Wang commented on FLINK-29315: --- I will have a look on the CI machine Alibaba001 t

[jira] [Assigned] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Wang reassigned FLINK-27579: - Assignee: Yao Zhang > The param client.timeout can not be set by dynamic properties when stoppi

[jira] [Commented] (FLINK-27579) The param client.timeout can not be set by dynamic properties when stopping the job

[ https://issues.apache.org/jira/browse/FLINK-27579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17624827#comment-17624827 ] Yang Wang commented on FLINK-27579: --- When working for FLINK-29749, I realize that this

  1   2   3   4   5   6   7   8   9   10   >