Re: Examples of Flink windowing unit tests, and option to bring in flink-spector to Flink

Thank you, Ted! I'll start from there! On Wed, May 3, 2017 at 5:52 PM, Ted Yu wrote: > See this related thread: > > http://search-hadoop.com/m/Flink/VkLeQcgMO91NWi982?subj= > flink+1+2+and+unit+testing+flinkspector > > On Wed, May 3, 2017 at 3:20 AM, Aljoscha Krettek

Re: request contributor permissions

Hi, In jira, I can not find the 'assign' issue button, can you check the permission? 2017-05-03 23:57 GMT+08:00 Till Rohrmann : > Hi, > > you should now have contributor rights. > > Cheers, > Till > > On Wed, May 3, 2017 at 5:42 PM, 杨华 wrote: > > >

[jira] [Created] (FLINK-6441) Improve the UDTF

Ruidong Li created FLINK-6441: - Summary: Improve the UDTF Key: FLINK-6441 URL: https://issues.apache.org/jira/browse/FLINK-6441 Project: Flink Issue Type: Improvement Reporter:

Re: Examples of Flink windowing unit tests, and option to bring in flink-spector to Flink

See this related thread: http://search-hadoop.com/m/Flink/VkLeQcgMO91NWi982?subj=flink+1+2+and+unit+testing+flinkspector On Wed, May 3, 2017 at 3:20 AM, Aljoscha Krettek wrote: > Hi, > Yes, unfortunately there are no good unit test examples for testing Flink > jobs (with

CFP for Dataworks Summit Sydney

The Australia/Pacific version of Dataworks Summit is in Sydney this year, September 20-21.   This is a great place to talk about work you are doing in Apache Flink or how you are using Flink.  Information on submitting an abstract is at

Trevor Grant has shared a document on Google Docs with you

Trevor Grant has invited you to view the following document: Open in Docs

[jira] [Created] (FLINK-6440) Noisy logs from metric fetcher

Stephan Ewen created FLINK-6440: --- Summary: Noisy logs from metric fetcher Key: FLINK-6440 URL: https://issues.apache.org/jira/browse/FLINK-6440 Project: Flink Issue Type: Bug

Re: Examples of Flink windowing unit tests, and option to bring in flink-spector to Flink

Hi, We should definitely wait wait Alexander has to say, he’s the original creator of flink-spectir. I’m cc’ing him but I’m not sure whether that’s still his current address. Best, Aljoscha > On 3. May 2017, at 19:14, Bowen Li wrote: > > Hi Aljoscha, >My team is

Re: Examples of Flink windowing unit tests, and option to bring in flink-spector to Flink

Hi Aljoscha, My team is looking at forking flink-spector and make it compatible with Flink 1.2. Thanks for confirming that we are in the right direction. What're the barriers of bring in flink-spector to Apache Flink? flink-spector is of Apache License 2.0, the same as Apache Flink. The

[jira] [Created] (FLINK-6439) Unclosed InputStream in OperatorSnapshotUtil#readStateHandle()

Ted Yu created FLINK-6439: - Summary: Unclosed InputStream in OperatorSnapshotUtil#readStateHandle() Key: FLINK-6439 URL: https://issues.apache.org/jira/browse/FLINK-6439 Project: Flink Issue Type:

Re: request contributor permissions

Hi, you should now have contributor rights. Cheers, Till On Wed, May 3, 2017 at 5:42 PM, 杨华 wrote: > Hi guys: > > Could somebody give me contributor permissions? my jira username is : > yanghua. > > Thanks. >

request contributor permissions

Hi guys: Could somebody give me contributor permissions? my jira username is : yanghua. Thanks.

[jira] [Created] (FLINK-6438) Expand docs home page a little

David Anderson created FLINK-6438: - Summary: Expand docs home page a little Key: FLINK-6438 URL: https://issues.apache.org/jira/browse/FLINK-6438 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-6437) Move history server configuration to a separate file

Stephan Ewen created FLINK-6437: --- Summary: Move history server configuration to a separate file Key: FLINK-6437 URL: https://issues.apache.org/jira/browse/FLINK-6437 Project: Flink Issue Type:

Re: Supported Hadoop versions

1) Flink 1.2 dropped Hadoop 1 but we don’t have a replacement “default”. 2) I’ll create a ticket to bump to the latest patch versions. 3) Uncertain if we can drop Hadoop 2.3 and/or 2.4. > On Apr 30, 2017, at 10:46 AM, Ted Yu wrote: > > For #1, +1 on dropping hadoop 1. >

[jira] [Created] (FLINK-6436) Bug in CommonCorrelate's generateCollector method when using udtf with udf

godfrey he created FLINK-6436: - Summary: Bug in CommonCorrelate's generateCollector method when using udtf with udf Key: FLINK-6436 URL: https://issues.apache.org/jira/browse/FLINK-6436 Project: Flink

Re: Examples of Flink windowing unit tests, and option to bring in flink-spector to Flink

Hi, Yes, unfortunately there are no good unit test examples for testing Flink jobs (with windowing or without). And yes, I would like to have something like flink-spector (or flink-spector) as part of Flink as the promoted way of doing Job testing. In my opinion this is blocked on a good way of

Re: [DISCUSS] Feature Freeze

This is the list of blocking issues for Flink 1.3: https://issues.apache.org/jira/browse/FLINK-5740?jql=project%20%3D%20FLINK%20AND%20status%20in%20(Open%2C%20%22In%20Progress%22%2C%20Reopened)%20AND%20priority%20%3D%20Blocker%20AND%20fixVersion%20%3D%201.3.0

[jira] [Created] (FLINK-6435) AsyncWaitOperator does not handle exceptions properly

Till Rohrmann created FLINK-6435: Summary: AsyncWaitOperator does not handle exceptions properly Key: FLINK-6435 URL: https://issues.apache.org/jira/browse/FLINK-6435 Project: Flink Issue