Re: [DISCUSS] Start a user...@flink.apache.org mailing list for the Chinese-speaking community?

2019-06-20 Thread vino yang
Hi Kurt, I have copied my reply to the Jira issue of INFRA[1]. Within my ability, I am happy to coordinate and promote this problem. Best, Vino [1]: https://issues.apache.org/jira/browse/INFRA-18249 Kurt Young 于2019年6月21日周五 下午12:11写道: > Hi vino, > > Thanks for your effort. Could you also

Re: [DISCUSS] Start a user...@flink.apache.org mailing list for the Chinese-speaking community?

2019-06-20 Thread Kurt Young
Hi vino, Thanks for your effort. Could you also share this information with apache INFRA? Maybe we can find a workable solution together. You can try to leave comments in this jira: https://issues.apache.org/jira/browse/INFRA-18249) Best, Kurt On Fri, Jun 21, 2019 at 11:45 AM vino yang wrote:

Re: [DISCUSS] Start a user...@flink.apache.org mailing list for the Chinese-speaking community?

2019-06-20 Thread vino yang
Hi all, The main reason is that the *Apache mail server has been used and caused a bounce attack on the QQ mailbox*. Detailed description: The third parties forged the domain name of the QQ mailbox to send spam to the Apache mail server. The Apache mail server does not make a correct check and

[jira] [Created] (FLINK-12921) Flink Job Scheduling

2019-06-20 Thread vim (JIRA)
vim created FLINK-12921: --- Summary: Flink Job Scheduling Key: FLINK-12921 URL: https://issues.apache.org/jira/browse/FLINK-12921 Project: Flink Issue Type: Improvement Components: API /

Re: [DISCUSS] Start a user...@flink.apache.org mailing list for the Chinese-speaking community?

2019-06-20 Thread vino yang
Hi Robert, Yes, QQ mail product belongs to Tencent and I work at Tencent. I am contacting QQ mail team and trying to know the reason. Once I get the reply and explanation. I will sync here. Best, Vino. Robert Metzger 于2019年6月20日周四 下午10:59写道: > Thanks a lot! > > qq.com belongs to Tencent,

[jira] [Created] (FLINK-12920) Drop support for register_table_sink with field_names and field_types parameters

2019-06-20 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12920: --- Summary: Drop support for register_table_sink with field_names and field_types parameters Key: FLINK-12920 URL: https://issues.apache.org/jira/browse/FLINK-12920 Project:

[jira] [Created] (FLINK-12919) flink-connector-hive compilation error in travis

2019-06-20 Thread leesf (JIRA)
leesf created FLINK-12919: - Summary: flink-connector-hive compilation error in travis Key: FLINK-12919 URL: https://issues.apache.org/jira/browse/FLINK-12919 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12918) unify catalog table implementation

2019-06-20 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12918: Summary: unify catalog table implementation Key: FLINK-12918 URL: https://issues.apache.org/jira/browse/FLINK-12918 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12917) support complex type of array, map, struct for Hive functions

2019-06-20 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12917: Summary: support complex type of array, map, struct for Hive functions Key: FLINK-12917 URL: https://issues.apache.org/jira/browse/FLINK-12917 Project: Flink Issue

[jira] [Created] (FLINK-12916) KeyedComplexChainTest.testMigrationAndRestore failed on Travis

2019-06-20 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-12916: - Summary: KeyedComplexChainTest.testMigrationAndRestore failed on Travis Key: FLINK-12916 URL: https://issues.apache.org/jira/browse/FLINK-12916 Project: Flink

[jira] [Created] (FLINK-12915) AbstractOperatorRestoreTestBase can deadlock if one test fails

2019-06-20 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-12915: - Summary: AbstractOperatorRestoreTestBase can deadlock if one test fails Key: FLINK-12915 URL: https://issues.apache.org/jira/browse/FLINK-12915 Project: Flink

[jira] [Created] (FLINK-12914) Remove legacy InstanceListener

2019-06-20 Thread leesf (JIRA)
leesf created FLINK-12914: - Summary: Remove legacy InstanceListener Key: FLINK-12914 URL: https://issues.apache.org/jira/browse/FLINK-12914 Project: Flink Issue Type: Sub-task Components:

[jira] [Created] (FLINK-12913) Remove legacy InstanceManager and InstanceManagerTest

2019-06-20 Thread leesf (JIRA)
leesf created FLINK-12913: - Summary: Remove legacy InstanceManager and InstanceManagerTest Key: FLINK-12913 URL: https://issues.apache.org/jira/browse/FLINK-12913 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Start a user...@flink.apache.org mailing list for the Chinese-speaking community?

2019-06-20 Thread Robert Metzger
Thanks a lot! qq.com belongs to Tencent, right? As far as I know, we have some active contributors working at Tencent (Vino Yang). Maybe he or other employees from Tencent following this mailing list, could help to make a connection to the QQ teams to resolve that problem? On Thu, Jun 20, 2019

Re: [DISCUSS] Start a user...@flink.apache.org mailing list for the Chinese-speaking community?

2019-06-20 Thread Kurt Young
>From INFRA's response: "Yes, they aggressively rate limit us, and all our efforts to contact them have gone unanswered. We recommend people use other providers." I think the only way is tell user not to use qq.com mails when using apache mailing list. Best, Kurt On Thu, Jun 20, 2019 at 10:23

[jira] [Created] (FLINK-12912) Incorrect handling of task.checkpoint.alignment.max-size when one checkpoint subsumes another one

2019-06-20 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-12912: -- Summary: Incorrect handling of task.checkpoint.alignment.max-size when one checkpoint subsumes another one Key: FLINK-12912 URL:

Re: [DISCUSS] Start a user...@flink.apache.org mailing list for the Chinese-speaking community?

2019-06-20 Thread Kurt Young
Thanks Robert, I left a comment in the JIRA you gave and see what will happen. Best, Kurt On Thu, Jun 20, 2019 at 9:04 PM Robert Metzger wrote: > Thank you all for working on this! > > +1 on conducting a survey! > > @Kurt: Yes, you can just file a JIRA ticket with INFRA (see a similar >

Re: Sort streams in windows

2019-06-20 Thread Fabian Hueske
Hi Eugene, I agree with Jan. Using a ProcessFunction is the way to go. ProcessFunction gives you all the tools you need: * ListState which is very cheap to append to (and you only need to read the ListState when you receive a watermark). * Access to event timestamps, the current watermark and

Re:Re: CatalogTestBase.* failed on travis

2019-06-20 Thread Haibo Sun
Thanks for the quick fix. Best, Haibo 在 2019-06-20 21:24:47,"jincheng sun" 写道: >Hi Haibo, > >The issue is fixed, great thanks for your timely report on this issue! > >Best, >Jincheng > > >jincheng sun 于2019年6月20日周四 下午9:04写道: > >> Hi flink devs: >> >> Normally, in order not to affect the

Re: CatalogTestBase.* failed on travis

2019-06-20 Thread jincheng sun
Hi Haibo, The issue is fixed, great thanks for your timely report on this issue! Best, Jincheng jincheng sun 于2019年6月20日周四 下午9:04写道: > Hi flink devs: > > Normally, in order not to affect the merge of the followup PR, we need to > revert the problematic commit, but since Dian quickly opens

Re: CatalogTestBase.* failed on travis

2019-06-20 Thread jincheng sun
Hi flink devs: Normally, in order not to affect the merge of the followup PR, we need to revert the problematic commit, but since Dian quickly opens the hotfix PR, this time we take the hotfix. So great thanks to Dian! Hi Dian, you are right,the test fail caused by the PR #8786, and I

Re: [DISCUSS] Start a user...@flink.apache.org mailing list for the Chinese-speaking community?

2019-06-20 Thread Robert Metzger
Thank you all for working on this! +1 on conducting a survey! @Kurt: Yes, you can just file a JIRA ticket with INFRA (see a similar example, also mentioning qq.com: https://issues.apache.org/jira/browse/INFRA-18249) On Thu, Jun 20, 2019 at 6:23 AM Kurt Young wrote: > Is there any chance

Re: [ANNOUNCEMENT] March 2019 Bay Area Apache Flink Meetup

2019-06-20 Thread Robert Metzger
Hey Xuefu, thanks a lot for organizing the Bay Area Flink Meetup. For others following this email thread, here is the (deep) link to the event: https://www.meetup.com/Bay-Area-Apache-Flink-Meetup/events/262216929/ I see that only 19 people have RSVPed so far. In my experience, it's possible to

Re: CatalogTestBase.* failed on travis

2019-06-20 Thread jincheng sun
Great thanks for the help to fix it Dian! I'll merge it. Dian Fu 于2019年6月20日周四 下午7:50写道: > Hi Haibo, > > Thanks a lot for report this bug. I guess it's caused by this PR: > https://github.com/apache/flink/pull/8786 < > https://github.com/apache/flink/pull/8786> @Bowen. I think we'd better >

[jira] [Created] (FLINK-12911) Port AppendStreamTableSink, UpsertStreamTableSink, RetractStreamTableSink to flink-api-java

2019-06-20 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12911: --- Summary: Port AppendStreamTableSink, UpsertStreamTableSink, RetractStreamTableSink to flink-api-java Key: FLINK-12911 URL: https://issues.apache.org/jira/browse/FLINK-12911

[jira] [Created] (FLINK-12910) Fix the Python catalog test issue

2019-06-20 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12910: --- Summary: Fix the Python catalog test issue Key: FLINK-12910 URL: https://issues.apache.org/jira/browse/FLINK-12910 Project: Flink Issue Type: Bug

Re: CatalogTestBase.* failed on travis

2019-06-20 Thread Dian Fu
Hi Haibo, Thanks a lot for report this bug. I guess it's caused by this PR: https://github.com/apache/flink/pull/8786 @Bowen. I think we'd better merge the code ONLY after the travis passed, especially when the changes are not just

Re: [DISCUSS] Deprecate previous Python APIs

2019-06-20 Thread Chesnay Schepler
I have created a JIRA and PR for removing the Python APIs. On 11/06/2019 15:30, Stephan Ewen wrote: Hi all! I would suggest to deprecating the existing python APIs for DataSet and DataStream API

CatalogTestBase.* failed on travis

2019-06-20 Thread Haibo Sun
Hi, guys I noticed that all of the Travis tests reported a number of failures as following. Is anyone working on this problem? __ CatalogTestBase.test_table_exists ___ self = def test_table_exists(self): >

[jira] [Created] (FLINK-12909) add try catch when find a unique file name for the spilling channel

2019-06-20 Thread xymaqingxiang (JIRA)
xymaqingxiang created FLINK-12909: - Summary: add try catch when find a unique file name for the spilling channel Key: FLINK-12909 URL: https://issues.apache.org/jira/browse/FLINK-12909 Project: Flink

Re: [COMMITTERS] GitHub problem with merging PRs or commenting on them

2019-06-20 Thread jincheng sun
Thanks for the reminder! @Chesnay Schepler I thought I had a network problem, it turned out to be a GitHub problem. I can't comment on the PR 5 minutes ago, it should be OK now! Chesnay Schepler 于2019年6月20日周四 下午5:21写道: > Attention fellow committers, > > There is currently an issue with GitHub

Re: [COMMITTERS] GitHub problem with merging PRs or commenting on them

2019-06-20 Thread Chesnay Schepler
* When you merge a PR through the UI it can happen that the commit is merged, _without _the PR being closed! On 20/06/2019 11:21, Chesnay Schepler wrote: Attention fellow committers, There is currently an issue with GitHub where it may not be possible to close PRs or comment on them. When

[COMMITTERS] GitHub problem with merging PRs or commenting on them

2019-06-20 Thread Chesnay Schepler
Attention fellow committers, There is currently an issue with GitHub where it may not be possible to close PRs or comment on them. When you merge a PR through the UI it can happen that the commit is merged, with the PR being closed! When this happens, don't try to merge it again (like I

[ANNOUNCE] Feature freeze for Apache Flink 1.9.0 release

2019-06-20 Thread Tzu-Li (Gordon) Tai
Hi devs, Per the feature discussions for 1.9.0 [1], I hereby announce the official feature freeze for Flink 1.9.0 to be on June 28. A release feature branch for 1.9 will be cut following that date. We’re roughly one week away from this date, but please keep in mind that we still shouldn’t rush

Re: [DISCUSS] Features for Apache Flink 1.9.0

2019-06-20 Thread Tzu-Li (Gordon) Tai
Hi all, Thanks for all the updates and work! >From the looks so far, overall it seems like we are still in a good spot to officially announce the feature freeze date to be on the originally proposed date, June 28. I’ll announce this in a separate thread. Cheers, Gordon On Fri, Jun 7, 2019 at

[jira] [Created] (FLINK-12908) flink-table-planner-blink does not compile on master

2019-06-20 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-12908: Summary: flink-table-planner-blink does not compile on master Key: FLINK-12908 URL: https://issues.apache.org/jira/browse/FLINK-12908 Project: Flink

Re: [DISCUSS] FLIP-44: Support Local Aggregation in Flink

2019-06-20 Thread vino yang
Hi Kurt, Thanks for your comments. It seems we come to a consensus that we should alleviate the performance degraded by data skew with local aggregation. In this FLIP, our key solution is to introduce local keyed partition to achieve this goal. I also agree that we can benefit a lot from the