[jira] [Created] (FLINK-11988) Remove legacy MockNetworkEnvironment

zhijiang created FLINK-11988: Summary: Remove legacy MockNetworkEnvironment Key: FLINK-11988 URL: https://issues.apache.org/jira/browse/FLINK-11988 Project: Flink Issue Type: Task Compo

Facebook: Save Wilpattu One Srilanka's Most Loved Place

Olá, Eu acabei de assinar o abaixo-assinado "Facebook: Save Wilpattu One Srilanka's Most Loved Place" e queria saber se você pode ajudar assinando também. A nossa meta é conseguir 15.000 assinaturas e precisamos de mais apoio. Você pode ler mais sobre este assunto e assinar o abaixo-assinado aqui

Re: [DISCUSS] Create a Flink ecosystem website

Okay, great. Congxian Qiu, Daryl and I have a kick-off call later today at 2pm CET, 9pm China time about the design of the ecosystem page (see: https://github.com/rmetzger/flink-community-tools/issues/4) Please let me know if others want to join as well, I can add them to the invite. On Wed, Mar

Re: [DISCUSS] Change underlying Frontend Architecture for Flink Web Dashboard

Hey all, Yadong has now opened a pull request with the Angular 7-based web frontend: https://github.com/apache/flink/pull/8016 The PR contains the complete dashboard, and is ready to check out, build and run locally. I believe it would be good to get some more feedback on the PR, from people with

Re: [DISCUSS] FLIP-33: Standardize connector metrics

As I said before, I believe this to be over-engineered and have no interest in this implementation. There are conceptual issues like defining a duplicate numBytesIn(PerSec) metric that already exists for each operator. On 21.03.2019 06:13, Becket Qin wrote: A few updates to the thread. I uplo

[jira] [Created] (FLINK-11989) Enable metric reporter modules in jdk9 runs

Chesnay Schepler created FLINK-11989: Summary: Enable metric reporter modules in jdk9 runs Key: FLINK-11989 URL: https://issues.apache.org/jira/browse/FLINK-11989 Project: Flink Issue Typ

[jira] [Created] (FLINK-11990) Streaming bucketing end-to-end test fail with hadoop 2.8

Yu Li created FLINK-11990: - Summary: Streaming bucketing end-to-end test fail with hadoop 2.8 Key: FLINK-11990 URL: https://issues.apache.org/jira/browse/FLINK-11990 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-11991) Set headers to use for CSV output

Julien Nioche created FLINK-11991: - Summary: Set headers to use for CSV output Key: FLINK-11991 URL: https://issues.apache.org/jira/browse/FLINK-11991 Project: Flink Issue Type: Improvement

Re: Fw: Contributor permission application

Done. On 20.03.2019 16:15, hdxg1101300123 wrote: Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is yutaochina. 2019-03-20 博彦科技股份有限公司 --上海泓智信息科技有限公司 地址：上海市长宁区天山路8号402室 邮编：200336 手机：15501079221 邮箱：hdxg1101300...@163.com

Re: Contributor permission application

Done. On 20.03.2019 23:49, Artsem Semianenka wrote: Hi guys, Could you please give me contributor permissions for Flink project? Here my Jira id: artsem.semianenka Best regards, Artsem

Re: contributor permission apply

Done. On 20.03.2019 15:46, jianl miao wrote: Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is jianlong miao.

[jira] [Created] (FLINK-11992) Update Apache Parquet 1.10.1

Fokko Driesprong created FLINK-11992: Summary: Update Apache Parquet 1.10.1 Key: FLINK-11992 URL: https://issues.apache.org/jira/browse/FLINK-11992 Project: Flink Issue Type: Bug

[CANCEL][VOTE] Release 1.8.0, release candidate #3

Hi, I’m hereby canceling the vote for RC3 of Flink 1.8.0 because of various issues mentioned in the vote thread. Best, Aljoscha Also, I noticed that cross-posting this to u...@flink.apache.org is a bit tricky. It seems that people only responded to the user thre

Re: [DISCUSS] Reorganizing Table-related Jira components some more

Cool, I like this. I have one last suggestion. How about this: Table SQL / API Table SQL / Client Table SQL / Classic Planner (or Legacy Planner): Flink Table SQL runtime and plan translation. Table SQL / Planner: plan-related for new Blink-based Table SQL runner. Table SQL / Runtime: runtime-re

Re: [DISCUSS] Introduction of a Table API Java Expression DSL

Thanks for your feedback Rong and Jark. @Jark: Yes, you are right that the string-based API is used quite a lot. On the other side, the potential user base in the future is still bigger than our current user base. Because the Table API will become equally important as the DataStream API, we re

Re: [DISCUSS] Reorganizing Table-related Jira components some more

Hi everyone, I also tried to summarize the previous discussion and would add an additional `Ecosystem` component. I would suggest: Table SQL / API Table SQL / Client Table SQL / Legacy Planner Table SQL / Planner Table SQL / Runtime Table SQL / Ecosystem (such as table connectors, formats, Hiv

回复：[DISCUSS] Flink Kerberos Improvement

Hi, all! We have met some similar security requirements and did some investigation on security strategies, the third strategy (AM keytab distributed via YARN; AM regenerates delegation tokens for containers.) mentioned in YARN security doc is already used by Spark1.5+ and we quite agree with th

Re: [DISCUSS] Create a Flink ecosystem website

Quick summary of our call: Daryl will soon start with a front end, build against a very simple mock-backend. Congxian will start implementing the Spring-based backend early April. As soon as the first prototype of the UI is ready, we'll share it here for feedback. On Thu, Mar 21, 2019 at 10:08 AM

Re: [REMINDER] Flink Forward San Francisco in a few days

I would like to add that the organizers of the conference have agreed to offer all Apache committers (of any Apache project) a free ticket. *To get your free ticket, use the "ASFCommitters19” promo code AND use your @apache.org email when registering.* Feel free to reach out to

[VOTE] Release 1.8.0, release candidate #4

Hi everyone, Please review and vote on the release candidate 4 for Flink 1.8.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1], * the off

Re: [DISCUSS] Create a Flink ecosystem website

Thanks for the update Robert! Looking forward to the prototype! On Thu, Mar 21, 2019 at 10:07 PM Robert Metzger wrote: > Quick summary of our call: > Daryl will soon start with a front end, build against a very simple > mock-backend. > Congxian will start implementing the Spring-based backend ea

Re: [DISCUSS] Reorganizing Table-related Jira components some more

+1 to Timo's proposal. Timo Walther 于2019年3月21日 周四21:40写道： > Hi everyone, > > I also tried to summarize the previous discussion and would add an > additional `Ecosystem` component. I would suggest: > > Table SQL / API > Table SQL / Client > Table SQL / Legacy Planner > Table SQL / Planner > Table

Re: [DISCUSS] Flink Kerberos Improvement

Hi Tao, Thanks for the comments and suggestions. Yes. I agree that the security improvement should be properly applied on other cluster management systems if designed properly. I am not very familiar with the K8s security setup, but most of the changes we proposal should be generic enough to appl

Re: [DISCUSS] Improvement to Flink Window Operator with Slicing

Hi Devs, Thank you all for the valuable feedbacks and comments in the previous design doc. We have currently created an initial design/work plan based on @Kurt's suggestions as "improvements with the sliding window scenario without changing/adding new public APIs". Please kindly take a look at th

Re: [DISCUSS] Reorganizing Table-related Jira components some more

+1 to Timo's proposal. Best, Jark On Fri, 22 Mar 2019 at 07:42, Kurt Young wrote: > +1 to Timo's proposal. > > Timo Walther 于2019年3月21日 周四21:40写道： > > > Hi everyone, > > > > I also tried to summarize the previous discussion and would add an > > additional `Ecosystem` component. I would suggest:

Re: [DISCUSS] Introduction of a Table API Java Expression DSL

Hi Timo, Sounds good to me. Do you want to deprecate the string-based API in 1.9 or make the decision in 1.10 after some feedbacks ? On Thu, 21 Mar 2019 at 21:32, Timo Walther wrote: > Thanks for your feedback Rong and Jark. > > @Jark: Yes, you are right that the string-based API is used quit

[jira] [Created] (FLINK-11993) Introduce partitionable filesystem sink

Jing Zhang created FLINK-11993: -- Summary: Introduce partitionable filesystem sink Key: FLINK-11993 URL: https://issues.apache.org/jira/browse/FLINK-11993 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-11994) Introduce TableImpl and remove Table in flink-table-planner-blink

Jark Wu created FLINK-11994: --- Summary: Introduce TableImpl and remove Table in flink-table-planner-blink Key: FLINK-11994 URL: https://issues.apache.org/jira/browse/FLINK-11994 Project: Flink Issu