Flink Kafka Issues

Hi, We are facing a serious production issue with Flink. Any help would be appreciated. We receive packets from a Kafka Cluster - This cluster has a sudden drop in the packets from 22:00 UTC till 00:30 UTC everyday [on a specific topic, say "topic A"]. Though our job reads from a different topic

[ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Hi all, I'm excited to announce that Jiangjie (Becket) Qin just became a Flink committer! Congratulations Becket! Best, Robert (on behalf of the Flink PMC)

Re: subscribe flink dev mail list

Hi, To subscribe to the dev mailing list you have to send an email to dev-subscr...@flink.apache.org Aljoscha > On 18. Jul 2019, at 10:58, venn wrote: > > I'am glad to subscribe the dev mail list >

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Well deserved. Best Yun Tang From: Robert Metzger Sent: Thursday, July 18, 2019 15:41 To: dev Subject: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project Hi all, I'm excited to announce that Jiangjie (Be

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Best, tison. Yun Tang 于2019年7月18日周四 下午3:53写道： > Congratulations Becket! Well deserved. > > Best > Yun Tang > > From: Robert Metzger > Sent: Thursday, July 18, 2019 15:41 > To: dev > Subject: [ANNOUNCE] Jiangjie (Becket) Qin has been ad

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats Becket! Best, Paul Lam > 在 2019年7月18日，15:41，Robert Metzger 写道： > > Hi all, > > I'm excited to announce that Jiangjie (Becket) Qin just became a Flink > committer! > > Congratulations Becket! > > Best, > Robert (on behalf of the Flink PMC)

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Well deserved. Cheers, Jark On Thu, 18 Jul 2019 at 15:56, Paul Lam wrote: > Congrats Becket! > > Best, > Paul Lam > > > 在 2019年7月18日，15:41，Robert Metzger 写道： > > > > Hi all, > > > > I'm excited to announce that Jiangjie (Becket) Qin just became a Flink > > committer! >

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Well deserved. Best, Congxian Jark Wu 于2019年7月18日周四 下午4:03写道： > Congratulations Becket! Well deserved. > > Cheers, > Jark > > On Thu, 18 Jul 2019 at 15:56, Paul Lam wrote: > > > Congrats Becket! > > > > Best, > > Paul Lam > > > > > 在 2019年7月18日，15:41，Robert Metzger 写道

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Best, Jingsong Lee -- From:Congxian Qiu Send Time:2019年7月18日(星期四) 16:09 To:dev@flink.apache.org Subject:Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project Congratulat

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats Becket! Best, Kurt On Thu, Jul 18, 2019 at 4:12 PM JingsongLee wrote: > Congratulations Becket! > > Best, Jingsong Lee > > > -- > From:Congxian Qiu > Send Time:2019年7月18日(星期四) 16:09 > To:dev@flink.apache.org > Subject:R

[jira] [Created] (FLINK-13316) Update NOTICE-binary

Chesnay Schepler created FLINK-13316: Summary: Update NOTICE-binary Key: FLINK-13316 URL: https://issues.apache.org/jira/browse/FLINK-13316 Project: Flink Issue Type: Improvement

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Thank you~ Xintong Song On Thu, Jul 18, 2019 at 4:20 PM Kurt Young wrote: > Congrats Becket! > > Best, > Kurt > > > On Thu, Jul 18, 2019 at 4:12 PM JingsongLee .invalid> > wrote: > > > Congratulations Becket! > > > > Best, Jingsong Lee > > > > > > ---

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Xintong Song 于2019年7月18日周四 下午4:33写道： > Congratulations Becket! > > Thank you~ > > Xintong Song > > > > On Thu, Jul 18, 2019 at 4:20 PM Kurt Young wrote: > > > Congrats Becket! > > > > Best, > > Kurt > > > > > > On Thu, Jul 18, 2019 at 4:12 PM JingsongLee > .invalid> > >

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats Becket! Best, Zhijiang -- From:Zhu Zhu Send Time:2019年7月18日(星期四) 16:35 To:dev Subject:Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project Congratulations Becket! Xintong Song 于2019年7月

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Well deserved. Cheers, forward Kurt Young 于2019年7月18日周四 下午4:20写道： > Congrats Becket! > > Best, > Kurt > > > On Thu, Jul 18, 2019 at 4:12 PM JingsongLee .invalid> > wrote: > > > Congratulations Becket! > > > > Best, Jingsong Lee > > > > > >

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Xu Forward 于2019年7月18日周四 下午4:39写道： > Congratulations Becket! Well deserved. > > > Cheers, > > forward > > Kurt Young 于2019年7月18日周四 下午4:20写道： > > > Congrats Becket! > > > > Best, > > Kurt > > > > > > On Thu, Jul 18, 2019 at 4:12 PM JingsongLee > .invalid> > > wrote: > >

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats Becket! On Thu, Jul 18, 2019 at 10:52 AM Jeff Zhang wrote: > Congratulations Becket! > > Xu Forward 于2019年7月18日周四 下午4:39写道： > > > Congratulations Becket! Well deserved. > > > > > > Cheers, > > > > forward > > > > Kurt Young 于2019年7月18日周四 下午4:20写道： > > > > > Congrats Becket! > > > > >

[jira] [Created] (FLINK-13317) Merge NetUtils and ClientUtils

Charles Xu created FLINK-13317: -- Summary: Merge NetUtils and ClientUtils Key: FLINK-13317 URL: https://issues.apache.org/jira/browse/FLINK-13317 Project: Flink Issue Type: Improvement

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Good to have you onboard! On 18/07/2019 10:56, Till Rohrmann wrote: > Congrats Becket! > > On Thu, Jul 18, 2019 at 10:52 AM Jeff Zhang wrote: > >> Congratulations Becket! >> >> Xu Forward 于2019年7月18日周四 下午4:39写道： >> >>> Congratulations Becket! Well deserved. >>> >>> >>> Ch

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! > 在 2019年7月18日，下午5:09，Dawid Wysakowicz 写道： > > Congratulations Becket! Good to have you onboard! > > On 18/07/2019 10:56, Till Rohrmann wrote: >> Congrats Becket! >> >> On Thu, Jul 18, 2019 at 10:52 AM Jeff Zhang wrote: >> >>> Congratulations Becket! >>> >>> Xu Forwa

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats Becket and welcome onboard as a committer! Best, Jincheng Dawid Wysakowicz 于2019年7月18日周四 下午5:10写道： > Congratulations Becket! Good to have you onboard! > > On 18/07/2019 10:56, Till Rohrmann wrote: > > Congrats Becket! > > > > On Thu, Jul 18, 2019 at 10:52 AM Jeff Zhang wrote: > > > >>

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats Becket! Best, Guowei Terry Wang 于2019年7月18日周四 下午5:17写道： > Congratulations Becket! > > > 在 2019年7月18日，下午5:09，Dawid Wysakowicz 写道： > > > > Congratulations Becket! Good to have you onboard! > > > > On 18/07/2019 10:56, Till Rohrmann wrote: > >> Congrats Becket! > >> > >> On Thu, Jul 18,

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Kostas On Thu, Jul 18, 2019 at 11:21 AM Guowei Ma wrote: > Congrats Becket! > > Best, > Guowei > > > Terry Wang 于2019年7月18日周四 下午5:17写道： > > > Congratulations Becket! > > > > > 在 2019年7月18日，下午5:09，Dawid Wysakowicz 写道： > > > > > > Congratulations Becket! Good to have you

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations! Best, Yun -- From:Kostas Kloudas Send Time:2019 Jul. 18 (Thu.) 17:30 To:dev Subject:Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project Congratulations Becket! Kostas On Thu

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations! Best, Vino Yun Gao 于2019年7月18日周四 下午5:31写道： > Congratulations! > > Best, > Yun > > > -- > From:Kostas Kloudas > Send Time:2019 Jul. 18 (Thu.) 17:30 > To:dev > Subject:Re: [ANNOUNCE] Jiangjie (Becket) Qin has been

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! Best, Hequn On Thu, Jul 18, 2019 at 5:34 PM vino yang wrote: > Congratulations! > > Best, > Vino > > Yun Gao 于2019年7月18日周四 下午5:31写道： > > > Congratulations! > > > > Best, > > Yun > > > > > > -- > > From:Kost

Re: instable checkpointing after migration to flink 1.8 (production issue)

Hi Congxian, Starting from this morning we have more issues with checkpointing in production. What we see is sync and async duration for some subtasks are very long but what strange is the total of sync and async durations are much less than the total end to end duration. Please check the follow

[ANNOUNCE] JIRA permissions changed: Only committers can assign somebody to a ticket

Hi all, The permissions for the FLINK Jira project have been changed [1], to *only allow committers and PMC members to assign somebody to a Jira ticket.* Anybody with a Jira account can be assigned to a ticket. There is no need for "Contributor" permissions. This has been discussed in this maili

Re: [DISCUSS] A more restrictive JIRA workflow

Infra has finally changed the permissions. I just announced the change in a separate email [1]. One thing I wanted to discuss here is, how do we want to handle all the "contributor permissions" requests? My proposal is to basically reject them with a nice message, pointing them to my announcement

[jira] [Created] (FLINK-13318) Blink planner tests failing on Scala 2.12

Chesnay Schepler created FLINK-13318: Summary: Blink planner tests failing on Scala 2.12 Key: FLINK-13318 URL: https://issues.apache.org/jira/browse/FLINK-13318 Project: Flink Issue Type:

[jira] [Created] (FLINK-13319) Catalog documentation is missing chinese page

Chesnay Schepler created FLINK-13319: Summary: Catalog documentation is missing chinese page Key: FLINK-13319 URL: https://issues.apache.org/jira/browse/FLINK-13319 Project: Flink Issue T

[jira] [Created] (FLINK-13320) Remove link to hive_compatibility from catalog docs

Chesnay Schepler created FLINK-13320: Summary: Remove link to hive_compatibility from catalog docs Key: FLINK-13320 URL: https://issues.apache.org/jira/browse/FLINK-13320 Project: Flink I

[jira] [Created] (FLINK-13321) Join a udf with constant arguments or without argument in TableAPI query of Blink Planner does not work now

Jing Zhang created FLINK-13321: -- Summary: Join a udf with constant arguments or without argument in TableAPI query of Blink Planner does not work now Key: FLINK-13321 URL: https://issues.apache.org/jira/browse/FLINK-

Re: [DISCUSS] A more restrictive JIRA workflow

Sounds good to me. On 18/07/2019 12:07, Robert Metzger wrote: Infra has finally changed the permissions. I just announced the change in a separate email [1]. One thing I wanted to discuss here is, how do we want to handle all the "contributor permissions" requests? My proposal is to basically

Re: [DISCUSS] A more restrictive JIRA workflow

Do our contribution guidelines contain anything that should be updated? On 18/07/2019 12:24, Chesnay Schepler wrote: Sounds good to me. On 18/07/2019 12:07, Robert Metzger wrote: Infra has finally changed the permissions. I just announced the change in a separate email [1]. One thing I wante

Re:Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket!Best, Haibo 在 2019-07-18 17:51:06，"Hequn Cheng" 写道： >Congratulations Becket! > >Best, Hequn > >On Thu, Jul 18, 2019 at 5:34 PM vino yang wrote: > >> Congratulations! >> >> Best, >> Vino >> >> Yun Gao 于2019年7月18日周四 下午5:31写道： >> >> > Congratulations! >> > >> > Best, >> > Yun

Re: [DISCUSS] A more restrictive JIRA workflow

Robert, Thanks for your effort. Rejecting contributor permission request with a nice message and pointing them to the announcement sounds reasonable. Just to be clear, we now have no person with contributor role, right? Chesnay, https://flink.apache.org/contributing/contribute-code.html has been

Re: [DISCUSS] A more restrictive JIRA workflow

We haven't wiped the set of contributors yet. Not sure if there's an easy way to remove the permissions for all of them; someone from the PMC may have to bite the bullet and click 600 times in a row :) On 18/07/2019 12:32, Zili Chen wrote: Robert, Thanks for your effort. Rejecting contributor

Re:Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

> Congratulations! Best, Danny Chan 在 2019年7月18日 +0800 PM6:29，Haibo Sun ，写道： > Congratulations Becket!Best, > Haibo > 在 2019-07-18 17:51:06，"Hequn Cheng" 写道： > > Congratulations Becket! > > > > Best, Hequn > > > > On Thu, Jul 18, 2019 at 5:34 PM vino yang wrote: > > > > > Congratulations! > > >

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer tothe Flink project

Congratulations ! Best Regards, Jiayi Liao Original Message Sender:Hequn chengchenghe...@gmail.com Recipient:dev...@flink.apache.org Date:Thursday, Jul 18, 2019 17:51 Subject:Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer tothe Flink project Congratulations Becket! Best,

[jira] [Created] (FLINK-13322) Fix serializer snapshot recovery in BaseArray and BaseMap serializers.

Caizhi Weng created FLINK-13322: --- Summary: Fix serializer snapshot recovery in BaseArray and BaseMap serializers. Key: FLINK-13322 URL: https://issues.apache.org/jira/browse/FLINK-13322 Project: Flink

[jira] [Created] (FLINK-13323) Add tests for complex data formats (generic array, generic map, etc.)

Caizhi Weng created FLINK-13323: --- Summary: Add tests for complex data formats (generic array, generic map, etc.) Key: FLINK-13323 URL: https://issues.apache.org/jira/browse/FLINK-13323 Project: Flink

Re: [DISCUSS] A more restrictive JIRA workflow

Checking the result, as a discovery, I found that one can still file a JIRA with "blocker" priority. IIRC someone in this thread once mentioned that "Don't allow contributors to set a blocker priority." Chesnay, Thanks for the clarification. Best, tison. Chesnay Schepler 于2019年7月18日周四 下午6:4

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer tothe Flink project

Congratulations Becket! Best Regards, Yu On Thu, 18 Jul 2019 at 18:46, bupt_ljy wrote: > Congratulations ! > > > Best Regards, > Jiayi Liao > > > Original Message > Sender:Hequn chengchenghe...@gmail.com > Recipient:dev...@flink.apache.org > Date:Thursday, Jul 18, 2019 17:51 > Subject:Re: [ANN

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats Becket! > 在 2019年7月18日，下午6:42，Danny Chan 写道： > >> Congratulations! > > Best, > Danny Chan > 在 2019年7月18日 +0800 PM6:29，Haibo Sun ，写道： >> Congratulations Becket!Best, >> Haibo >> 在 2019-07-18 17:51:06，"Hequn Cheng" 写道： >>> Congratulations Becket! >>> >>> Best, Hequn >>> >>> On Thu, Ju

[jira] [Created] (FLINK-13324) flink-shaded-hadoop could exclude curator dependency

TisonKun created FLINK-13324: Summary: flink-shaded-hadoop could exclude curator dependency Key: FLINK-13324 URL: https://issues.apache.org/jira/browse/FLINK-13324 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-13325) Add test case for FLINK-13249

Stefan Richter created FLINK-13325: -- Summary: Add test case for FLINK-13249 Key: FLINK-13325 URL: https://issues.apache.org/jira/browse/FLINK-13325 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13326) Support asynchronous writing to raw operator (and raw keyed) state

Igal Shilman created FLINK-13326: Summary: Support asynchronous writing to raw operator (and raw keyed) state Key: FLINK-13326 URL: https://issues.apache.org/jira/browse/FLINK-13326 Project: Flink

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats Becket! Best, Xingcan On Thu, Jul 18, 2019, 07:17 Dian Fu wrote: > Congrats Becket! > > > 在 2019年7月18日，下午6:42，Danny Chan 写道： > > > >> Congratulations! > > > > Best, > > Danny Chan > > 在 2019年7月18日 +0800 PM6:29，Haibo Sun ，写道： > >> Congratulations Becket!Best, > >> Haibo > >> 在 2019-07-

Re: instable checkpointing after migration to flink 1.8 (production issue)

Hi, Bekir First, The e2e time for a sub task is the $ack_time_received_in_JM - $trigger_time_in_JM. And checkpoint includes some steps on task side such as 1) receive first barrier; 2) barrier align(for exactly once); 3) operator snapshot sync part; 4) operator snapshot async part, the images you

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulations Becket! -- Rong On Thu, Jul 18, 2019 at 7:05 AM Xingcan Cui wrote: > Congrats Becket! > > Best, > Xingcan > > On Thu, Jul 18, 2019, 07:17 Dian Fu wrote: > > > Congrats Becket! > > > > > 在 2019年7月18日，下午6:42，Danny Chan 写道： > > > > > >> Congratulations! > > > > > > Best, > > > Da

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congratulation, Becket! At least you're able to assign JIRAs now! On Thu, Jul 18, 2019 at 8:22 AM Rong Rong wrote: > Congratulations Becket! > > -- > Rong > > On Thu, Jul 18, 2019 at 7:05 AM Xingcan Cui wrote: > > > Congrats Becket! > > > > Best, > > Xingcan > > > > On Thu, Jul 18, 2019, 07:17

[jira] [Created] (FLINK-13327) Blink planner not compiling with Scala 2.12

Chesnay Schepler created FLINK-13327: Summary: Blink planner not compiling with Scala 2.12 Key: FLINK-13327 URL: https://issues.apache.org/jira/browse/FLINK-13327 Project: Flink Issue Typ

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats Becket! :) Richard On Thu, Jul 18, 2019 at 5:52 PM Xuefu Z wrote: > Congratulation, Becket! At least you're able to assign JIRAs now! > > On Thu, Jul 18, 2019 at 8:22 AM Rong Rong wrote: > > > Congratulations Becket! > > > > -- > > Rong > > > > On Thu, Jul 18, 2019 at 7:05 AM Xingcan

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats! On Thu, Jul 18, 2019 at 9:58 AM Richard Deurwaarder wrote: > Congrats Becket! :) > > Richard > > On Thu, Jul 18, 2019 at 5:52 PM Xuefu Z wrote: > > > Congratulation, Becket! At least you're able to assign JIRAs now! > > > > On Thu, Jul 18, 2019 at 8:22 AM Rong Rong wrote: > > > > >

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats! On Thu, Jul 18, 2019 at 10:21 AM Thomas Weise wrote: > Congrats! > > > On Thu, Jul 18, 2019 at 9:58 AM Richard Deurwaarder > wrote: > > > Congrats Becket! :) > > > > Richard > > > > On Thu, Jul 18, 2019 at 5:52 PM Xuefu Z wrote: > > > > > Congratulation, Becket! At least you're able

Issue running basic example locally

Hello everyone, I'm using IntelliJ in a ubuntu environment with java 1.8 to run my Flink framworks. My goal is consume few kinesis stream services and build a sort of pipeline. Initially I have build my pom.xml file attached and a test java class attached too. However , once I run my class from t

Re: [ANNOUNCE] JIRA permissions changed: Only committers can assign somebody to a ticket

shall we announce in user ML too? Users who are used to assign tickets to themselves should also be aware of this change On Thu, Jul 18, 2019 at 3:06 AM Robert Metzger wrote: > Hi all, > > The permissions for the FLINK Jira project have been changed [1], to *only > allow committers and PMC membe

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats, Jiangjie! On Thu, Jul 18, 2019 at 11:07 AM Shuyi Chen wrote: > Congrats! > > On Thu, Jul 18, 2019 at 10:21 AM Thomas Weise wrote: > > > Congrats! > > > > > > On Thu, Jul 18, 2019 at 9:58 AM Richard Deurwaarder > > wrote: > > > > > Congrats Becket! :) > > > > > > Richard > > > > > > O

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Thanks everyone! It's really a pleasure working with all of you :) On Fri, Jul 19, 2019 at 3:48 AM Bowen Li wrote: > Congrats, Jiangjie! > > On Thu, Jul 18, 2019 at 11:07 AM Shuyi Chen wrote: > > > Congrats! > > > > On Thu, Jul 18, 2019 at 10:21 AM Thomas Weise wrote: > > > > > Congrats! > >

[jira] [Created] (FLINK-13328) add IT case for reading and writing generic table metadata via HiveCatalog

Bowen Li created FLINK-13328: Summary: add IT case for reading and writing generic table metadata via HiveCatalog Key: FLINK-13328 URL: https://issues.apache.org/jira/browse/FLINK-13328 Project: Flink

Re:请问这些名词，在翻译 Glossary 时，有必要翻译成中文吗？

Hi，Zili Chen: 早上好，你讲的没错，谢谢。另外我发现，Glossary 英文文档中没有 Slot 和 Parallelism 的说明，建议添加。这样可以方便初学者和用户的学习和使用！ 祝好 Original Message Subject: Re: 请问这些名词，在翻译 Glossary 时，有必要翻译成中文吗？ From: Zili Chen To: user...@flink.apache.org CC: 没有可援引的通译出处建议专有名词不要翻译。Glossary 的解释部分可以解释得详尽一点，上面像 reco

Re: Issue running basic example locally

Hi Andres, `provided` of flink-streaming-java seems suspicious, can you remove it and see what happens? Andres Angel 于2019年7月19日周五 上午3:10写道： > Hello everyone, > > I'm using IntelliJ in a ubuntu environment with java 1.8 to run my Flink > framworks. My goal is consume few kinesis stream services

Re: 请问这些名词，在翻译 Glossary 时，有必要翻译成中文吗？

Hi, 欢迎有 PR 后同步到这个 thread 上 :-) Best, tison. highfei2011 于2019年7月19日周五 上午8:34写道： > Hi，Zili Chen: > 早上好，你讲的没错，谢谢。另外我发现，Glossary 英文文档中没有 Slot 和 Parallelism > 的说明，建议添加。这样可以方便初学者和用户的学习和使用！ > > 祝好 > > > > Original Message > Subject: Re: 请问这些名词，在翻译 Glossary 时，有必要翻译成中文吗？ > F

[jira] [Created] (FLINK-13329) Set env config for sql jobs

XuPingyong created FLINK-13329: -- Summary: Set env config for sql jobs Key: FLINK-13329 URL: https://issues.apache.org/jira/browse/FLINK-13329 Project: Flink Issue Type: Task Components

flink-mapr-fs failed in travis

Hi everyone: flink-mapr-fs failed in travis, and I retried many times, and also failed. Anyone has idea about this? 01:32:54.755 [ERROR] Failed to execute goal on project flink-mapr-fs: Could not resolve dependencies for project org.apache.flink:flink-mapr-fs:jar:1.10-SNAPSHOT: Failed to collec

Re: [ANNOUNCE] Jiangjie (Becket) Qin has been added as a committer to the Flink project

Congrats Becket! It is really great to have you on board. Regards, Shaoxuan On Fri, Jul 19, 2019 at 7:24 AM Becket Qin wrote: > Thanks everyone! > > It's really a pleasure working with all of you :) > > On Fri, Jul 19, 2019 at 3:48 AM Bowen Li wrote: > > > Congrats, Jiangjie! > > > > On Thu, J

Re: 请问这些名词，在翻译 Glossary 时，有必要翻译成中文吗？

Hi highfei, Thanks for bringing up this discussion. I would suggest to move the discussion to the Glossary translation JIRA FLINK-13037 . Thanks, Jark On Fri, 19 Jul 2019 at 09:00, Zili Chen wrote: > Hi, > > 欢迎有 PR 后同步到这个 thread 上 :-) > >

Re: 请问这些名词，在翻译 Glossary 时，有必要翻译成中文吗？

Hi, Just find the Glossary translation PR is created [1]. Let's move the discussion there. [1]. https://github.com/apache/flink/pull/9173 On Fri, 19 Jul 2019 at 11:22, Jark Wu wrote: > Hi highfei, > > Thanks for bringing up this discussion. I would suggest to move the > discussion to the Gloss

Re: [DISCUSS] A more restrictive JIRA workflow

A quick question, what should we do if a developer creates a JIRA issue and then create a pull request at once without assigning? Regards, Jark On Thu, 18 Jul 2019 at 18:50, Zili Chen wrote: > Checking the result, as a discovery, I found that one can > still file a JIRA with "blocker" priority

Re: [DISCUSS] A more restrictive JIRA workflow

@Jack >From https://flink.apache.org/contributing/contribute-code.html the community claims - Only start working on the implementation if there is consensus on the approach (e.g. you are assigned to the ticket) and accurately answer your question, - Pull requests belonging to unassigned Jira ti

Re: [DISCUSS] A more restrictive JIRA workflow

Fair enough, we might rephrase as "Pull requests belonging to unassigned Jira tickets or not authored by assignee will ..." For the action "what should we do", iirc someone in this thread proposed closing it via flinkbot. Or leaving without review and merge could be ok before we implement automat

could rest api : /jobs/:jobid/yarn-cancel trigger the savepoint?

Hi community, I have a question is that could rest api : /jobs/:jobid/yarn-cancel trigger the savepoint? I saw the fink src code, and I find it didn't trigger the savepoint, is it right? Thank you to reply .

[jira] [Created] (FLINK-13330) Remove unnecessary to reduce testing time in blink

Jingsong Lee created FLINK-13330: Summary: Remove unnecessary to reduce testing time in blink Key: FLINK-13330 URL: https://issues.apache.org/jira/browse/FLINK-13330 Project: Flink Issue Type

[jira] [Created] (FLINK-13331) Add TestMiniClusters to maintain cache share cluster between Tests

Jingsong Lee created FLINK-13331: Summary: Add TestMiniClusters to maintain cache share cluster between Tests Key: FLINK-13331 URL: https://issues.apache.org/jira/browse/FLINK-13331 Project: Flink

Re:Re: 请问这些名词，在翻译 Glossary 时，有必要翻译成中文吗？

Hi, Jark Wu ,Thanks I am discussing in there . 在 2019-07-19 11:22:53，"Jark Wu" 写道： >Hi, > >Just find the Glossary translation PR is created [1]. Let's move the >discussion there. > >[1]. https://github.com/apache/flink/pull/9173 > >On Fri, 19 Jul 2019 at 11:22, Jark Wu wrote: > >> Hi hi

[DISCUSS] Drop stale class Program

Hi devs, Participating the thread "Flink client api enhancement"[1], I just notice that inside submission codepath of Flink we always has a branch dealing with the case that main class of user program is a subclass of o.a.f.api.common.Program, which is defined as @PublicEvolving public interface

Re: flink-mapr-fs failed in travis

It seems that it is introduced by this commit: https://github.com/apache/flink/commit/5c36c650e6520d92191ce2da33f7dcae774319f6 Hi @Chesnay Schepler , do we need to add "-Punsafe-mapr-repo" to the ".travis.yml"? Best, Jark On Fri, 19 Jul 2019 at 10:58, JingsongLee wrote: > Hi everyone: > > flin

[jira] [Created] (FLINK-13332) PackagedProgram#isUsingInteractiveMode implemented error prone

TisonKun created FLINK-13332: Summary: PackagedProgram#isUsingInteractiveMode implemented error prone Key: FLINK-13332 URL: https://issues.apache.org/jira/browse/FLINK-13332 Project: Flink Issue

[jira] [Created] (FLINK-13333) Potentially NPE of preview plan functionality

TisonKun created FLINK-1: Summary: Potentially NPE of preview plan functionality Key: FLINK-1 URL: https://issues.apache.org/jira/browse/FLINK-1 Project: Flink Issue Type: Bug Aff