[jira] [Created] (FLINK-12286) The default log4j.properties will overwrite the customized log4j property file.

2019-04-22 Thread Tang Yan (JIRA)
Tang Yan created FLINK-12286: Summary: The default log4j.properties will overwrite the customized log4j property file. Key: FLINK-12286 URL: https://issues.apache.org/jira/browse/FLINK-12286 Project: Flin

[jira] [Created] (FLINK-12287) A document error in "StreamElement.java"

2019-04-22 Thread YangFei (JIRA)
YangFei created FLINK-12287: --- Summary: A document error in "StreamElement.java" Key: FLINK-12287 URL: https://issues.apache.org/jira/browse/FLINK-12287 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12288) Bump Calcite dependency to 1.19.0 in blink planner

2019-04-22 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12288: --- Summary: Bump Calcite dependency to 1.19.0 in blink planner Key: FLINK-12288 URL: https://issues.apache.org/jira/browse/FLINK-12288 Project: Flink Issue Type: New Feat

Apply for contributor permission

2019-04-22 Thread 张军
Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is zhangjun Thanks.

I want to apply Flink JIRA contributor

2019-04-22 Thread Armstrong
Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is Armstrongya.

[jira] [Created] (FLINK-12289) Fix bugs and typos in Memory manager

2019-04-22 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12289: Summary: Fix bugs and typos in Memory manager Key: FLINK-12289 URL: https://issues.apache.org/jira/browse/FLINK-12289 Project: Flink Issue Type: Bug Compon

[jira] [Created] (FLINK-12290) Fix the misleading exception message in SharedSlot class

2019-04-22 Thread Liya Fan (JIRA)
Liya Fan created FLINK-12290: Summary: Fix the misleading exception message in SharedSlot class Key: FLINK-12290 URL: https://issues.apache.org/jira/browse/FLINK-12290 Project: Flink Issue Type:

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

2019-04-22 Thread Piyush Narang
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://github.com/apache/flink/pull/8117 ). Would really appreciate if someone familiar with the flink file systems code could take a look at this review request and pr

Re: Support for ProtoBuf data format in StreamingFileSink

2019-04-22 Thread Kailash Dayanand
Friendly remainder. Any thoughts on this approach ? On Tue, Apr 9, 2019 at 11:36 AM Kailash Dayanand wrote: > cc'ing few folks who are interested in this discussion. > > On Tue, Apr 9, 2019 at 11:35 AM Kailash Dayanand > wrote: > >> Hello, >> >> I am looking to contribute a ProtoParquetWriter s

Re: Support for ProtoBuf data format in StreamingFileSink

2019-04-22 Thread Jakob Homan
+1. Sounds good to me. -Jakob On Mon, Apr 22, 2019 at 9:00 AM Kailash Dayanand wrote: > > Friendly remainder. Any thoughts on this approach ? > > On Tue, Apr 9, 2019 at 11:36 AM Kailash Dayanand wrote: > > > cc'ing few folks who are interested in this discussion. > > > > On Tue, Apr 9, 2019 at

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

2019-04-22 Thread jincheng sun
Hi everyone, Thank you for all of your feedback and comments in google doc! I have updated the google doc and add the UDFs part. For a short summary: - Python TableAPI - Flink introduces a set of Python Table API Interfaces which align with Flink Java Table API. It uses Py4j framework to commu

[jira] [Created] (FLINK-12291) Add benchmarks for the input processors

2019-04-22 Thread Haibo Sun (JIRA)
Haibo Sun created FLINK-12291: - Summary: Add benchmarks for the input processors Key: FLINK-12291 URL: https://issues.apache.org/jira/browse/FLINK-12291 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-12292) Add benchmarks for the input processors

2019-04-22 Thread Haibo Sun (JIRA)
Haibo Sun created FLINK-12292: - Summary: Add benchmarks for the input processors Key: FLINK-12292 URL: https://issues.apache.org/jira/browse/FLINK-12292 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12293) Fix some comment typos in flink-streaming-java.

2019-04-22 Thread Ji Liu (JIRA)
Ji Liu created FLINK-12293: -- Summary: Fix some comment typos in flink-streaming-java. Key: FLINK-12293 URL: https://issues.apache.org/jira/browse/FLINK-12293 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12294) kafka consumer, data locality

2019-04-22 Thread Sergey (JIRA)
Sergey created FLINK-12294: -- Summary: kafka consumer, data locality Key: FLINK-12294 URL: https://issues.apache.org/jira/browse/FLINK-12294 Project: Flink Issue Type: Improvement Component

[jira] [Created] (FLINK-12295) use retract aggregate function instead of regular aggregate function for retractable aggregate in code gen

2019-04-22 Thread godfrey he (JIRA)
godfrey he created FLINK-12295: -- Summary: use retract aggregate function instead of regular aggregate function for retractable aggregate in code gen Key: FLINK-12295 URL: https://issues.apache.org/jira/browse/FLINK-1

[jira] [Created] (FLINK-12296) Data loss silently in RocksDBStateBackend when more than one operator chained in a single task

2019-04-22 Thread Congxian Qiu(klion26) (JIRA)
Congxian Qiu(klion26) created FLINK-12296: - Summary: Data loss silently in RocksDBStateBackend when more than one operator chained in a single task Key: FLINK-12296 URL: https://issues.apache.org/jira/bro

[jira] [Created] (FLINK-12297) We should clean the closure for OutputTags

2019-04-22 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-12297: Summary: We should clean the closure for OutputTags Key: FLINK-12297 URL: https://issues.apache.org/jira/browse/FLINK-12297 Project: Flink Issue Type