[jira] [Created] (FLINK-12362) Add container number config option for Flink on yarn job cluster mode

vinoyang created FLINK-12362: Summary: Add container number config option for Flink on yarn job cluster mode Key: FLINK-12362 URL: https://issues.apache.org/jira/browse/FLINK-12362 Project: Flink

[jira] [Created] (FLINK-12363) Refactor legacy rest handlers

vinoyang created FLINK-12363: Summary: Refactor legacy rest handlers Key: FLINK-12363 URL: https://issues.apache.org/jira/browse/FLINK-12363 Project: Flink Issue Type: Task Components:

Application for Contributor Permission

Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is zhouhaiqing. Thanks a lot for your help and time. Best Regards, Zhou Haiqing

Contributor Permission Application

Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission?My JIRA ID is JFrame. I would like to thank you for your generous help in this matter. JFrame

Application for Contributor Permission

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

Application for Contributor Permission

Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is zhouhaiqing. Thanks a lot for your help and time. Best Regards, Zhou Haiqing

[jira] [Created] (FLINK-12364) Introduce a CheckpointFailureManager to centralized manage checkpoint failure

vinoyang created FLINK-12364: Summary: Introduce a CheckpointFailureManager to centralized manage checkpoint failure Key: FLINK-12364 URL: https://issues.apache.org/jira/browse/FLINK-12364 Project: Flink

Re: Application for Contributor Permission

Hi, Welcome to the Flink community. I gave you contributor permissions for Jira. Best, Fabian Am Mo., 29. Apr. 2019 um 09:28 Uhr schrieb deng ziming < dengziming1...@gmail.com>: > Hi, > > I want to contribute to Apache Flink. > Would you please give me the contributor permission? > My JIRA ID i

Re: Contributor Permission Application

Hi JFrame, Welcome to the Flink community. I gave you contributor permissions for Jira. Best, Fabian Am Mo., 29. Apr. 2019 um 09:27 Uhr schrieb 张俸铭 <15963339...@163.com>: > Hi, > > I want to contribute to Apache Flink. > > Would you please give me the contributor permission?My JIRA ID is JFrame

Re: Application for Contributor Permission

Hi Zhou Haiqing, Welcome to the Flink community. I gave you contributor permissions for Jira. Best, Fabian Am Mo., 29. Apr. 2019 um 09:48 Uhr schrieb Hunk : > Hi, > I want to contribute to Apache Flink. Would you please give me the > contributor permission? > My JIRA ID is zhouhaiqing. >

Contribute to flink

Hi, I want to contribute to Flink, Would you please give me the contributor permission? And my JIRA ID is ft20...@qq.com . thanks.

Contributor Permission Request

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

[jira] [Created] (FLINK-12365) Add stats related catalog APIs

Xuefu Zhang created FLINK-12365: --- Summary: Add stats related catalog APIs Key: FLINK-12365 URL: https://issues.apache.org/jira/browse/FLINK-12365 Project: Flink Issue Type: Sub-task C

[jira] [Created] (FLINK-12366) Clean up Catalog APIs to make them more consistent and coherent

Xuefu Zhang created FLINK-12366: --- Summary: Clean up Catalog APIs to make them more consistent and coherent Key: FLINK-12366 URL: https://issues.apache.org/jira/browse/FLINK-12366 Project: Flink

RE: [DISCUSS] Bump required Maven version to 3.1.1 (from 3.0.3)

Hi Robert, Just as an FYI, Redhat 7 Enterprise also still ships with 3.0.5 as default. I did a manual upgrade to a later version on one of our Redhat servers, but it appears that this plugin doesn't use the repositories as are defined in a settings.xml, but tries to setup an external connection

RE: kafka partitions, data locality

Hi Stefan, Thnx for clarify! But still it remains an open question for me because we use keyBy method and I did not found any public interface of keys reassignment (smth like partionCustom for DataStream). As I heard, there is some internal mechanism with key groups and mapping key to groups. I

Re: [DISCUSS] Update our Roadmap

Hi everyone, Since we had no more comments on this thread, I think we proceed to update the roadmap. @Jeff Zhang I agree, we should add the Python efforts to the roadmap. Do you want to prepare a short paragraph that we can add to the document? Best, Fabian Am Mi., 17. Apr. 2019 um 15:04 Uhr s

[jira] [Created] (FLINK-12367) Create rich versions of functions for Scala

Dominik Wosiński created FLINK-12367: Summary: Create rich versions of functions for Scala Key: FLINK-12367 URL: https://issues.apache.org/jira/browse/FLINK-12367 Project: Flink Issue Typ

Re: [DISCUSS] Update our Roadmap

Hi Fabian, I think the mentioning of FLIP-32 is still valid as it has not yet been completed. I would like to add more details to it and also add more description about FLINK-11439. Big ongoing refactorings such as the type system rework should also be mentioned there. I will prepare a paragra

Re: [DISCUSS] Bump required Maven version to 3.1.1 (from 3.0.3)

The other connection you're referring to is likely the plugin downloading dependencies from npm. On 29/04/2019 13:50, Visser, M.J.H. (Martijn) wrote: Hi Robert, Just as an FYI, Redhat 7 Enterprise also still ships with 3.0.5 as default. I did a manual upgrade to a later version on one of our

Re: Flink Filesystems [FLINK-12115] - Review adding Azure FS support

Hey Piyush, sorry for the delay. Some folks have started reviewing your change now. Best, Robert On Mon, Apr 22, 2019 at 5:10 PM Piyush Narang wrote: > Hi folks, > > I put up this review a couple of weeks back and after an initial set of > comments, I haven’t heard back from anyone ( > https:/

Re: [DISCUSS] Update our Roadmap

jincheng(cc) is driving the python effort, I think he can help to prepare it. Fabian Hueske 于2019年4月29日周一 下午10:15写道： > Hi everyone, > > Since we had no more comments on this thread, I think we proceed to update > the roadmap. > > @Jeff Zhang I agree, we should add the Python efforts > to the

Re: [DISCUSS] Temporarily remove support for job rescaling via CLI action "modify"

Since there were no objections so far, I will proceed with removing the code [1]. [1] https://issues.apache.org/jira/browse/FLINK-12312 On Wed, Apr 24, 2019 at 1:38 PM Gary Yao wrote: > The idea is to also remove the rescaling code in the JobMaster. This will > make > it easier to remove the Ex

Re: [DISCUSS] Update our Roadmap

Great, thanks Jeff and Timo! @Jincheng do you want to write a paragraph about the Python effort and open a PR for it? I'll remove the issue about Hadoop convenience builds (FLINK-11266). Best, Fabian Am Mo., 29. Apr. 2019 um 16:37 Uhr schrieb Jeff Zhang : > jincheng(cc) is driving the python e

Re: [DISCUSS] Update our Roadmap

Sure, I will do it！I think the python table api info should in the roadmap! Thank you @Jeff @Fabian Fabian Hueske 于2019年4月29日 周一23:05写道： > Great, thanks Jeff and Timo! > > @Jincheng do you want to write a paragraph about the Python effort and > open a PR for it? > > I'll remove the issue about H

Re: [DISCUSS] Bump required Maven version to 3.1.1 (from 3.0.3)

Thanks Martijn. RHEL has quite long support cycles :) Would you still be okay with the version bump? (The workaround here being to manually download a later maven version for Flink builds) For the npm dependencies: Is Flink the only npm project build on these servers? (I'm asking because there mi

Re: Contributor Permission Request

Hi, I gave you permissions. On Mon, Apr 29, 2019 at 12:29 PM 张晨 wrote: > Hi, > I want to contribute to Apache Flink. > Would you please give me the contributor permission? > My JIRA ID is pekingzcc >

Re: Contribute to flink

Hi, I gave you permissions. On Mon, Apr 29, 2019 at 12:22 PM jake wrote: > Hi, > > I want to contribute to Flink, Would you please give me the contributor > permission? > And my JIRA ID is ft20...@qq.com . > > thanks.

Re: 申请 JIRA Contributor 权限

Hi, I was not able to reliably identify you. The Jira Id "yd" does not exist: https://issues.apache.org/jira/secure/ViewProfile.jspa?name=dy Is that you? https://issues.apache.org/jira/secure/ViewProfile.jspa?name=dey (the JIRA Id is "dey" then) On Sat, Apr 27, 2019 at 3:10 AM 叶问 wrote: > Hi, >

Re: [DISCUSS] Improve Queryable State and introduce a QueryServerProxy component

On Fri, Apr 26, 2019 at 8:58 PM vino yang wrote: > I agree with your opinion that "*Flink jobs don't sufficiently meet these > requirements to work as a replacement for a data store.*". Actually, I > think it's obviously not Flink's goal. > I would not be so sure. When data Artisans introduced

[jira] [Created] (FLINK-12368) add subtask index to FlinkKafkaConsumerBase logging, which can be very useful when debugging problem

Steven Zhen Wu created FLINK-12368: -- Summary: add subtask index to FlinkKafkaConsumerBase logging, which can be very useful when debugging problem Key: FLINK-12368 URL: https://issues.apache.org/jira/browse/FLINK

I want to contribute to Apache Flink

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

Re: [DISCUSS] Improve Queryable State and introduce a QueryServerProxy component

Hi Elias, OK, I think we do not need to agree on this point of view. In order to make the discussion more efficient, we need to focus a bit, let's talk about the query architecture's improvement. Best, Vino Elias Levy 于2019年4月30日周二 上午1:06写道： > On Fri, Apr 26, 2019 at 8:58 PM vino yang wrote:

Apply for confluence Wiki edit permission

Hi, I am going to create a new FLIP for Proposal of Flink Driver. Could you please give me the edit permission for this page: https://cw

[jira] [Created] (FLINK-12369) Introducing next version failover strategy interfaces and implement a region failover strategy with it

Zhu Zhu created FLINK-12369: --- Summary: Introducing next version failover strategy interfaces and implement a region failover strategy with it Key: FLINK-12369 URL: https://issues.apache.org/jira/browse/FLINK-12369

[jira] [Created] (FLINK-12370) Integrated Travis for Python Table API

sunjincheng created FLINK-12370: --- Summary: Integrated Travis for Python Table API Key: FLINK-12370 URL: https://issues.apache.org/jira/browse/FLINK-12370 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12371) Add support for converting (NOT) IN/ (NOT) EXISTS to SemiJoin, and generating optimized logical plan

godfrey he created FLINK-12371: -- Summary: Add support for converting (NOT) IN/ (NOT) EXISTS to SemiJoin, and generating optimized logical plan Key: FLINK-12371 URL: https://issues.apache.org/jira/browse/FLINK-12371

Re: [DISCUSS] Update our Roadmap

Hi Jeff&Fabian, I have open the PR about add Python Table API section to the roadmap. I appreciate if you have time to look at it. :) https://github.com/apache/flink-web/pull/204 Regards, Jincheng jincheng sun 于2019年4月29日周一 下午11:12写道： > Sure, I will do it！I think the python table api info sho

[jira] [Created] (FLINK-12372) Implement ExecutionSlotAllocator

Gary Yao created FLINK-12372: Summary: Implement ExecutionSlotAllocator Key: FLINK-12372 URL: https://issues.apache.org/jira/browse/FLINK-12372 Project: Flink Issue Type: Sub-task Compo