[jira] [Created] (FLINK-6107) Add custom checkstyle for flink-streaming-java

2017-03-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6107: --- Summary: Add custom checkstyle for flink-streaming-java Key: FLINK-6107 URL: https://issues.apache.org/jira/browse/FLINK-6107 Project: Flink Issue Type

[jira] [Created] (FLINK-6108) Add sum(fieldName) to sum based on named POJO fields

2017-03-18 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6108: - Summary: Add sum(fieldName) to sum based on named POJO fields Key: FLINK-6108 URL: https://issues.apache.org/jira/browse/FLINK-6108 Project: Flink Issue Ty

Re: [DISCUSS] Code style / checkstyle

2017-03-18 Thread Aljoscha Krettek
I added an issue for adding a custom checkstyle.xml for flink-streaming-java so that we can gradually add checks: https://issues.apache.org/jira/browse/FLINK-6107. I outlined the procedure in the Jira. We can use this as a pilot project and see how it goes and then gradually also apply to other

[jira] [Created] (FLINK-6109) Add "consumer lag" report metric to FlinkKafkaConsumer

2017-03-18 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6109: -- Summary: Add "consumer lag" report metric to FlinkKafkaConsumer Key: FLINK-6109 URL: https://issues.apache.org/jira/browse/FLINK-6109 Project: Flink

[jira] [Created] (FLINK-6110) Flink unnecessarily repeats shared work triggered by different blocking sinks, leading to massive inefficiency

2017-03-18 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6110: - Summary: Flink unnecessarily repeats shared work triggered by different blocking sinks, leading to massive inefficiency Key: FLINK-6110 URL: https://issues.apache.org/jira/brows

[jira] [Created] (FLINK-6111) Remove sleep after python process generation

2017-03-18 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-6111: --- Summary: Remove sleep after python process generation Key: FLINK-6111 URL: https://issues.apache.org/jira/browse/FLINK-6111 Project: Flink Issue Type:

[jira] [Created] (FLINK-6112) Support new numerical functions when calcite release

2017-03-18 Thread Tao Meng (JIRA)
Tao Meng created FLINK-6112: --- Summary: Support new numerical functions when calcite release Key: FLINK-6112 URL: https://issues.apache.org/jira/browse/FLINK-6112 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6113) Implement split/select with OutputTag

2017-03-18 Thread Chen Qin (JIRA)
Chen Qin created FLINK-6113: --- Summary: Implement split/select with OutputTag Key: FLINK-6113 URL: https://issues.apache.org/jira/browse/FLINK-6113 Project: Flink Issue Type: Improvement C

Re: Machine Learning on Flink - Next steps

2017-03-18 Thread Stavros Kontopoulos
Hi all... I agree about the tensorflow integration it seems to be important from what I hear. Should we sign up somewhere for the working groups (gdcos)? I would like to start helping with the model serving feature. Best Regards, Stavros On Fri, Mar 17, 2017 at 10:34 PM, Gábor Hermann wrote: >

[jira] [Created] (FLINK-6114) Type checking fails with generics, even when concrete type of field is not needed

2017-03-18 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6114: - Summary: Type checking fails with generics, even when concrete type of field is not needed Key: FLINK-6114 URL: https://issues.apache.org/jira/browse/FLINK-6114 Pro

[jira] [Created] (FLINK-6115) Need more helpful error message when trying to serialize a tuple with a null field

2017-03-18 Thread Luke Hutchison (JIRA)
Luke Hutchison created FLINK-6115: - Summary: Need more helpful error message when trying to serialize a tuple with a null field Key: FLINK-6115 URL: https://issues.apache.org/jira/browse/FLINK-6115 Pr

[jira] [Created] (FLINK-6116) Watermarks don't work when unioning with same DataStream

2017-03-18 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6116: --- Summary: Watermarks don't work when unioning with same DataStream Key: FLINK-6116 URL: https://issues.apache.org/jira/browse/FLINK-6116 Project: Flink