Re: [ANNOUNCE] Two new committers: Xingcan Cui and Nico Kruber

Thanks, everyone! It’s an honor which inspires me to devote more to our community. Regards, Xingcan > On May 10, 2018, at 2:06 AM, Peter Huang wrote: > > Congratulations Nico and Xingcan! > > On Wed, May 9, 2018 at 11:04 AM, Thomas Weise wrote: > >> Congrats! >> >> >> On Wed, May 9, 2018

[Discuss] FLIP-26 - SSL Mutual Authentication

Hello, Given that some SSL enhancement bugs have been posted lately, I took some time to revise FLIP-26 which explores how to harden both external and internal communication. https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=80453255 Some recent related issues: - FLINK-9312 - mutu

[jira] [Created] (FLINK-9327) Support explicit ROW value constructor in Flink SQL

Shuyi Chen created FLINK-9327: - Summary: Support explicit ROW value constructor in Flink SQL Key: FLINK-9327 URL: https://issues.apache.org/jira/browse/FLINK-9327 Project: Flink Issue Type: Sub-t

Flink Memory Usage

Hi, I have Flink running on 2 docker images, one for the job manager, and one for the task manager, with the configuration below. 64GB RAM machine 200 GB SSD used only by RocksDB Flink's memory configuration file is like that: jobmanager.heap.mb: 3072 taskmanager.heap.mb: 53248 taskmanager.mem

[jira] [Created] (FLINK-9326) TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode

Samuel Doyle created FLINK-9326: --- Summary: TaskManagerOptions.NUM_TASK_SLOTS does not work for local/embedded mode Key: FLINK-9326 URL: https://issues.apache.org/jira/browse/FLINK-9326 Project: Flink

Re: [ANNOUNCE] Two new committers: Xingcan Cui and Nico Kruber

Congratulations Nico and Xingcan! On Wed, May 9, 2018 at 11:04 AM, Thomas Weise wrote: > Congrats! > > > On Wed, May 9, 2018 at 10:14 AM, Bowen Li wrote: > > > Congratulations! > > > > On Tue, May 8, 2018 at 11:06 PM, Zhijiang(wangzhijiang999) < > > wangzhijiang...@aliyun.com> wrote: > > > > >

Re: [ANNOUNCE] Two new committers: Xingcan Cui and Nico Kruber

Congrats! On Wed, May 9, 2018 at 10:14 AM, Bowen Li wrote: > Congratulations! > > On Tue, May 8, 2018 at 11:06 PM, Zhijiang(wangzhijiang999) < > wangzhijiang...@aliyun.com> wrote: > > > Congratulations, Xingcan and Nico ! > > Nico is a good PR reviewer and I gained a lot from him. > > :)---

Re: [ANNOUNCE] Two new committers: Xingcan Cui and Nico Kruber

Congratulations! On Tue, May 8, 2018 at 11:06 PM, Zhijiang(wangzhijiang999) < wangzhijiang...@aliyun.com> wrote: > Congratulations, Xingcan and Nico ! > Nico is a good PR reviewer and I gained a lot from him. > :)--发件人：Fabian > Huesk

[jira] [Created] (FLINK-9325) generate the _meta file only when the writing is totally successful

Sihua Zhou created FLINK-9325: - Summary: generate the _meta file only when the writing is totally successful Key: FLINK-9325 URL: https://issues.apache.org/jira/browse/FLINK-9325 Project: Flink

[jira] [Created] (FLINK-9324) SingleLogicalSlot returns completed release future before slot is properly returned

Till Rohrmann created FLINK-9324: Summary: SingleLogicalSlot returns completed release future before slot is properly returned Key: FLINK-9324 URL: https://issues.apache.org/jira/browse/FLINK-9324 Pro

Re: Version Compatibility of Flink-1.4.2 with Zookeeper-3.4.11

There shouldn't be a problem given that they are just different bugfix versions. On 09.05.2018 12:14, Stalin Jeyaraj wrote: Hi, We are using Flink-1.4.2 and its internal dependency is Zookeeper-3.4.5. But already we are using Zookeeper-3.4.11 in our application. So its diffi

Version Compatibility of Flink-1.4.2 with Zookeeper-3.4.11

Hi, We are using Flink-1.4.2 and its internal dependency is Zookeeper-3.4.5. But already we are using Zookeeper-3.4.11 in our application. So its difficult to change the Zookeeper version to 3.4.5. Please confirm us whether the Zookeeper-3.4.11 is compatible with Flink-1.4.2.

[jira] [Created] (FLINK-9323) Move checkstyle configuration

Chesnay Schepler created FLINK-9323: --- Summary: Move checkstyle configuration Key: FLINK-9323 URL: https://issues.apache.org/jira/browse/FLINK-9323 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9322) Add exception throwing map function that simulates failures to the general purpose DataStream job

Tzu-Li (Gordon) Tai created FLINK-9322: -- Summary: Add exception throwing map function that simulates failures to the general purpose DataStream job Key: FLINK-9322 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-9321) Rename SubtasksAllAccumulatorsHandlers

Chesnay Schepler created FLINK-9321: --- Summary: Rename SubtasksAllAccumulatorsHandlers Key: FLINK-9321 URL: https://issues.apache.org/jira/browse/FLINK-9321 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9320) Update `test-ha.sh` end-to-end test to use general purpose DataStream job

Tzu-Li (Gordon) Tai created FLINK-9320: -- Summary: Update `test-ha.sh` end-to-end test to use general purpose DataStream job Key: FLINK-9320 URL: https://issues.apache.org/jira/browse/FLINK-9320 P

[jira] [Created] (FLINK-9319) Move some flink-docs dependencies into profiles

Chesnay Schepler created FLINK-9319: --- Summary: Move some flink-docs dependencies into profiles Key: FLINK-9319 URL: https://issues.apache.org/jira/browse/FLINK-9319 Project: Flink Issue Typ

[jira] [Created] (FLINK-9318) Mark ConfigOptionsDocsCompletenessTest as IT case

Chesnay Schepler created FLINK-9318: --- Summary: Mark ConfigOptionsDocsCompletenessTest as IT case Key: FLINK-9318 URL: https://issues.apache.org/jira/browse/FLINK-9318 Project: Flink Issue T