[GitHub] [flink-kubernetes-operator] kingsathurthi commented on pull request #552: Fixing the container vulnerability by updating maven dependency

2023-04-09 Thread via GitHub
kingsathurthi commented on PR #552: URL: https://github.com/apache/flink-kubernetes-operator/pull/552#issuecomment-1501393713 Hi Yang, I'm still active on this is issue, please allow me some time to close this. -- This is an automated message from the Apache Git Service. To respond to

[jira] [Updated] (FLINK-31374) ProxyStreamPartitioner should implement ConfigurableStreamPartitioner

2023-04-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31374: --- Labels: pull-request-available (was: ) > ProxyStreamPartitioner should implement

[GitHub] [flink-ml] jiangxin369 opened a new pull request, #231: [FLINK-31374] ProxyStreamPartitioner should implement ConfigurableStreamPartitioner

2023-04-09 Thread via GitHub
jiangxin369 opened a new pull request, #231: URL: https://github.com/apache/flink-ml/pull/231 ## What is the purpose of the change Make the ProxyStreamPartitioner implement ConfigurableStreamPartitioner. Otherwise, the KeyGroupRange that is computed in

[GitHub] [flink-kubernetes-operator] yangjf2019 commented on pull request #552: Fixing the container vulnerability by updating maven dependency

2023-04-09 Thread via GitHub
yangjf2019 commented on PR #552: URL: https://github.com/apache/flink-kubernetes-operator/pull/552#issuecomment-1501357652 Hi @kingsathurthi , sorry to bother you! If you are no longer following up, please close this issue and I will take over the management of it. -- This is an

[jira] [Assigned] (FLINK-31344) Support to update nested columns in update statement

2023-04-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-31344: Assignee: Aitozi (was: luoyuxia) > Support to update nested columns in update statement >

[jira] [Assigned] (FLINK-31344) Support to update nested columns in update statement

2023-04-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] luoyuxia reassigned FLINK-31344: Assignee: luoyuxia > Support to update nested columns in update statement >

[jira] [Commented] (FLINK-31344) Support to update nested columns in update statement

2023-04-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710023#comment-17710023 ] Aitozi commented on FLINK-31344: Thanks for your reply. Totally agree with you. I have basically

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-09 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710022#comment-17710022 ] RocMarshal commented on FLINK-31757: [~Weijie Guo] Glad to get your attention and reminding~:) I'll

[jira] [Commented] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-09 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710021#comment-17710021 ] Weijie Guo commented on FLINK-31757: Hi [~RocMarshal], Can you add more details to this ticket? I

[jira] [Updated] (FLINK-31757) Optimize Flink un-balanced tasks scheduling

2023-04-09 Thread RocMarshal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] RocMarshal updated FLINK-31757: --- Summary: Optimize Flink un-balanced tasks scheduling (was: Optimize Flink tasks un-balanced

[jira] [Created] (FLINK-31757) Optimize Flink tasks un-balanced scheduling

2023-04-09 Thread RocMarshal (Jira)
RocMarshal created FLINK-31757: -- Summary: Optimize Flink tasks un-balanced scheduling Key: FLINK-31757 URL: https://issues.apache.org/jira/browse/FLINK-31757 Project: Flink Issue Type:

[jira] [Commented] (FLINK-31686) Filesystem connector should replace the shallow copy with deep copy

2023-04-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710020#comment-17710020 ] luoyuxia commented on FLINK-31686: -- +1 for adding a new api. +1 for public discussion. > Filesystem

[jira] [Commented] (FLINK-31344) Support to update nested columns in update statement

2023-04-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710011#comment-17710011 ] luoyuxia commented on FLINK-31344: -- [~aitozi] I think it's fine to make SqlParser to accept the

[jira] (FLINK-31344) Support to update nested columns in update statement

2023-04-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31344 ] luoyuxia deleted comment on FLINK-31344: -- was (Author: luoyuxia): [~aitozi] Why need to modify the iinterface SupportsRowLevelUpdate? > Support to update nested columns in update statement >

[jira] [Commented] (FLINK-31344) Support to update nested columns in update statement

2023-04-09 Thread luoyuxia (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17710009#comment-17710009 ] luoyuxia commented on FLINK-31344: -- [~aitozi] Why need to modify the iinterface SupportsRowLevelUpdate?

[GitHub] [flink] flinkbot commented on pull request #22371: [FLINK-28171] [flink-kubernates] enable add appProtocol via the configuration and verify it is not overridden by Default port defintion

2023-04-09 Thread via GitHub
flinkbot commented on PR #22371: URL: https://github.com/apache/flink/pull/22371#issuecomment-1501130037 ## CI report: * 60aac8039125ce954c91b63f578ea35467e7a054 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-28171) Adjust Job and Task manager port definitions to work with Istio+mTLS

2023-04-09 Thread Sigalit Aliazov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709974#comment-17709974 ] Sigalit Aliazov commented on FLINK-28171: - hello, [~wangyang0918]  and [~martijnvisser] we

[GitHub] [flink] sigalite opened a new pull request, #22371: [FLINK-28171] [flink-kubernates] enable add appProtocol via the configuration and verify it is not overridden by Default port defintion

2023-04-09 Thread via GitHub
sigalite opened a new pull request, #22371: URL: https://github.com/apache/flink/pull/22371 ## What is the purpose of the change enable the job manager and task manager communicate in a Kubernetes cluster with Istio and mTLS enabled. ## Brief change log Add the

[jira] [Commented] (FLINK-31344) Support to update nested columns in update statement

2023-04-09 Thread Aitozi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17709961#comment-17709961 ] Aitozi commented on FLINK-31344: Hi [~luoyuxia], when solving the FLINK-31301 I notice this ticket.