[jira] [Created] (FLINK-12093) Apache Flink:Active MQ consumer job is getting finished after first message consume.

2019-04-03 Thread shiv kumar (JIRA)
shiv kumar created FLINK-12093: -- Summary: Apache Flink:Active MQ consumer job is getting finished after first message consume. Key: FLINK-12093 URL: https://issues.apache.org/jira/browse/FLINK-12093 Proj

[jira] [Created] (FLINK-12094) Introduce sort merge join operator to blink batch

2019-04-03 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12094: Summary: Introduce sort merge join operator to blink batch Key: FLINK-12094 URL: https://issues.apache.org/jira/browse/FLINK-12094 Project: Flink Issue Type:

Re: [Proposal] Shuffle resources lifecycle management

2019-04-03 Thread zhijiang
Hi Andrey, Thanks for concluding this valuable proposal. It really extends and enhances the details of partition lifecycle management ever mentioned in FLIP-31. I reviewed the google doc and agreed the general points in it. One implict point in doc is that the shuffle is not limted to only serv

[jira] [Created] (FLINK-12095) Canceling vs cancelling

2019-04-03 Thread Mike Pedersen (JIRA)
Mike Pedersen created FLINK-12095: - Summary: Canceling vs cancelling Key: FLINK-12095 URL: https://issues.apache.org/jira/browse/FLINK-12095 Project: Flink Issue Type: Bug Component

Re: Apply for JIRA permission

2019-04-03 Thread Chesnay Schepler
You now have contributor permissions. On 03/04/2019 08:18, Hefei Li wrote: Hi guys, I want to contribute to Apache Flink. Would you please give me the permission as a contributor ? My JIRA username is *lhfei *. === Best Regards Hefei LiHefei Li MP: +86 1870158

[jira] [Created] (FLINK-12096) Flink counter state getting stuck on usin

2019-04-03 Thread Yogesh Nandigamq (JIRA)
Yogesh Nandigamq created FLINK-12096: Summary: Flink counter state getting stuck on usin Key: FLINK-12096 URL: https://issues.apache.org/jira/browse/FLINK-12096 Project: Flink Issue Type:

[jira] [Created] (FLINK-12097) Flink SQL hangs in StreamTableEnvironment.sqlUpdate, keeps executing and seems never stop, finally lead to java.lang.OutOfMemoryError: GC overhead limit exceeded

2019-04-03 Thread xu (JIRA)
xu created FLINK-12097: -- Summary: Flink SQL hangs in StreamTableEnvironment.sqlUpdate, keeps executing and seems never stop, finally lead to java.lang.OutOfMemoryError: GC overhead limit exceeded Key: FLINK-12097 URL: https

[DISCUSS] Drop Elasticssearch 1 connector

2019-04-03 Thread Chesnay Schepler
Hello everyone, I'm proposing to remove the connector for elasticsearch 1. The connector is used significantly less than more recent versions (2&5 are downloaded 4-5x more), and hasn't seen any development for over a hear, yet still incurred maintenance overhead due to licensing and testing.

[jira] [Created] (FLINK-12098) Add support for generating optimized logical plan for simple group aggregate on batch

2019-04-03 Thread godfrey he (JIRA)
godfrey he created FLINK-12098: -- Summary: Add support for generating optimized logical plan for simple group aggregate on batch Key: FLINK-12098 URL: https://issues.apache.org/jira/browse/FLINK-12098 Pro

[jira] [Created] (FLINK-12099) Elasticsearch(1)SinkITCase fails on Java 9

2019-04-03 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-12099: Summary: Elasticsearch(1)SinkITCase fails on Java 9 Key: FLINK-12099 URL: https://issues.apache.org/jira/browse/FLINK-12099 Project: Flink Issue Type

[jira] [Created] (FLINK-12100) Kafka 0.10 tests fail on Java 9

2019-04-03 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-12100: Summary: Kafka 0.10 tests fail on Java 9 Key: FLINK-12100 URL: https://issues.apache.org/jira/browse/FLINK-12100 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12101) Race condition when concurrenty running uploaded jars via REST

2019-04-03 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-12101: -- Summary: Race condition when concurrenty running uploaded jars via REST Key: FLINK-12101 URL: https://issues.apache.org/jira/browse/FLINK-12101 Project: F

[jira] [Created] (FLINK-12102) FlinkILoopTest fails on Java 9

2019-04-03 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-12102: Summary: FlinkILoopTest fails on Java 9 Key: FLINK-12102 URL: https://issues.apache.org/jira/browse/FLINK-12102 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12103) Extend builtin operator metrics with user defined scope and variables

2019-04-03 Thread Ben Marini (JIRA)
Ben Marini created FLINK-12103: -- Summary: Extend builtin operator metrics with user defined scope and variables Key: FLINK-12103 URL: https://issues.apache.org/jira/browse/FLINK-12103 Project: Flink

[jira] [Created] (FLINK-12104) Flink Kafka fails with Incompatible KafkaProducer version / NoSuchFieldException sequenceNumbers

2019-04-03 Thread Tim (JIRA)
Tim created FLINK-12104: --- Summary: Flink Kafka fails with Incompatible KafkaProducer version / NoSuchFieldException sequenceNumbers Key: FLINK-12104 URL: https://issues.apache.org/jira/browse/FLINK-12104 Projec

[jira] [Created] (FLINK-12105) TUMBLE INTERVAL value errors out for 100 or more value

2019-04-03 Thread Vinod Mehra (JIRA)
Vinod Mehra created FLINK-12105: --- Summary: TUMBLE INTERVAL value errors out for 100 or more value Key: FLINK-12105 URL: https://issues.apache.org/jira/browse/FLINK-12105 Project: Flink Issue Ty

Re: [DISCUSS] FLIP-38 Support python language in flink TableAPI

2019-04-03 Thread Shuyi Chen
Thanks a lot for driving the FLIP, jincheng. The approach looks good. Adding multi-lang support sounds a promising direction to expand the footprint of Flink. Do we have plan for adding Golang support? As many backend engineers nowadays are familiar with Go, but probably not Java as much, adding Go

[CANCEL][VOTE] Release 1.8.0, release candidate #4

2019-04-03 Thread Aljoscha Krettek
I’m hereby canceling the vote for Flink 1.8.0 RC4 in favour of a new RC that I will create shortly now that the blockers are resolved. > On 1. Apr 2019, at 13:21, Till Rohrmann wrote: > > Thanks for reporting this problem and opening a JIRA issue. I've created a > fix for the problem [1]. > >

[jira] [Created] (FLINK-12106) Jobmanager is killing FINISHED taskmanger containers, causing exception in still running Taskmanagers an

2019-04-03 Thread John (JIRA)
John created FLINK-12106: Summary: Jobmanager is killing FINISHED taskmanger containers, causing exception in still running Taskmanagers an Key: FLINK-12106 URL: https://issues.apache.org/jira/browse/FLINK-12106

Re: [DISCUSS] FLIP-38 Support python language in flink TableAPI

2019-04-03 Thread Thomas Weise
Thanks for putting this proposal together. It would be nice, if you could share a few use case examples (maybe add them as section to the FLIP?). The reason I ask: The table API is immensely useful, but it isn't clear to me what value other language bindings provide without UDF support. With FLIP

[jira] [Created] (FLINK-12107) Use Proxy For DataDog Validation

2019-04-03 Thread Luka Jurukovski (JIRA)
Luka Jurukovski created FLINK-12107: --- Summary: Use Proxy For DataDog Validation Key: FLINK-12107 URL: https://issues.apache.org/jira/browse/FLINK-12107 Project: Flink Issue Type: Improvemen

contributor permission

2019-04-03 Thread 邵志鹏
Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is shaozhipeng. Thank you very much.

[VOTE] Release 1.8.0, release candidate #5

2019-04-03 Thread Aljoscha Krettek
Hi everyone, Please review and vote on the release candidate 5 for Flink 1.8.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1], * the off

Re: [DISCUSS] FLIP-38 Support python language in flink TableAPI

2019-04-03 Thread jincheng sun
Hi Jeff, thank you for your encouragement and valuable comments on the google doc. I saw that you participated in many pySpark discussions a long time ago, I am very grateful and look forward to your follow-up comments on pyFlink! Thanks, Jincheng Jeff Zhang 于2019年4月2日周二 下午10:53写道: > Thanks ji

Re: [DISCUSS] FLIP-38 Support python language in flink TableAPI

2019-04-03 Thread jincheng sun
Hi Shuyi, Glad to see your feedback and port more requirements about multi-language! I think the Flink community is very much looking forward to more language support, of course, Golang should be in the future support list. Since the topic of supporting Python on Flink has been researched and dis

[jira] [Created] (FLINK-12108) Simplify splitting expressions into projections, aggregations & windowProperties

2019-04-03 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-12108: Summary: Simplify splitting expressions into projections, aggregations & windowProperties Key: FLINK-12108 URL: https://issues.apache.org/jira/browse/FLINK-12108