Re: [DISCUSS] Improve the flinkbot

2019-03-05 Thread Kurt Young
Hi Dev, I've been using the flinkbot and the label for a couple days, it worked really well! I have a minor suggestion, can we use different colors for different labels? We don't need to have different colors for every label, but only to distinguish whether someone had review the PR. For example,

[jira] [Created] (FLINK-11832) Convert some InternalType property related functions to InternalType's method

2019-03-05 Thread Kurt Young (JIRA)
Kurt Young created FLINK-11832: -- Summary: Convert some InternalType property related functions to InternalType's method Key: FLINK-11832 URL: https://issues.apache.org/jira/browse/FLINK-11832 Project:

[jira] [Created] (FLINK-11831) Separate CodeGeneratorContext for different generation targets

2019-03-05 Thread Kurt Young (JIRA)
Kurt Young created FLINK-11831: -- Summary: Separate CodeGeneratorContext for different generation targets Key: FLINK-11831 URL: https://issues.apache.org/jira/browse/FLINK-11831 Project: Flink

[jira] [Created] (FLINK-11830) Introduce CodeGeneratorContext to maintain reusable statements for code generation

2019-03-05 Thread Jark Wu (JIRA)
Jark Wu created FLINK-11830: --- Summary: Introduce CodeGeneratorContext to maintain reusable statements for code generation Key: FLINK-11830 URL: https://issues.apache.org/jira/browse/FLINK-11830 Project:

Re: [DISCUSS] Create a Flink ecosystem website

2019-03-05 Thread Becket Qin
Forgot to provide the link... [1] https://www.apache.org/dev/services.html#blogs (Apache infra services) [2] https://www.apache.org/dev/freebsd-jails (FreeBSD Jail provided by Apache Infra) On Wed, Mar 6, 2019 at 10:46 AM Becket Qin wrote: > Hi Robert, > > Thanks for the feedback. These are

Re: [DISCUSS] Create a Flink ecosystem website

2019-03-05 Thread Becket Qin
Hi Robert, Thanks for the feedback. These are good points. We should absolutely shoot for a dynamic website to support more interactions in the community. There might be a few things to solve: 1. The website code itself. An open source solution would be great. TBH, I do not have much experience

Re: [DISCUSS] Create a Flink ecosystem website

2019-03-05 Thread Shaoxuan Wang
Hi Becket and Robert, I like this idea! Let us roll this out with Flink connectors at the first beginning. We can start with a static page, and upgrade it when we find a better solution for dynamic one with rich functions. Regards, Shaoxuan On Wed, Mar 6, 2019 at 1:36 AM Robert Metzger

Re: [DISCUSS] Create a Flink ecosystem website

2019-03-05 Thread vino yang
Hi Becket, Great idea! +1 for this proposal. Best, Vino Bowen Li 于2019年3月6日周三 上午6:24写道: > Thanks for bring it up, Becket. That sounds very good to me. Spark also > has such a page for ecosystem project > https://spark.apache.org/third-party-projects.html and a hosted website >

Re: [DISCUSS] FLIP-33: Terminate/Suspend Job with Savepoint

2019-03-05 Thread Elias Levy
Apologies for the late reply. I think this is badly needed, but I fear we are adding complexity by introducing yet two more stop commands. We'll have: cancel, stop, terminate. and suspend. We basically want to do two things: terminate a job with prejudice or stop a job safely. For the former

Re: [DISCUSS] Create a Flink ecosystem website

2019-03-05 Thread Bowen Li
Thanks for bring it up, Becket. That sounds very good to me. Spark also has such a page for ecosystem project https://spark.apache.org/third-party-projects.html and a hosted website https://spark-packages.org/ with metadata, categories/tags and stats mentioned in the doc. Bowen On Tue, Mar 5,

Re: [DISCUSS] Create a Flink ecosystem website

2019-03-05 Thread Robert Metzger
Hey Becket, This is a great idea! For this to be successful, we need to make sure the page is placed prominently so that the people submitting something will get attention for their contributions. I think a dynamic site would probably be better, if we want features such as up and downvoting or

[jira] [Created] (FLINK-11829) [checkpoint] FsCheckpointStateOutputStream might store state in files even state size below fileStateThreshold

2019-03-05 Thread Yun Tang (JIRA)
Yun Tang created FLINK-11829: Summary: [checkpoint] FsCheckpointStateOutputStream might store state in files even state size below fileStateThreshold Key: FLINK-11829 URL:

[jira] [Created] (FLINK-11828) [HA] Test instability: ZooKeeperHADispatcherTest.testStandbyDispatcherJobRecovery

2019-03-05 Thread Andrey Zagrebin (JIRA)
Andrey Zagrebin created FLINK-11828: --- Summary: [HA] Test instability: ZooKeeperHADispatcherTest.testStandbyDispatcherJobRecovery Key: FLINK-11828 URL: https://issues.apache.org/jira/browse/FLINK-11828

Error on importing flink source code into Intellij

2019-03-05 Thread Felipe Gutierrez
Hello, I imported the flink source code at my Intellij IDE following the steps described here https://ci.apache.org/projects/flink/flink-docs-stable/flinkDev/ide_setup.html#importing-flink and after I included the CheckStyle described here. When I use "mvn clean package -DskipTests" everything

re:WELCOME to dev@flink.apache.org

2019-03-05 Thread 107565445
Hi Guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is zhouhuiyu.

[jira] [Created] (FLINK-11827) Introduce DataFormatConverters to convert internal data format and java format

2019-03-05 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-11827: Summary: Introduce DataFormatConverters to convert internal data format and java format Key: FLINK-11827 URL: https://issues.apache.org/jira/browse/FLINK-11827

[jira] [Created] (FLINK-11826) Kafka09ITCase.testRateLimitedConsumer fails on Travis

2019-03-05 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11826: - Summary: Kafka09ITCase.testRateLimitedConsumer fails on Travis Key: FLINK-11826 URL: https://issues.apache.org/jira/browse/FLINK-11826 Project: Flink

[DISCUSS] Create a Flink ecosystem website

2019-03-05 Thread Becket Qin
Hi folks, I would like to start a discussion thread about creating a Flink ecosystem website. The website aims to help contributors who have developed projects around Flink share their work with the community. Please see the following doc for more details.

[jira] [Created] (FLINK-11825) Resolve name clash of StateTTL TimeCharacteristic class

2019-03-05 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-11825: - Summary: Resolve name clash of StateTTL TimeCharacteristic class Key: FLINK-11825 URL: https://issues.apache.org/jira/browse/FLINK-11825 Project: Flink

Re: [DISCUSS] -- Need to be able to access multiple s3 buckets with different authentication from within a single job

2019-03-05 Thread Stephan Ewen
Sorry for the very late reply. I would try to see if you can simply pass in an instance of filesystem into the source / sink you are using, rather than relying on getting the file system via the scheme. The only point where you probably need to accept the file system by scheme is for

[jira] [Created] (FLINK-11824) Event-time attribute cannot have same name as in original format

2019-03-05 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-11824: - Summary: Event-time attribute cannot have same name as in original format Key: FLINK-11824 URL: https://issues.apache.org/jira/browse/FLINK-11824 Project: Flink

[jira] [Created] (FLINK-11823) TrySerializer#duplicate does not create a proper duplication

2019-03-05 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-11823: Summary: TrySerializer#duplicate does not create a proper duplication Key: FLINK-11823 URL: https://issues.apache.org/jira/browse/FLINK-11823 Project: Flink

[jira] [Created] (FLINK-11822) Introduce Flink metadata handler

2019-03-05 Thread godfrey he (JIRA)
godfrey he created FLINK-11822: -- Summary: Introduce Flink metadata handler Key: FLINK-11822 URL: https://issues.apache.org/jira/browse/FLINK-11822 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-11821) fix the error package location of KafkaDeserializationSchemaWrapper.java file

2019-03-05 Thread lamber-ken (JIRA)
lamber-ken created FLINK-11821: -- Summary: fix the error package location of KafkaDeserializationSchemaWrapper.java file Key: FLINK-11821 URL: https://issues.apache.org/jira/browse/FLINK-11821 Project: