Re: Future of classical remoting in Pekko

2023-09-24 Thread He Pin
All the relatived changes have been merged,Which is mainly for CVEs, and there are some changes relative to performance too. Currently pekko only releases snapshot version, if you decide to contains it in 1.19, will need pekko1.1.0 to release before right? On 2023/09/20 14:29:45 Ferenc Csaky

[VOTE] FLIP-314: Support Customized Job Lineage Listener

2023-09-24 Thread Shammon FY
Hi devs, Thanks for all the feedback on FLIP-314: Support Customized Job Lineage Listener [1] in thread [2]. I would like to start a vote for it. The vote will be opened for at least 72 hours unless there is an objection or insufficient votes. [1] https://cwiki.apache.org/confluence/display/FLIN

Re: FW: RE: [DISCUSS] FLIP-314: Support Customized Job Lineage Listener

2023-09-24 Thread Shammon FY
Hi David, Do you want the detailed topology for Flink job? You can get `JobDetailsInfo` in `RestCusterClient` with the submitted job id, it has `String jsonPlan`. You can parse the json plan to get all steps and relations between them in a Flink job. Hope this can help you, thanks! Best, Shammon

[jira] [Created] (FLINK-33148) Update Web UI to adopt the new "endpoint" field in REST API

2023-09-24 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-33148: - Summary: Update Web UI to adopt the new "endpoint" field in REST API Key: FLINK-33148 URL: https://issues.apache.org/jira/browse/FLINK-33148 Project: Flink

[jira] [Created] (FLINK-33147) Introduce a new "endpoint" field in REST API to represent TaskManager endpoint (host + port) and deprecate the "host" field

2023-09-24 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-33147: - Summary: Introduce a new "endpoint" field in REST API to represent TaskManager endpoint (host + port) and deprecate the "host" field Key: FLINK-33147 URL: https://issues.apache.

[jira] [Created] (FLINK-33146) FLIP-363: Unify the Representation of TaskManager Location in REST API and Web UI

2023-09-24 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-33146: - Summary: FLIP-363: Unify the Representation of TaskManager Location in REST API and Web UI Key: FLINK-33146 URL: https://issues.apache.org/jira/browse/FLINK-33146 P

回复: [DISCUSS] FLIP-367: Support Setting Parallelism for Table/SQL Sources

2023-09-24 Thread Chen Zhanghao
Hi Lincoln, Thanks for the comments. - For concerns #1, I agree that we do not always produce optimal plan for both cases. However, it is difficult to do so and non-trivial complexity is expected. On the other hand, although our proposal generates a sub-optimal plan when the bottleneck is on t

[jira] [Created] (FLINK-33145) Exposes the FileLifeCycleListener interface

2023-09-24 Thread wenhao.yu (Jira)
wenhao.yu created FLINK-33145: - Summary: Exposes the FileLifeCycleListener interface Key: FLINK-33145 URL: https://issues.apache.org/jira/browse/FLINK-33145 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-33144) Deprecate Iteration API in DataStream

2023-09-24 Thread Wencong Liu (Jira)
Wencong Liu created FLINK-33144: --- Summary: Deprecate Iteration API in DataStream Key: FLINK-33144 URL: https://issues.apache.org/jira/browse/FLINK-33144 Project: Flink Issue Type: Technical Deb

[RESULT][VOTE] FLIP-357: Deprecate Iteration API of DataStream

2023-09-24 Thread Wencong Liu
Hi all, Thanks everyone for your review and the votes! I am happy to announce that FLIP-357: Deprecate Iteration API of DataStream [1] has been accepted. There are 4 binding votes and 1 non-binding vote [2]: - Dong Lin (binding) - Jing Ge (binding) - Xintong Song (binding) - Yangze Guo (binding)

[jira] [Created] (FLINK-33143) Wrongly throw error while temporary table join with invalidScan lookup source and selected as view

2023-09-24 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-33143: - Summary: Wrongly throw error while temporary table join with invalidScan lookup source and selected as view Key: FLINK-33143 URL: https://issues.apache.org/jira/browse/FLINK-331

Re: [VOTE] FLIP-327: Support switching from batch to stream mode to improve throughput when processing backlog data

2023-09-24 Thread Xintong Song
+1 (binding) Best, Xintong On Sat, Sep 23, 2023 at 10:16 PM Yuepeng Pan wrote: > +1(non-binding), thank you for driving this proposal. > > Best, > Yuepeng Pan. > At 2023-09-22 14:07:45, "Dong Lin" wrote: > >Hi all, > > > >We would like to start the vote for FLIP-327: Support switching from

[jira] [Created] (FLINK-33141) Promentheus Sink Connector - Amazon Managed Prometheus Request Signer

2023-09-24 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33141: -- Summary: Promentheus Sink Connector - Amazon Managed Prometheus Request Signer Key: FLINK-33141 URL: https://issues.apache.org/jira/browse/FLINK-33141 Project: Fl

[jira] [Created] (FLINK-33142) Prometheus Sink Connector - Update Documentation

2023-09-24 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33142: -- Summary: Prometheus Sink Connector - Update Documentation Key: FLINK-33142 URL: https://issues.apache.org/jira/browse/FLINK-33142 Project: Flink Issue Ty

[jira] [Created] (FLINK-33140) Prometheus Sink Connector - E2E test

2023-09-24 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33140: -- Summary: Prometheus Sink Connector - E2E test Key: FLINK-33140 URL: https://issues.apache.org/jira/browse/FLINK-33140 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33139) Prometheus Sink Connector - Table API support

2023-09-24 Thread Lorenzo Nicora (Jira)
Lorenzo Nicora created FLINK-33139: -- Summary: Prometheus Sink Connector - Table API support Key: FLINK-33139 URL: https://issues.apache.org/jira/browse/FLINK-33139 Project: Flink Issue Type: