[jira] [Created] (FLINK-11770) Update FlinkKinesisConsumerMigrationTest for 1.8

vinoyang created FLINK-11770: Summary: Update FlinkKinesisConsumerMigrationTest for 1.8 Key: FLINK-11770 URL: https://issues.apache.org/jira/browse/FLINK-11770 Project: Flink Issue Type: Sub-task

ask for contributor permission

Hi guys: Could somebody give me contributor permissions? my jira username is : stephenye Thanks.

[jira] [Created] (FLINK-11769) The estimateDataTypesSize method in FlinkRelNode causes NPE for Multiset

Xingcan Cui created FLINK-11769: --- Summary: The estimateDataTypesSize method in FlinkRelNode causes NPE for Multiset Key: FLINK-11769 URL: https://issues.apache.org/jira/browse/FLINK-11769 Project: Flink

[jira] [Created] (FLINK-11768) Update TypeSerializerSnapshotMigrationITCase for Flink 1.8

vinoyang created FLINK-11768: Summary: Update TypeSerializerSnapshotMigrationITCase for Flink 1.8 Key: FLINK-11768 URL: https://issues.apache.org/jira/browse/FLINK-11768 Project: Flink Issue Type

[jira] [Created] (FLINK-11767) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.8

vinoyang created FLINK-11767: Summary: Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.8 Key: FLINK-11767 URL: https://issues.apache.org/jira/browse/FLINK-11767 Project: Flink

[jira] [Created] (FLINK-11766) Update Java / Scala StatefulJobSavepointMigrationITCase for 1.8

vinoyang created FLINK-11766: Summary: Update Java / Scala StatefulJobSavepointMigrationITCase for 1.8 Key: FLINK-11766 URL: https://issues.apache.org/jira/browse/FLINK-11766 Project: Flink Issu

[jira] [Created] (FLINK-11765) Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7

vinoyang created FLINK-11765: Summary: Update Java / Scala StatefulJobWBroadcastStateMigrationITCase for 1.7 Key: FLINK-11765 URL: https://issues.apache.org/jira/browse/FLINK-11765 Project: Flink

[jira] [Created] (FLINK-11764) Update BucketingSinkMigrationTest for Flink 1.8

vinoyang created FLINK-11764: Summary: Update BucketingSinkMigrationTest for Flink 1.8 Key: FLINK-11764 URL: https://issues.apache.org/jira/browse/FLINK-11764 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] Flink 1.8 release branch has been cut

Hi, @Aljoscha Krettek @Timo Walther The PR of FLINK-11728 It's better to be merged into 1.8 branch before the first release candidate, I will do it ASAP. Best, Jincheng Hequn Cheng 于2019年2月25日周一 下午8:12写道： > @Aljoscha Thanks for driving this

[jira] [Created] (FLINK-11762) Update WindowOperatorMigrationTest for 1.8

vinoyang created FLINK-11762: Summary: Update WindowOperatorMigrationTest for 1.8 Key: FLINK-11762 URL: https://issues.apache.org/jira/browse/FLINK-11762 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11763) Update AbstractKeyedOperatorRestoreTestBase for 1.9

vinoyang created FLINK-11763: Summary: Update AbstractKeyedOperatorRestoreTestBase for 1.9 Key: FLINK-11763 URL: https://issues.apache.org/jira/browse/FLINK-11763 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-11761) Update FlinkKafkaConsumerBaseMigrationTest for 1.8

vinoyang created FLINK-11761: Summary: Update FlinkKafkaConsumerBaseMigrationTest for 1.8 Key: FLINK-11761 URL: https://issues.apache.org/jira/browse/FLINK-11761 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-11760) Update CEPMigrationTest for 1.8

vinoyang created FLINK-11760: Summary: Update CEPMigrationTest for 1.8 Key: FLINK-11760 URL: https://issues.apache.org/jira/browse/FLINK-11760 Project: Flink Issue Type: Test Components

[jira] [Created] (FLINK-11759) Update AbstractNonKeyedOperatorRestoreTestBase for 1.8

vinoyang created FLINK-11759: Summary: Update AbstractNonKeyedOperatorRestoreTestBase for 1.8 Key: FLINK-11759 URL: https://issues.apache.org/jira/browse/FLINK-11759 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-11758) Update ContinuousFileProcessingMigrationTest for 1.8

vinoyang created FLINK-11758: Summary: Update ContinuousFileProcessingMigrationTest for 1.8 Key: FLINK-11758 URL: https://issues.apache.org/jira/browse/FLINK-11758 Project: Flink Issue Type: Sub-

[jira] [Created] (FLINK-11757) Add the version number of Flink 1.8 to MigrationVersion

vinoyang created FLINK-11757: Summary: Add the version number of Flink 1.8 to MigrationVersion Key: FLINK-11757 URL: https://issues.apache.org/jira/browse/FLINK-11757 Project: Flink Issue Type: S

[jira] [Created] (FLINK-11756) Update migration tests for Flink 1.8

vinoyang created FLINK-11756: Summary: Update migration tests for Flink 1.8 Key: FLINK-11756 URL: https://issues.apache.org/jira/browse/FLINK-11756 Project: Flink Issue Type: Test Compo

Re: Recommended module for connector ratelimiting?

Since we want to be able to use the rate limiter for multiple connectors and potentially elsewhere, plus it is user facing, this seems to be the right area. Perhaps org.apache.flink.api.common.io specifically? On Mon, Feb 25, 2019 at 5:40 PM Lakshmi Gururaja Rao wrote: > Hi all, > > The PR that

[jira] [Created] (FLINK-11755) Remove ensureCompatibility method from TypeSerializer abstraction

Tzu-Li (Gordon) Tai created FLINK-11755: --- Summary: Remove ensureCompatibility method from TypeSerializer abstraction Key: FLINK-11755 URL: https://issues.apache.org/jira/browse/FLINK-11755 Proje

Re: [DISCUSS] A more restrictive JIRA workflow

Hi, Timo Thanks for putting this together and bring the discussion. +1 to making our JIRAs a bit more restrictive! I think this makes a good point of view. It would be helpful to force the contributors to think more about the issues rather than take it directly or maybe rashly. One little suggest

[jira] [Created] (FLINK-11754) Translate the "Roadmap" page into Chinese

Jark Wu created FLINK-11754: --- Summary: Translate the "Roadmap" page into Chinese Key: FLINK-11754 URL: https://issues.apache.org/jira/browse/FLINK-11754 Project: Flink Issue Type: Sub-task

One source is much slower than the other side when join history data

When consuming history data in join operator with eventTime, reading data from one source is much slower than the other. As a result, the join operator will cache much data from the faster source in order to wait the slower source. The question is that how can I make the difference of c

apply contributor permission

Hi, all I want to contribute to Apache Flink. Would you kindly give me the contributor permission? My JIRA ID is Leonard Xu

Re: [DISCUSS] Adding a mid-term roadmap to the Flink website

Great job. Stephan! Best, Vino Jamie Grier 于2019年2月27日周三 上午2:27写道： > This is awesome, Stephan! Thanks for doing this. > > -Jamie > > > On Tue, Feb 26, 2019 at 9:29 AM Stephan Ewen wrote: > >> Here is the pull request with a draft of the roadmap: >> https://github.com/apache/flink-web/pull/178

[jira] [Created] (FLINK-11753) Add utils for serialization compatibility tests

Igal Shilman created FLINK-11753: Summary: Add utils for serialization compatibility tests Key: FLINK-11753 URL: https://issues.apache.org/jira/browse/FLINK-11753 Project: Flink Issue Type: I

Re: [DISCUSS] Adding a mid-term roadmap to the Flink website

This is awesome, Stephan! Thanks for doing this. -Jamie On Tue, Feb 26, 2019 at 9:29 AM Stephan Ewen wrote: > Here is the pull request with a draft of the roadmap: > https://github.com/apache/flink-web/pull/178 > > Best, > Stephan > > On Fri, Feb 22, 2019 at 5:18 AM Hequn Cheng wrote: > >> H

Re: [DISCUSS] A more restrictive JIRA workflow

I like the idea of pushing more for "discuss before opening a PR", and this could help with that part. We have to be clear though that this is not meant as a way to discourage contributions. If we decide to switch to that mode, I think we need to - Concurrently update the contribution guide and

Re: [DISCUSS] Adding a mid-term roadmap to the Flink website

Here is the pull request with a draft of the roadmap: https://github.com/apache/flink-web/pull/178 Best, Stephan On Fri, Feb 22, 2019 at 5:18 AM Hequn Cheng wrote: > Hi Stephan, > > Thanks for summarizing the great roadmap! It is very helpful for users and > developers to track the direction of

[jira] [Created] (FLINK-11752) Move flink-python to opt

Ufuk Celebi created FLINK-11752: --- Summary: Move flink-python to opt Key: FLINK-11752 URL: https://issues.apache.org/jira/browse/FLINK-11752 Project: Flink Issue Type: Improvement Comp

Re: [RESULT][VOTE] Clean up and reorganize the JIRA components

I agree with Robert from now. Best, Jincheng Robert Metzger 于2019年2月26日周二 下午7:03写道： > Thank you for the suggestion. > > Would this be "Runtime / State TTL" ? > > How about adding this once we really have collected enough tickets to > justify a separate component? > The number of components is q

Re: [RESULT][VOTE] Clean up and reorganize the JIRA components

I agree with Robert. Until there are enough tickets justifying a dedicated component "Runtime / State TTL" should belong to "Runtime / State Backends". On Tue, Feb 26, 2019 at 12:03 PM Robert Metzger wrote: > Thank you for the suggestion. > > Would this be "Runtime / State TTL" ? > > How about a

Re: [DISCUSS] Move flink-python to opt

+1 from my side for the proposal. Cheers, Till On Tue, Feb 26, 2019 at 7:37 AM jincheng sun wrote: > Thanks for bringing up this DISCUSS Ufuk! > > Makes sense. +1 for doing this. > > Best, > Jincheng > > Ufuk Celebi 于2019年2月25日周一 下午10:33写道： > > > Dear devs, > > > > what are your thoughts abou

Re: Guidance to new Flink developers

Hello Gordon, Dawid, Thanks for putting that pull request in 1.8 release and helping on the review. I'm still in observe mode on the list :) Tried not to chip in too early with new suggestions since they might have been proposed or already in the process. But here are my two cents: The things I

Re: [RESULT][VOTE] Clean up and reorganize the JIRA components

Thank you for the suggestion. Would this be "Runtime / State TTL" ? How about adding this once we really have collected enough tickets to justify a separate component? The number of components is quite high already, and I would like to avoid expanding it further too early. Unless others also ask

[jira] [Created] (FLINK-11751) Extend release notes for Flink 1.8

Aljoscha Krettek created FLINK-11751: Summary: Extend release notes for Flink 1.8 Key: FLINK-11751 URL: https://issues.apache.org/jira/browse/FLINK-11751 Project: Flink Issue Type: Task

apply contributor permission

Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is xiangtao

Re: [RESULT][VOTE] Clean up and reorganize the JIRA components

Hi all, Thank you for such useful effort, Robert! I would also suggest a separate tag for state TTL, like queryable state. There might be not so many issues atm but it might help in future. Thanks, Andrey On Mon, Feb 25, 2019 at 8:02 PM Robert Metzger wrote: > The proposal has been approved w

[jira] [Created] (FLINK-11750) Refactor the creation of ResultPartitionID in IntermediateResultPartition

zhijiang created FLINK-11750: Summary: Refactor the creation of ResultPartitionID in IntermediateResultPartition Key: FLINK-11750 URL: https://issues.apache.org/jira/browse/FLINK-11750 Project: Flink