[jira] [Created] (FLINK-6004) Allow FlinkKinesisConsumer to skip corrupted messages

2017-03-08 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-6004: -- Summary: Allow FlinkKinesisConsumer to skip corrupted messages Key: FLINK-6004 URL: https://issues.apache.org/jira/browse/FLINK-6004 Project: Flink

Re: [DISCUSS] Side Outputs and Split/Select

2017-03-08 Thread Jamie Grier
+1 On Sat, Mar 4, 2017 at 12:25 AM, Kostas Kloudas wrote: > +1 > > > On Mar 2, 2017, at 1:08 PM, Fabian Hueske wrote: > > > > +1 > > > > 2017-03-02 12:11 GMT+01:00 Aljoscha Krettek : > > > >> Ok, so it seems we have to go with the OutputTag variant for windows as > >> well, for now. > >> > >> F

[jira] [Created] (FLINK-6003) Change docker image to be based on the openjdk one (debian+alpine)

2017-03-08 Thread JIRA
Ismaël Mejía created FLINK-6003: --- Summary: Change docker image to be based on the openjdk one (debian+alpine) Key: FLINK-6003 URL: https://issues.apache.org/jira/browse/FLINK-6003 Project: Flink

Re: FLINK-5734 : Code Generation for NormalizedKeySorter

2017-03-08 Thread Greg Hogan
Hi Pat, I’m still trying to understand the implications of Java’s Class Hierarchy Analysis [0]. Flink currently uses only a single implementation of InMemorySorter, which is NormalizedKeySorter. FLINK-4705 adds support for FixedLengthRecordSorter for Flink’s Value types and Tuples. This propo

[jira] [Created] (FLINK-6002) Setup: Download and Start Flink/MacOS X in Quickstart page is not rendered correctly

2017-03-08 Thread Bowen Li (JIRA)
Bowen Li created FLINK-6002: --- Summary: Setup: Download and Start Flink/MacOS X in Quickstart page is not rendered correctly Key: FLINK-6002 URL: https://issues.apache.org/jira/browse/FLINK-6002 Project: Fli

[jira] [Created] (FLINK-6001) NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness

2017-03-08 Thread Vladislav Pernin (JIRA)
Vladislav Pernin created FLINK-6001: --- Summary: NPE on TumblingEventTimeWindows with ContinuousEventTimeTrigger and allowedLateness Key: FLINK-6001 URL: https://issues.apache.org/jira/browse/FLINK-6001

[jira] [Created] (FLINK-6000) Can not start HA cluster with start-cluster.sh

2017-03-08 Thread Dawid Wysakowicz (JIRA)
Dawid Wysakowicz created FLINK-6000: --- Summary: Can not start HA cluster with start-cluster.sh Key: FLINK-6000 URL: https://issues.apache.org/jira/browse/FLINK-6000 Project: Flink Issue Type

[jira] [Created] (FLINK-5999) MiniClusterITCase.runJobWithMultipleRpcServices fails

2017-03-08 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5999: -- Summary: MiniClusterITCase.runJobWithMultipleRpcServices fails Key: FLINK-5999 URL: https://issues.apache.org/jira/browse/FLINK-5999 Project: Flink Issue Type: T

[jira] [Created] (FLINK-5998) Un-fat Hadoop from Flink fat jar

2017-03-08 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-5998: - Summary: Un-fat Hadoop from Flink fat jar Key: FLINK-5998 URL: https://issues.apache.org/jira/browse/FLINK-5998 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5997) Docker build tools should inline GPG key to verify HTTP Flink release download

2017-03-08 Thread Patrick Lucas (JIRA)
Patrick Lucas created FLINK-5997: Summary: Docker build tools should inline GPG key to verify HTTP Flink release download Key: FLINK-5997 URL: https://issues.apache.org/jira/browse/FLINK-5997 Project:

[jira] [Created] (FLINK-5996) Jobmanager HA should not crash on lost ZK node

2017-03-08 Thread Gyula Fora (JIRA)
Gyula Fora created FLINK-5996: - Summary: Jobmanager HA should not crash on lost ZK node Key: FLINK-5996 URL: https://issues.apache.org/jira/browse/FLINK-5996 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5995) Get a Exception when creating the ListStateDescriptor with a TypeInformation

2017-03-08 Thread sunjincheng (JIRA)
sunjincheng created FLINK-5995: -- Summary: Get a Exception when creating the ListStateDescriptor with a TypeInformation Key: FLINK-5995 URL: https://issues.apache.org/jira/browse/FLINK-5995 Project: Flin

[jira] [Created] (FLINK-5994) Add Janino to flink-table JAR file

2017-03-08 Thread Timo Walther (JIRA)
Timo Walther created FLINK-5994: --- Summary: Add Janino to flink-table JAR file Key: FLINK-5994 URL: https://issues.apache.org/jira/browse/FLINK-5994 Project: Flink Issue Type: Bug Comp

RE: [DISCUSS] Flink ML roadmap

2017-03-08 Thread Kavulya, Soila P
Hi Theodore, We had put together a proposal for an ML DSL in Apache Beam. We had developed a couple of scoring engines as part of TAP https://github.com/tapanalyticstoolkit/model-scoring-java and https://github.com/tapanalyticstoolkit/scoring-pipelines. However, our group is no longer actively

[jira] [Created] (FLINK-5993) Add section about Azure deployment

2017-03-08 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-5993: -- Summary: Add section about Azure deployment Key: FLINK-5993 URL: https://issues.apache.org/jira/browse/FLINK-5993 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-5992) Enable file registration at distributed cache in stream execution environment

2017-03-08 Thread Zohar Mizrahi (JIRA)
Zohar Mizrahi created FLINK-5992: Summary: Enable file registration at distributed cache in stream execution environment Key: FLINK-5992 URL: https://issues.apache.org/jira/browse/FLINK-5992 Project: