Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-07-02 Thread via GitHub
davidradl commented on code in PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#discussion_r2179921531 ## docs/layouts/shortcodes/generated/kubernetes_operator_config_configuration.html: ## @@ -152,6 +152,12 @@ Duration The ti

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-07-02 Thread via GitHub
davidradl commented on code in PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#discussion_r2179916851 ## docs/layouts/shortcodes/generated/kubernetes_operator_config_configuration.html: ## @@ -152,6 +152,12 @@ Duration The ti

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-07-02 Thread via GitHub
davidradl commented on code in PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#discussion_r2179916851 ## docs/layouts/shortcodes/generated/kubernetes_operator_config_configuration.html: ## @@ -152,6 +152,12 @@ Duration The ti

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-06-10 Thread via GitHub
chenyuzhi459 commented on PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#issuecomment-2958555002 I have changed the default value of new param `flink.client.io.threads` to 10. -- This is an automated message from the Apache Git Service. To respond to the messa

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-05-29 Thread via GitHub
chenyuzhi459 commented on PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#issuecomment-2921169602 Because `flink.client.io.threads=60` specifies the number of EventExecutors that handle event in NioEventLoopGroup, when creating NioEventLoopGroup, a corresponding

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-05-25 Thread via GitHub
gyfora commented on PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#issuecomment-2908716749 Why does `flink.client.io.threads=60` affect how many threads are created in the tests? Wouldn't threads be created lazily? -- This is an automated message from the Apac

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-05-23 Thread via GitHub
chenyuzhi459 commented on PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#issuecomment-2904106838 I think the default value of `flink.client.io.threads=60` new parameter is too big in the test environment, because multiple FlinkResourceContextFactory and flinkC

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-05-23 Thread via GitHub
chenyuzhi459 commented on PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#issuecomment-2904094832 I have reproduced the `Too many open files` issue of CI at local compile env, I will resolved it as soon as possible -- This is an automated message from the Apac

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-05-23 Thread via GitHub
gaborgsomogyi commented on PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#issuecomment-2903599779 This feature looks promising. Can you plz answer because we're intended to do a release soon? -- This is an automated message from the Apache Git Service. To resp

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-05-22 Thread via GitHub
gyfora commented on PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#issuecomment-2900402656 Seems to be consistently broken, did you manage to build/test locally? -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-05-21 Thread via GitHub
chenyuzhi459 commented on PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#issuecomment-2899712189 Could you help take a look at the latest CI failure issue, which doesn't seem to be related to this code commit? -- This is an automated message from the Apache Gi

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-05-21 Thread via GitHub
chenyuzhi459 commented on code in PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#discussion_r2099912200 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/RestClientProxy.java: ## @@ -0,0 +1,110 @@ +/* + * License

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-05-11 Thread via GitHub
gyfora commented on code in PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#discussion_r2083854374 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/service/RestClientProxy.java: ## @@ -0,0 +1,110 @@ +/* + * Licensed to t

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-05-11 Thread via GitHub
chenyuzhi459 commented on PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#issuecomment-2870721397 Is there any other problem with this pr? I don't know why CI check was cancelled @gyfora -- This is an automated message from the Apache Git Service. To re

Re: [PR] [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-04-29 Thread via GitHub
chenyuzhi459 commented on PR #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956#issuecomment-2837981756 It depends on when will the pr https://github.com/apache/flink/pull/25788 could be merged. If necessary, I can submit the pr fix in both 1.20 and 2.x versions

[PR] Draft PR [FLINK-36876] Add proxy for restClient [flink-kubernetes-operator]

2025-03-15 Thread via GitHub
chenyuzhi459 opened a new pull request, #956: URL: https://github.com/apache/flink-kubernetes-operator/pull/956 ## What is the purpose of the change Add proxy for restClient, which supports to use shared `EventLoopGroup` ## Brief change log - *Introduce a new