about contributor permission

2019-06-11 Thread Xu Pingyong
Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is julien1987 .

[jira] [Created] (FLINK-7423) Always reuse an instance to get elements from an inputFormat

2017-08-10 Thread Xu Pingyong (JIRA)
Xu Pingyong created FLINK-7423: -- Summary: Always reuse an instance to get elements from an inputFormat Key: FLINK-7423 URL: https://issues.apache.org/jira/browse/FLINK-7423 Project: Flink

Re:Re: KeyBy fields do not support java.lang.Array?

2017-08-01 Thread Xu Pingyong
Hi Aljoscha: Thanks for your reply. Look forward to the final solution. Best Regards Xu Pingyong 在 2017-07-31 22:39:38,"Aljoscha Krettek" 写道: >Hi, > >Which version of Flink are you using? This issue should have been resolved at >least by 1.3.0: https://

KeyBy fields do not support java.lang.Array?

2017-07-31 Thread Xu Pingyong
What do you think about this case? Best Regards! Xu Pingyong

[jira] [Created] (FLINK-7201) ConcurrentModificationException in JobLeaderIdService

2017-07-14 Thread Xu Pingyong (JIRA)
Xu Pingyong created FLINK-7201: -- Summary: ConcurrentModificationException in JobLeaderIdService Key: FLINK-7201 URL: https://issues.apache.org/jira/browse/FLINK-7201 Project: Flink Issue Type

[jira] [Created] (FLINK-7152) use CombineOutputSelector instead of outputSelector list

2017-07-11 Thread Xu Pingyong (JIRA)
Xu Pingyong created FLINK-7152: -- Summary: use CombineOutputSelector instead of outputSelector list Key: FLINK-7152 URL: https://issues.apache.org/jira/browse/FLINK-7152 Project: Flink Issue

Re:[DISCUSS]refactor StreamConfig

2017-07-06 Thread Xu Pingyong
, it contains: 1) operator information: name, id 2) input serializer. 3) is.chain.start, is.chain.end (existed now, maybe moved later) 4) state.key.serializer What do you think? Best Regards! Xu Pingyong

Re:refactor StreamConfig

2017-07-04 Thread Xu Pingyong
you think? Best Regards! Xu Pingyong At 2017-07-05 11:02:56, "Xu Pingyong" wrote: >Hi Aljoscha: > > >Ye, I agree with you that an operator should not see output edges and >serialisers. The call getChainIndex() is used only in >OperatorConfig.toString(), it

Re: refactor StreamConfig

2017-07-04 Thread Xu Pingyong
Stephan meant is only that changing OperatorConfig to be serialisable. If StreamConfig is also serialisable, it need to be serialized into the Configuration, which is underlying before and flows across modules. Do you agree what I understand? Best Regards! Xu Pingyong At 2017-07-05 00

[jira] [Created] (FLINK-7065) separate the flink-streaming-java module from flink-clients

2017-07-03 Thread Xu Pingyong (JIRA)
Xu Pingyong created FLINK-7065: -- Summary: separate the flink-streaming-java module from flink-clients Key: FLINK-7065 URL: https://issues.apache.org/jira/browse/FLINK-7065 Project: Flink

[jira] [Created] (FLINK-7018) Reconstruct streamgraph to clear interface

2017-06-27 Thread Xu Pingyong (JIRA)
Xu Pingyong created FLINK-7018: -- Summary: Reconstruct streamgraph to clear interface Key: FLINK-7018 URL: https://issues.apache.org/jira/browse/FLINK-7018 Project: Flink Issue Type

[jira] [Created] (FLINK-7016) Move inputFormat to InputFormatVertex from TaskConfig

2017-06-27 Thread Xu Pingyong (JIRA)
Xu Pingyong created FLINK-7016: -- Summary: Move inputFormat to InputFormatVertex from TaskConfig Key: FLINK-7016 URL: https://issues.apache.org/jira/browse/FLINK-7016 Project: Flink Issue Type

[jira] [Created] (FLINK-7015) Separate OperatorConfig from StreamConfig

2017-06-27 Thread Xu Pingyong (JIRA)
Xu Pingyong created FLINK-7015: -- Summary: Separate OperatorConfig from StreamConfig Key: FLINK-7015 URL: https://issues.apache.org/jira/browse/FLINK-7015 Project: Flink Issue Type: Improvement