[jira] [Created] (FLINK-21220) Change the type of cpuCores in ResourceProfile to CPUResource

2021-01-31 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-21220: -- Summary: Change the type of cpuCores in ResourceProfile to CPUResource Key: FLINK-21220 URL: https://issues.apache.org/jira/browse/FLINK-21220 Project: Flink

Re: [VOTE] FLIP-160: Declarative scheduler

2021-01-31 Thread Yangze Guo
+1 (non-binding) Best, Yangze Guo On Sat, Jan 30, 2021 at 8:40 AM Xintong Song wrote: > > +1 (binding) > > Thank you~ > > Xintong Song > > > > On Fri, Jan 29, 2021 at 10:41 PM Robert Metzger wrote: > > > ... and thanks a lot for your work :) I'm

Re: [VOTE] FLIP-159: Reactive Mode

2021-01-27 Thread Yangze Guo
Thanks for driving this, Robert! LGTM. +1 minor: Just a little confused about the program. It seems this proposal relies on the FLIP-160, which is still under discussion. Should we always vote for the prerequisite first? Best, Yangze Guo On Thu, Jan 28, 2021 at 3:27 PM Xintong Song wrote

[jira] [Created] (FLINK-21177) Introduce the counterpart of slotmanager.number-of-slots.max in fine-grained resource management

2021-01-27 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-21177: -- Summary: Introduce the counterpart of slotmanager.number-of-slots.max in fine-grained resource management Key: FLINK-21177 URL: https://issues.apache.org/jira/browse/FLINK-21177

[jira] [Created] (FLINK-21174) Optimize the performance of ResourceAllocationStrategy

2021-01-27 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-21174: -- Summary: Optimize the performance of ResourceAllocationStrategy Key: FLINK-21174 URL: https://issues.apache.org/jira/browse/FLINK-21174 Project: Flink Issue

Re: [DISCUSS] FLIP-160: Declarative scheduler

2021-01-27 Thread Yangze Guo
generated randomly. Thus, it's not guaranteed to be unique across different jobs and different execution. This characteristic is also inherited by the ExecutionVertexID. UUIC, the ParallelismAndResourceAssignments is a job-level concept so it will work well. Best, Yangze Guo On Wed, Jan 27, 2021

Re: [DISCUSS] FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements

2021-01-25 Thread Yangze Guo
** Default operator resource times number of operators. If there are no other issues, I'll update the FLIP accordingly and start a vote thread. Thanks all for the valuable feedback again. Best, Yangze Guo Best, Yangze Guo On Fri, Jan 22, 2021 at 11:30 AM Xintong Song wrote: > > >

Re: [DISCUSS] FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements

2021-01-20 Thread Yangze Guo
@Till Also +1 to treat the SSG resource requirements as a hint instead of a restrict. We can treat it as a follow-up effort and make it clear in JavaDocs at the first step. Best, Yangze Guo On Thu, Jan 21, 2021 at 10:00 AM Xintong Song wrote: > > I think this makes sense. > > The s

[jira] [Created] (FLINK-21047) Expose the correct registered/free resources information in SlotManager

2021-01-19 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-21047: -- Summary: Expose the correct registered/free resources information in SlotManager Key: FLINK-21047 URL: https://issues.apache.org/jira/browse/FLINK-21047 Project: Flink

Re: [DISCUSS] FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements

2021-01-19 Thread Yangze Guo
QL will be transferred to is a black box to the user. We also do not guarantee the cross-version of consistency of the transformation so far. I think it can be treated as a follow-up work when the fine-grained resource management is end-to-end ready. Best, Yangze Guo On Wed, Jan 20, 2021 at 11:16

Re: [ANNOUNCE] Welcome Guowei Ma as a new Apache Flink Committer

2021-01-19 Thread Yangze Guo
Congratulations, Guowei! Well deserved. Best, Yangze Guo On Wed, Jan 20, 2021 at 1:46 PM Xintong Song wrote: > > Congratulations, Guowei~! > > > Thank you~ > > Xintong Song > > > > On Wed, Jan 20, 2021 at 1:42 PM Yuan Mei wrote: > > > Congrats Guowei

Re: [ANNOUNCE] Apache Flink 1.12.1 released

2021-01-19 Thread Yangze Guo
Thanks Xintong for the great work! Best, Yangze Guo On Tue, Jan 19, 2021 at 4:47 PM Till Rohrmann wrote: > > Thanks a lot for driving this release Xintong. This was indeed a release with > some obstacles to overcome and you did it very well! > > Cheers, > Till > > On T

Re: [DISCUSS] Planning Flink 1.13

2021-01-14 Thread Yangze Guo
Thanks for being the release managers, Guowei and Dawid. +1 for the proposed feature freeze date Best, Yangze Guo On Fri, Jan 15, 2021 at 2:01 AM Zhu Zhu wrote: > > +1 for Dawid and Guowei being the release managers and +1 for the proposed > feature freeze date > > Thanks, >

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

2021-01-12 Thread Yangze Guo
Congrats, Danny! Best, Yangze Guo On Tue, Jan 12, 2021 at 5:55 PM Xingbo Huang wrote: > > Congratulations, Danny! > > Best, > Xingbo > > Dian Fu 于2021年1月12日周二 下午5:48写道: > > > Congratulations, Danny! > > > > Regards, > > Dian > > > > &

Re: [DISCUSS] FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements

2021-01-07 Thread Yangze Guo
resource requirements will be converted to Slot-level. - So far, the end-user interfaces for specifying resource requirements are still under discussion. For runtime interfaces, it should only require the minimum set of information needed for resource management. Best, Yangze Guo On Thu,

[DISCUSS] FLIP-156: Runtime Interfaces for Fine-Grained Resource Requirements

2021-01-06 Thread Yangze Guo
ring group. Please find more details in the FLIP wiki document [1]. Looking forward to your feedback. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-156%3A+Runtime+Interfaces+for+Fine-Grained+Resource+Requirements Best, Yangze Guo

[jira] [Created] (FLINK-20865) Prevent potential resource deadlock in fine-grained resource management

2021-01-06 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-20865: -- Summary: Prevent potential resource deadlock in fine-grained resource management Key: FLINK-20865 URL: https://issues.apache.org/jira/browse/FLINK-20865 Project: Flink

[jira] [Created] (FLINK-20864) Apply exact matching rules in fulfilling resource requirement with slot resource

2021-01-06 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-20864: -- Summary: Apply exact matching rules in fulfilling resource requirement with slot resource Key: FLINK-20864 URL: https://issues.apache.org/jira/browse/FLINK-20864 Project

[jira] [Created] (FLINK-20863) Exclude network memory from ResourceProfile

2021-01-06 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-20863: -- Summary: Exclude network memory from ResourceProfile Key: FLINK-20863 URL: https://issues.apache.org/jira/browse/FLINK-20863 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-20838) Implement SlotRequestAdapter for the FineGrainedSlotManager

2021-01-03 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-20838: -- Summary: Implement SlotRequestAdapter for the FineGrainedSlotManager Key: FLINK-20838 URL: https://issues.apache.org/jira/browse/FLINK-20838 Project: Flink

[jira] [Created] (FLINK-20837) Assign an increasing number larger than the numberOfSlot to dynamic slots

2021-01-03 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-20837: -- Summary: Assign an increasing number larger than the numberOfSlot to dynamic slots Key: FLINK-20837 URL: https://issues.apache.org/jira/browse/FLINK-20837 Project: Flink

[jira] [Created] (FLINK-20836) Register TaskManager with total and default slot resource profile in SlotManager

2021-01-03 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-20836: -- Summary: Register TaskManager with total and default slot resource profile in SlotManager Key: FLINK-20836 URL: https://issues.apache.org/jira/browse/FLINK-20836 Project

[jira] [Created] (FLINK-20835) Implement FineGrainedSlotManager

2021-01-03 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-20835: -- Summary: Implement FineGrainedSlotManager Key: FLINK-20835 URL: https://issues.apache.org/jira/browse/FLINK-20835 Project: Flink Issue Type: Sub-task

Re: Insufficient number of network buffers after restarting

2020-12-24 Thread Yangze Guo
can lead to the "insufficient network buffer" as well. Best, Yangze Guo On Fri, Dec 25, 2020 at 12:54 AM Yufei Liu wrote: > > Hey, > I’ve found that job will throw “java.io.IOException: Insufficient number of > network buffers: required 51, but only 1 available” after job

Re: [DISCUSS] Enforce common opinionated coding style using Spotless

2020-12-16 Thread Yangze Guo
+1 Thanks for driving this! Best, Yangze Guo On Thu, Dec 17, 2020 at 2:39 PM Igal Shilman wrote: > > +1 it works really well in StateFun for quite some time. > > On Thursday, December 17, 2020, Wei Zhong wrote: > > > +1 for the coding style automation. Thanks for drivi

Re: [ANNOUNCE] Apache Flink 1.12.0 released

2020-12-11 Thread Yangze Guo
Congratulations to everyone who contributed! Thanks for being our release managers Dian and Robert! Best, Yangze Guo On Fri, Dec 11, 2020 at 3:51 PM Matthias Pohl wrote: > > I agree - thanks for managing the release, Dian & Robert! +1 > > Matthias > > On Fri, Dec 11,

[jira] [Created] (FLINK-20073) Add kerberos setup documentation for native k8s integration

2020-11-10 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-20073: -- Summary: Add kerberos setup documentation for native k8s integration Key: FLINK-20073 URL: https://issues.apache.org/jira/browse/FLINK-20073 Project: Flink

Re: [ANNOUNCE] New Apache Flink Committer - Congxian Qiu

2020-10-28 Thread Yangze Guo
Congratulations! Best, Yangze Guo On Thu, Oct 29, 2020 at 2:31 PM Jark Wu wrote: > > Congrats Congxian! > > Best, > Jark > > On Thu, 29 Oct 2020 at 14:28, Yu Li wrote: > > > Hi all, > > > > On behalf of the PMC, I’m very happy to announce

Re: [ANNOUNCE] New PMC member: Zhu Zhu

2020-10-08 Thread Yangze Guo
Congratulations! Zhu Zhu. Best, Yangze Guo On Fri, Oct 9, 2020 at 12:58 PM Benchao Li wrote: > > Congratulations! > > Zhu Zhu 于2020年10月7日周三 下午8:05写道: > > > Thank you all! It's my great pleasure to work with you to > > continuously improve Flink and grow the co

Re: [DISCUSS][Code-Style] The approach to implement singleton pattern

2020-09-25 Thread Yangze Guo
, please -1. Thanks for all the feedbacks again. Looking forward to your comments! Best, Yangze Guo On Fri, Sep 25, 2020 at 5:50 PM Jingsong Li wrote: > > Hi, thanks for starting this discussion. > > I am +1 for using the private constructor for util class. We don't need to > ch

[DISCUSS][Code-Style] The approach to implement singleton pattern

2020-09-25 Thread Yangze Guo
pattern and append it to the code-style guidelines. We may also have a JIRA ticket to refactor the existing code. What do you think? [1] https://github.com/apache/flink/pull/13416 Best, Yangze Guo

Re: [ANNOUNCE] New Apache Flink Committer - Godfrey He

2020-09-15 Thread Yangze Guo
Congratulations! Xiaoling. Best, Yangze Guo On Wed, Sep 16, 2020 at 12:45 PM Dian Fu wrote: > > Congratulations, well deserved! > > Regards, > Dian > > > 在 2020年9月16日,下午12:36,Guowei Ma 写道: > > > > Congratulations :) > > > > Best, > > Guowe

Re: [ANNOUNCE] New Apache Flink Committer - Yun Tang

2020-09-15 Thread Yangze Guo
Congrats, Yun! Best, Yangze Guo On Tue, Sep 15, 2020 at 6:58 PM Dian Fu wrote: > > Congratulations! Well deserved! > > Regards, > Dian > > > 在 2020年9月15日,下午6:51,Yun Gao 写道: > > > > Congratulations Yun

Re: [ANNOUNCE] New Apache Flink Committer - Arvid Heise

2020-09-14 Thread Yangze Guo
Congrats! Arvid. Best, Yangze Guo On Tue, Sep 15, 2020 at 1:31 PM Congxian Qiu wrote: > > Congratulations Arvid > > Best, > Congxian > > > Benchao Li 于2020年9月15日周二 下午12:52写道: > > > Congratulations! > > > > Zhu Zhu 于2020年9月15日周二 上午11:05写道: > &g

Re: [VOTE] FLIP-141: Intra-Slot Managed Memory Sharing

2020-09-06 Thread Yangze Guo
+1 Best, Yangze Guo On Mon, Sep 7, 2020 at 10:54 AM Zhu Zhu wrote: > > +1 > > Thanks, > Zhu > > Dian Fu 于2020年9月7日周一 上午10:34写道: > > > +1 > > > > > 在 2020年9月3日,下午8:46,Till Rohrmann 写道: > > > > > > Hi Xintong, > > > > &

Re: [DISCUSS] FLIP-141: Intra-Slot Managed Memory Sharing

2020-09-02 Thread Yangze Guo
Thanks for driving this! The newest version LGTM. +1 for this FLIP. Best, Yangze Guo On Thu, Sep 3, 2020 at 2:11 PM Dian Fu wrote: > > Thanks for driving this FLIP, Xintong! +1 to the updated version. > > > 在 2020年9月2日,下午6:09,Xintong Song 写道: > > > > Thanks for the i

Re: Re: [ANNOUNCE] New PMC member: Dian Fu

2020-08-27 Thread Yangze Guo
Congrats Dian! Best, Yangze Guo On Thu, Aug 27, 2020 at 6:26 PM Zhu Zhu wrote: > > Congratulations Dian! > > Thanks, > Zhu > > Zhijiang 于2020年8月27日周四 下午6:04写道: > > > Congrats, Dian! > > > > --

Re: [ANNOUNCE] Apache Flink 1.10.2 released

2020-08-24 Thread Yangze Guo
Thanks a lot for being the release manager Zhu Zhu! Congrats to all others who have contributed to the release! Best, Yangze Guo On Tue, Aug 25, 2020 at 2:42 PM Dian Fu wrote: > > Thanks ZhuZhu for managing this release and everyone else who contributed to > this release! > >

Re: Flink kubernetes autoscale

2020-08-24 Thread Yangze Guo
/flink-docs-release-1.11/ops/deployment/native_kubernetes.html [2] https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/deployment/kubernetes.html [3] https://issues.apache.org/jira/browse/FLINK-10407 Best, Yangze Guo On Mon, Aug 24, 2020 at 6:20 PM Mazen wrote: > > To the best

[jira] [Created] (FLINK-18971) Support to mount kerberos conf as ConfigMap and Keytab as Secrete

2020-08-17 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-18971: -- Summary: Support to mount kerberos conf as ConfigMap and Keytab as Secrete Key: FLINK-18971 URL: https://issues.apache.org/jira/browse/FLINK-18971 Project: Flink

Re: Hi

2020-07-26 Thread Yangze Guo
In 1.11, Flink does no support to run on Windows. The given doc is for release-1.9 as your former email mentioned. Best, Yangze Guo On Mon, Jul 27, 2020 at 11:57 AM Suryanarayana Murthy Maganti wrote: > > Hi Dev & Yangze, > > > C:\Users\xyz>cd softwares > > C:\

Re: Hi

2020-07-26 Thread Yangze Guo
Hi, If you do not run it with Cgwin, you could follow this guide[1]. [1] https://ci.apache.org/projects/flink/flink-docs-release-1.9//getting-started/tutorials/flink_on_windows.html#starting-with-windows-batch-files Best, Yangze Guo On Fri, Jul 24, 2020 at 9:53 PM Suryanarayana Murthy Maganti

Re: Hi

2020-07-23 Thread Yangze Guo
Hi, In order to better analyze this problem, it would be good to provide: - The command and config you start flink. - Logs of JobManager and TaskManager, you could find it in the logs/ directory of your Flink distribution in standalone mode. Best, Yangze Guo On Thu, Jul 23, 2020 at 10:10 PM

Re: Flink Redis connectivity

2020-07-23 Thread Yangze Guo
Do you need to read the state you maintained from Redis? The flink-connector-redis only contains sink operator. Best, Yangze Guo On Thu, Jul 23, 2020 at 3:28 PM Ramya Ramamurthy wrote: > > Hi, > > Thanks for your response. > > I am trying to maintain some state in redis, and

Re: [ANNOUNCE] Apache Flink 1.11.1 released

2020-07-22 Thread Yangze Guo
Congrats! Thanks Dian Fu for being release manager, and everyone involved! Best, Yangze Guo On Wed, Jul 22, 2020 at 3:14 PM Wei Zhong wrote: > > Congratulations! Thanks Dian for the great work! > > Best, > Wei > > > 在 2020年7月22日,15:09,Leonard Xu 写道: > > >

Re: Flink Redis connectivity

2020-07-21 Thread Yangze Guo
Hi, I think you could implement `RichMapFunction` and create `redisClient` in the `open` method. Best, Yangze Guo On Tue, Jul 21, 2020 at 6:43 PM Ramya Ramamurthy wrote: > > Hi, > > As per the understanding we have from the documentation, I guess its not > possible to take the r

Re: subscribe dev mail list

2020-07-20 Thread Yangze Guo
Hi Jake, To subscribe, please send an email to dev-subscr...@flink.apache.org. If you have any questions, you can find more detailed instructions in [1]. [1] https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list Best, Yangze Guo On Tue, Jul 21, 2020 at 2:49 PM Jake wrote

[jira] [Created] (FLINK-18583) The _id field is incorrectly set to index in Elasticsearch6 DynamicTableSink

2020-07-13 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-18583: -- Summary: The _id field is incorrectly set to index in Elasticsearch6 DynamicTableSink Key: FLINK-18583 URL: https://issues.apache.org/jira/browse/FLINK-18583 Project

Re: [ANNOUNCE] Apache Flink 1.11.0 released

2020-07-07 Thread Yangze Guo
Thanks, Zhijiang and Piotr. Congrats to everyone involved! Best, Yangze Guo On Wed, Jul 8, 2020 at 10:19 AM Jark Wu wrote: > > Congratulations! > Thanks Zhijiang and Piotr for the great work as release manager, and thanks > everyone who makes the release possible! > > Best, &g

Re: [ANNOUNCE] New PMC member: Piotr Nowojski

2020-07-06 Thread Yangze Guo
Congratulations! Best, Yangze Guo On Tue, Jul 7, 2020 at 11:01 AM Jiayi Liao wrote: > > Congratulations Piotr! > > Best, > Jiayi Liao > > On Tue, Jul 7, 2020 at 10:54 AM Jark Wu wrote: > > > Congratulations Piotr! > > > > Best, > > Jark >

Re: Hi!

2020-06-24 Thread Yangze Guo
://flink.apache.org/contributing/contribute-code.html Best, Yangze Guo On Wed, Jun 24, 2020 at 5:59 PM 郭海帅 wrote: > > Hi, I want to contribute to Apache Flink. > Would you please give me the permission as a contributor? > My JIRA ID is JJ GUO.

[jira] [Created] (FLINK-18361) Support username and password options for new Elasticsearch connector

2020-06-18 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-18361: -- Summary: Support username and password options for new Elasticsearch connector Key: FLINK-18361 URL: https://issues.apache.org/jira/browse/FLINK-18361 Project: Flink

Re: [Reminder] Prefer {% link %} tag in documentation

2020-06-16 Thread Yangze Guo
I second Jark's comment. We need a CI mechanism to ensure this. Best, Yangze Guo On Wed, Jun 17, 2020 at 11:45 AM Jark Wu wrote: > > Hi everyone, > > Before going to use {% link %} and adding a CI to force using link tag, I > suggest adding a CI profile to check broken

Re: [ANNOUNCE] Yu Li is now part of the Flink PMC

2020-06-16 Thread Yangze Guo
Congrats, Yu! Best, Yangze Guo On Wed, Jun 17, 2020 at 9:35 AM Xintong Song wrote: > > Congratulations Yu, well deserved~! > > Thank you~ > > Xintong Song > > > > On Wed, Jun 17, 2020 at 9:15 AM jincheng sun wrote: >> >> Hi all, >> >> On beh

[jira] [Created] (FLINK-18267) Missing NOTICE file in flink-examples-streaming

2020-06-11 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-18267: -- Summary: Missing NOTICE file in flink-examples-streaming Key: FLINK-18267 URL: https://issues.apache.org/jira/browse/FLINK-18267 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-18264) Translate the "External Resource Framework" page into Chinese

2020-06-11 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-18264: -- Summary: Translate the "External Resource Framework" page into Chinese Key: FLINK-18264 URL: https://issues.apache.org/jira/browse/FLINK-18264 Proj

Re: [Reminder] Prefer {% link %} tag in documentation

2020-06-09 Thread Yangze Guo
Thanks for that reminder, Seth! +1 to add a check during CI if possible. Best, Yangze Guo On Wed, Jun 10, 2020 at 3:04 AM Kostas Kloudas wrote: > > Thanks for the heads up Seth! > > Kostas > > On Tue, Jun 9, 2020 at 7:27 PM Seth Wiesman wrote: > > > > The tag

[jira] [Created] (FLINK-18205) Mitigate the use of reflection in HadoopModule

2020-06-09 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-18205: -- Summary: Mitigate the use of reflection in HadoopModule Key: FLINK-18205 URL: https://issues.apache.org/jira/browse/FLINK-18205 Project: Flink Issue Type

Re: [ANNOUNCE] New Flink Committer: Benchao Li

2020-06-08 Thread Yangze Guo
Congratulations! Best, Yangze Guo On Tue, Jun 9, 2020 at 2:32 PM Dian Fu wrote: > > Congrats Benchao! > > Regards, > Dian > > > 在 2020年6月9日,下午2:30,Xintong Song 写道: > > > > Congratulations, Benchao~! > > > > Thank you~ > > > > Xintong

Re: [ANNOUNCE] New Apache Flink Committer - Xintong Song

2020-06-04 Thread Yangze Guo
Congrats, Xintong! Best, Yangze Guo On Fri, Jun 5, 2020 at 12:48 PM Benchao Li wrote: > > Congratulations Xintong, well deserved! > > Becket Qin 于2020年6月5日周五 下午12:45写道: > > > Hi all, > > > > On behalf of the PMC, I’m very happy to announce Xintong

Re: [Discussion] flink elasticsearch connector supports

2020-06-03 Thread Yangze Guo
tests (performance and correctness) to address Robert's comments. [1] https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals [2] https://cwiki.apache.org/confluence/display/FLINK/FLIP+Template Best, Yangze Guo On Wed, Jun 3, 2020 at 9:41 AM Jacky Lau wrote: > > H

[jira] [Created] (FLINK-18109) Manually test external resource framework with GPUDriver

2020-06-03 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-18109: -- Summary: Manually test external resource framework with GPUDriver Key: FLINK-18109 URL: https://issues.apache.org/jira/browse/FLINK-18109 Project: Flink Issue

[jira] [Created] (FLINK-18081) Fix broken links in "Kerberos Authentication Setup and Configuration" doc

2020-06-02 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-18081: -- Summary: Fix broken links in "Kerberos Authentication Setup and Configuration" doc Key: FLINK-18081 URL: https://issues.apache.org/jira/browse/FLINK-18081 Proj

[jira] [Created] (FLINK-18080) Translate the "Kerberos Authentication Setup and Configuration" page into Chinese

2020-06-02 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-18080: -- Summary: Translate the "Kerberos Authentication Setup and Configuration" page into Chinese Key: FLINK-18080 URL: https://issues.apache.org/jira/browse/F

Re: I want to contribute to Apache Flink

2020-06-01 Thread Yangze Guo
://flink.apache.org/contributing/contribute-code.html Best, Yangze Guo On Mon, Jun 1, 2020 at 5:06 PM 以梦为马 wrote: > > Hi Guys, > > I want to contribute to Apache Flink. > Would you please give me the permission as a contributor? > My JIRA ID is pony712.

[jira] [Created] (FLINK-18018) Bundle GPU plugin in "plugins/" directory

2020-05-28 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-18018: -- Summary: Bundle GPU plugin in "plugins/" directory Key: FLINK-18018 URL: https://issues.apache.org/jira/browse/FLINK-18018 Project: Flink

[jira] [Created] (FLINK-17917) ResourceInformationReflector#getExternalResources should ignore the external resource with a value of 0

2020-05-24 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17917: -- Summary: ResourceInformationReflector#getExternalResources should ignore the external resource with a value of 0 Key: FLINK-17917 URL: https://issues.apache.org/jira/browse/FLINK

Re: [DISCUSS] Semantics of our JIRA fields

2020-05-22 Thread Yangze Guo
Thanks for driving this discussion, Robert. +1 for the proposal. Best, Yangze Guo On Fri, May 22, 2020 at 3:32 PM Robert Metzger wrote: > > Thanks for your response! > > The information about supported Flink releases is quite hidden, but it is > on the downloads page in the &qu

[jira] [Created] (FLINK-17862) The internal class StreamingRuntimeContext is leaked in AbstractUdfStreamOperator

2020-05-21 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17862: -- Summary: The internal class StreamingRuntimeContext is leaked in AbstractUdfStreamOperator Key: FLINK-17862 URL: https://issues.apache.org/jira/browse/FLINK-17862

[jira] [Created] (FLINK-17795) Add an example to show how to leverage GPU resources

2020-05-18 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17795: -- Summary: Add an example to show how to leverage GPU resources Key: FLINK-17795 URL: https://issues.apache.org/jira/browse/FLINK-17795 Project: Flink Issue Type

Re: [ANNOUNCE] Apache Flink 1.10.1 released

2020-05-17 Thread Yangze Guo
Thanks Yu for the great job. Congrats everyone who made this release possible. Best, Yangze Guo On Mon, May 18, 2020 at 10:57 AM Leonard Xu wrote: > > > Thanks Yu for being the release manager, and everyone else who made this > possible. > > Best, > Leonard Xu > > 在 2

Re: [VOTE] Guarantee that @PublicEvolving classes are API and binary compatible across bug fix releases (x.y.u and x.y.v)

2020-05-15 Thread Yangze Guo
+1 Best, Yangze Guo On Sat, May 16, 2020 at 12:26 AM Yuan Mei wrote: > > +1 > > On Sat, May 16, 2020 at 12:21 AM Ufuk Celebi wrote: > > > +1 > > > > – Ufuk > > > > > > On Fri, May 15, 2020 at 4:54 PM Zhijiang > .invalid> > > wro

Re: Would you please give me the permission as a contributor

2020-05-08 Thread Yangze Guo
://flink.apache.org/contributing/contribute-code.html Best, Yangze Guo On Sat, May 9, 2020 at 10:16 AM 天地任我游 <770236...@qq.com> wrote: > > Hi Guys, I want to contribute to Apache Flink. Would you please give me the > permission as a contributor? My JIRA ID is limaowei66.

[jira] [Created] (FLINK-17579) Set the resource id of taskexecutor from environment variable if possible in standalone mode

2020-05-08 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17579: -- Summary: Set the resource id of taskexecutor from environment variable if possible in standalone mode Key: FLINK-17579 URL: https://issues.apache.org/jira/browse/FLINK-17579

[jira] [Created] (FLINK-17574) Deduplicate the process execution logic in Flink

2020-05-08 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17574: -- Summary: Deduplicate the process execution logic in Flink Key: FLINK-17574 URL: https://issues.apache.org/jira/browse/FLINK-17574 Project: Flink Issue Type

[jira] [Created] (FLINK-17540) Adding tests/tools checking the pattern of new configuration options following the xyz.max/min pattern

2020-05-05 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17540: -- Summary: Adding tests/tools checking the pattern of new configuration options following the xyz.max/min pattern Key: FLINK-17540 URL: https://issues.apache.org/jira/browse/FLINK

[jira] [Created] (FLINK-17539) Migrate the configuration options which do not follow the xyz.max/min pattern.

2020-05-05 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17539: -- Summary: Migrate the configuration options which do not follow the xyz.max/min pattern. Key: FLINK-17539 URL: https://issues.apache.org/jira/browse/FLINK-17539 Project

[jira] [Created] (FLINK-17536) Change the config option of max limitation to "slotmanager.number-of-slots.max"

2020-05-05 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17536: -- Summary: Change the config option of max limitation to "slotmanager.number-of-slots.max" Key: FLINK-17536 URL: https://issues.apache.org/jira/browse/FLINK-17536

[jira] [Created] (FLINK-17535) Treat min/max as part of the hierarchy of config option

2020-05-05 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17535: -- Summary: Treat min/max as part of the hierarchy of config option Key: FLINK-17535 URL: https://issues.apache.org/jira/browse/FLINK-17535 Project: Flink Issue

Re: [DISCUSS] Send issue and pull request notifications for flink-web and flink-shaded to iss...@flink.apache.org

2020-05-04 Thread Yangze Guo
+1 Best, Yangze Guo On Tue, May 5, 2020 at 6:14 AM Thomas Weise wrote: > > +1 > > > On Mon, May 4, 2020 at 10:02 AM Marta Paes Moreira > wrote: > > > +1, this is quite annoying and distracting. > > > > Marta > > > > On Mon, May 4, 2020 at

[RESULT][VOTE] FLIP-108: edit the Public API

2020-05-04 Thread Yangze Guo
epted. I'll update the FLIP doc accordingly. [1] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/quot-VOTE-FLIP-108-edit-the-Public-API-quot-td40995.html Best, Yangze Guo

Re: [VOTE] Release 1.10.1, release candidate #2

2020-05-02 Thread Yangze Guo
+1 (non-binding) - Building from source with all tests passed - Build a custom image with 1.10.1-rc2 - Deploy a native session cluster on K8s and submit multiple jobs - Deploy a session cluster on Yarn and submit multiple jobs - Submit WordCount on Yarn in per-job mode. Best, Yangze Guo On Fri

"[VOTE] FLIP-108: edit the Public API"

2020-04-30 Thread Yangze Guo
rding-the-class-loader-and-dependency-td40893.html Best, Yangze Guo

Re: [DISCUSS][FLIP-108] Problems regarding the class loader and dependency

2020-04-30 Thread Yangze Guo
es" itself might limit the flexibility. Best, Yangze Guo On Thu, Apr 30, 2020 at 7:41 PM Aljoscha Krettek wrote: > > I agree with Till and Xintong, if the ExternalResourceInfo is only a > holder of properties that doesn't have any sublasses it can just become > the "pr

Re: [DISCUSS][FLIP-108] Problems regarding the class loader and dependency

2020-04-29 Thread Yangze Guo
ache/flink/streaming/examples/wordcount/WordCount.java Best, Yangze Guo On Wed, Apr 29, 2020 at 3:25 PM Xintong Song wrote: > > > > > Will she ask for some properties and then pass them to another component? > > Yes. Take GPU as an example, the property needed is "GPU index&qu

[DISCUSS][FLIP-108] Problems regarding the class loader and dependency

2020-04-28 Thread Yangze Guo
/FLIP-108%3A+Add+GPU+support+in+Flink [2] https://ci.apache.org/projects/flink/flink-docs-master/ops/plugins.html Best, Yangze Guo

Re: [DISCUSS] Should max/min be part of the hierarchy of config option?

2020-04-28 Thread Yangze Guo
ion in the next 72 hours, I'd like to open JIRA tickets addressing the above consensus. Best, Yangze Guo On Mon, Apr 27, 2020 at 9:52 PM Jark Wu wrote: > > +1 for xyz.[min|max] > > This is already mentioned in the Code Style Guideline [1]. > > Best, > Jark > > >

[jira] [Created] (FLINK-17408) Introduce GPUDriver

2020-04-27 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17408: -- Summary: Introduce GPUDriver Key: FLINK-17408 URL: https://issues.apache.org/jira/browse/FLINK-17408 Project: Flink Issue Type: Sub-task Components

[jira] [Created] (FLINK-17407) Introduce external resource framework.

2020-04-27 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17407: -- Summary: Introduce external resource framework. Key: FLINK-17407 URL: https://issues.apache.org/jira/browse/FLINK-17407 Project: Flink Issue Type: Sub-task

[RESULT][VOTE] FLIP-108: Add GPU support in Flink

2020-04-27 Thread Yangze Guo
votes. Thus, FLIP-108 has been accepted. Thanks everyone for joining the discussion and giving feedback! [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-108%3A+Add+GPU+support+in+Flink Best, Yangze Guo

Re: [DISCUSS] Exact feature freeze date

2020-04-23 Thread Yangze Guo
+1 Best, Yangze Guo On Fri, Apr 24, 2020 at 9:49 AM Dian Fu wrote: > > +1 > > Regards, > Dian > > > 在 2020年4月24日,上午9:47,Leonard Xu 写道: > > > > + 1 for the feature freeze date > > > > Best, > > Leonard Xu > > > > &g

[jira] [Created] (FLINK-17331) Add NettyMessageContent interface for all the class which could be write to NettyMessage

2020-04-22 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17331: -- Summary: Add NettyMessageContent interface for all the class which could be write to NettyMessage Key: FLINK-17331 URL: https://issues.apache.org/jira/browse/FLINK-17331

[DISCUSS] Should max/min be part of the hierarchy of config option?

2020-04-21 Thread Yangze Guo
[3] https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/config.html Best, Yangze Guo

[jira] [Created] (FLINK-17300) Log the lineage information between ExecutionAttemptID and AllocationID

2020-04-21 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17300: -- Summary: Log the lineage information between ExecutionAttemptID and AllocationID Key: FLINK-17300 URL: https://issues.apache.org/jira/browse/FLINK-17300 Project: Flink

[jira] [Created] (FLINK-17297) Log the lineage information between ExecutionAttemptID and SlotRequestID

2020-04-21 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17297: -- Summary: Log the lineage information between ExecutionAttemptID and SlotRequestID Key: FLINK-17297 URL: https://issues.apache.org/jira/browse/FLINK-17297 Project: Flink

[jira] [Created] (FLINK-17298) Log the lineage information between ExecutionAttemptID and SlotRequestID

2020-04-21 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17298: -- Summary: Log the lineage information between ExecutionAttemptID and SlotRequestID Key: FLINK-17298 URL: https://issues.apache.org/jira/browse/FLINK-17298 Project: Flink

[jira] [Created] (FLINK-17295) Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber

2020-04-21 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17295: -- Summary: Refactor the ExecutionAttemptID to consist of ExecutionVertexID and attemptNumber Key: FLINK-17295 URL: https://issues.apache.org/jira/browse/FLINK-17295

[RESULT][VOTE] FLIP-118: Improve Flink's ID System

2020-04-21 Thread Yangze Guo
e for joining the discussion and giving feedback! [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=148643521 Best, Yangze Guo

[jira] [Created] (FLINK-17216) Allow user to provide credential provider to Elasticsearch rest client.

2020-04-17 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17216: -- Summary: Allow user to provide credential provider to Elasticsearch rest client. Key: FLINK-17216 URL: https://issues.apache.org/jira/browse/FLINK-17216 Project: Flink

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

2020-04-17 Thread Yangze Guo
Congratulations! Best, Yangze Guo On Fri, Apr 17, 2020 at 3:19 PM Jeff Zhang wrote: > > Congratulations, Hequn! > > Paul Lam 于2020年4月17日周五 下午3:02写道: > > > Congrats Hequn! Thanks a lot for your contribution to the community! > > > > Best, > > Paul Lam

<    1   2   3   4   >