Contributor permission application

2019-03-04 Thread zenppl liu
Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is zenppl@gmail.com.

[jira] [Created] (FLINK-11804) Make sure the CloseableRegistry used in backend builder is registered with task

2019-03-04 Thread Yu Li (JIRA)
Yu Li created FLINK-11804: - Summary: Make sure the CloseableRegistry used in backend builder is registered with task Key: FLINK-11804 URL: https://issues.apache.org/jira/browse/FLINK-11804 Project: Flink

Re: [DISCUSS] Introducing Builder in FlinkKafkaProducer

2019-03-04 Thread Piotr Nowojski
Hi, This would definitely be beneficial. And yes, we would have to keep the current constructors for at least one release marked as @Deprecated. Piotrek > On 4 Mar 2019, at 08:49, Александр wrote: > > Hi, devs. I recently joined the community and I'm trying to understand the > project module

Re: Contributor permission application

2019-03-04 Thread Fabian Hueske
Hi, Welcome to the Flink community. Jira does not use the email address as user name. Hence I couldn't add you. Please check again and send me your user name. Thank you, Fabian Am Mo., 4. März 2019 um 10:29 Uhr schrieb zenppl liu : > Hi, > > I want to contribute to Apache Flink. > Would you ple

Re: [DISCUSS] Improve the flinkbot

2019-03-04 Thread Robert Metzger
GitHub has two methods for authentication with the APIs: a) using an account's oauth token b) using the GitHub Apps API Most of the libraries for the GH API use a), so does Flinkbot. The problem with a) is that it does not allow for fine-grained access control, and Infra does not want to give Flin

Re: Flink Custom SourceFunction and SinkFunction

2019-03-04 Thread Piotr Nowojski
Hi, I couldn’t find any references to your question neither I haven’t seen such use case, but: Re 1. It looks like it could work Re 2. It should work as well, but just try to use StreamingFileSink Re 3. For custom source/sink function, if you do not care data processing guarantees it’s quite

Contributor permission

2019-03-04 Thread 张大伟
Hi, I want to contribute code to Apache Flink. Would you give the contributor permission ,and my JIRA ID is *aloyszhang .*

[jira] [Created] (FLINK-11805) A Common External Shuffle Service Framework

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11805: -- Summary: A Common External Shuffle Service Framework Key: FLINK-11805 URL: https://issues.apache.org/jira/browse/FLINK-11805 Project: Flink Issue Type: N

[jira] [Created] (FLINK-11806) Import shaded jetcd

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11806: -- Summary: Import shaded jetcd Key: FLINK-11806 URL: https://issues.apache.org/jira/browse/FLINK-11806 Project: Flink Issue Type: Task Components

[jira] [Created] (FLINK-11807) Implement etcd based LeaderElectionService and LeaderRetrievalService

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11807: -- Summary: Implement etcd based LeaderElectionService and LeaderRetrievalService Key: FLINK-11807 URL: https://issues.apache.org/jira/browse/FLINK-11807 Project: Fl

[jira] [Created] (FLINK-11808) etcd based SharedCount or sequencer

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11808: -- Summary: etcd based SharedCount or sequencer Key: FLINK-11808 URL: https://issues.apache.org/jira/browse/FLINK-11808 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-11809) Implement etcd based StateHandleStore

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11809: -- Summary: Implement etcd based StateHandleStore Key: FLINK-11809 URL: https://issues.apache.org/jira/browse/FLINK-11809 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-11810) Implement etcd based CheckpointRecoveryFactory

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11810: -- Summary: Implement etcd based CheckpointRecoveryFactory Key: FLINK-11810 URL: https://issues.apache.org/jira/browse/FLINK-11810 Project: Flink Issue Type

Re: Contributor permission

2019-03-04 Thread Fabian Hueske
Hi, Welcome to the Flink community. I've given you contributor permissions for Jira. Best, Fabian Am Mo., 4. März 2019 um 12:39 Uhr schrieb 张大伟 : > Hi, > I want to contribute code to Apache Flink. > Would you give the contributor permission ,and > my JIRA ID is *aloyszhang .* >

[jira] [Created] (FLINK-11811) Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11811: -- Summary: Implement etcd based RunningJobsRegistry and SubmittedJobGraphStore Key: FLINK-11811 URL: https://issues.apache.org/jira/browse/FLINK-11811 Project: Flin

[jira] [Created] (FLINK-11812) Composite etcd based HighAvailability components

2019-03-04 Thread MalcolmSanders (JIRA)
MalcolmSanders created FLINK-11812: -- Summary: Composite etcd based HighAvailability components Key: FLINK-11812 URL: https://issues.apache.org/jira/browse/FLINK-11812 Project: Flink Issue Ty

Re: [DISCUSS] Introducing Builder in FlinkKafkaProducer

2019-03-04 Thread Aljoscha Krettek
I think before doing anything quick here we should look at this more holistically: How do the different connectors work, i.e. how do you construct them? Can we find a way to unify that, maybe using a Builder pattern? And then should we make a plan of getting the connectors there, possibly with a

[jira] [Created] (FLINK-11813) Standby per job mode Dispatchers don't know job's JobSchedulingStatus

2019-03-04 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-11813: - Summary: Standby per job mode Dispatchers don't know job's JobSchedulingStatus Key: FLINK-11813 URL: https://issues.apache.org/jira/browse/FLINK-11813 Project: Flin

[jira] [Created] (FLINK-11815) Support execution with static resources (Flip-6): E.g. spreading tasks across available set of TMs

2019-03-04 Thread Piotr Nowojski (JIRA)
Piotr Nowojski created FLINK-11815: -- Summary: Support execution with static resources (Flip-6): E.g. spreading tasks across available set of TMs Key: FLINK-11815 URL: https://issues.apache.org/jira/browse/FLINK-1

[jira] [Created] (FLINK-11814) Changes of FLINK-11516 causes compilation failure

2019-03-04 Thread Yu Li (JIRA)
Yu Li created FLINK-11814: - Summary: Changes of FLINK-11516 causes compilation failure Key: FLINK-11814 URL: https://issues.apache.org/jira/browse/FLINK-11814 Project: Flink Issue Type: Bug Affec

[jira] [Created] (FLINK-11816) Changes of FLINK-11516 causes compilation failure

2019-03-04 Thread Yu Li (JIRA)
Yu Li created FLINK-11816: - Summary: Changes of FLINK-11516 causes compilation failure Key: FLINK-11816 URL: https://issues.apache.org/jira/browse/FLINK-11816 Project: Flink Issue Type: Bug

Re: [DISCUSS] Introducing Builder in FlinkKafkaProducer

2019-03-04 Thread Piotr Nowojski
Definitely we could go one step further. Having one common way to initialise connectors (I think this definitely would need a Builder pattern) might be even better, but it’s also much larger change with more things that need to be considered. Like what about type safety of configuration paramete

[jira] [Created] (FLINK-11817) DataStream API Tutorial uses deprecated fold function

2019-03-04 Thread Michael Holler (JIRA)
Michael Holler created FLINK-11817: -- Summary: DataStream API Tutorial uses deprecated fold function Key: FLINK-11817 URL: https://issues.apache.org/jira/browse/FLINK-11817 Project: Flink Iss

Re: Contributor permission application

2019-03-04 Thread zenppl liu
Hi, Sorry for the wrong ID. My username is zenppl. Thank you, Zenppl > 在 2019年3月4日,下午6:34,Fabian Hueske 写道: > > Hi, > > Welcome to the Flink community. > Jira does not use the email address as user name. Hence I couldn't add you. > Please check again and send me your user name. > > Thank you,

[jira] [Created] (FLINK-11818) Provide pipe transformation function for DataSet API

2019-03-04 Thread vinoyang (JIRA)
vinoyang created FLINK-11818: Summary: Provide pipe transformation function for DataSet API Key: FLINK-11818 URL: https://issues.apache.org/jira/browse/FLINK-11818 Project: Flink Issue Type: Impr

[jira] [Created] (FLINK-11819) Additional attribute for order by not support by flink sql, but told supported in doc

2019-03-04 Thread Lifei Chen (JIRA)
Lifei Chen created FLINK-11819: -- Summary: Additional attribute for order by not support by flink sql, but told supported in doc Key: FLINK-11819 URL: https://issues.apache.org/jira/browse/FLINK-11819 Pro

[jira] [Created] (FLINK-11820) KafkaDeserializationSchemaWrapper should filter record which value is null

2019-03-04 Thread lamber-ken (JIRA)
lamber-ken created FLINK-11820: -- Summary: KafkaDeserializationSchemaWrapper should filter record which value is null Key: FLINK-11820 URL: https://issues.apache.org/jira/browse/FLINK-11820 Project: Flink