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

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

+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

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

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

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

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

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:

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

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

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

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

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:

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

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

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

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

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

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:

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

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

RE: [DISCUSS] Flink ML roadmap

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

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

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

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: