[jira] [Created] (FLINK-7425) Support Map in TypeExtractor

2017-08-10 Thread Timo Walther (JIRA)
Timo Walther created FLINK-7425: --- Summary: Support Map in TypeExtractor Key: FLINK-7425 URL: https://issues.apache.org/jira/browse/FLINK-7425 Project: Flink Issue Type: Improvement Co

[jira] [Created] (FLINK-7424) `CEP` component make `KeyedStream` choose wrong channel

2017-08-10 Thread Benedict Jin (JIRA)
Benedict Jin created FLINK-7424: --- Summary: `CEP` component make `KeyedStream` choose wrong channel Key: FLINK-7424 URL: https://issues.apache.org/jira/browse/FLINK-7424 Project: Flink Issue Typ

[jira] [Created] (FLINK-7423) Always reuse an instance to get elements from an inputFormat

2017-08-10 Thread Xu Pingyong (JIRA)
Xu Pingyong created FLINK-7423: -- Summary: Always reuse an instance to get elements from an inputFormat Key: FLINK-7423 URL: https://issues.apache.org/jira/browse/FLINK-7423 Project: Flink Iss

[jira] [Created] (FLINK-7422) Upgrade Kinesis Client Library (KCL) in flink-connector-kinesis from 1.6.2 to 1.8.1

2017-08-10 Thread Bowen Li (JIRA)
Bowen Li created FLINK-7422: --- Summary: Upgrade Kinesis Client Library (KCL) in flink-connector-kinesis from 1.6.2 to 1.8.1 Key: FLINK-7422 URL: https://issues.apache.org/jira/browse/FLINK-7422 Project: Flin

[jira] [Created] (FLINK-7421) AvroRow(De)serializationSchema not serializable

2017-08-10 Thread Timo Walther (JIRA)
Timo Walther created FLINK-7421: --- Summary: AvroRow(De)serializationSchema not serializable Key: FLINK-7421 URL: https://issues.apache.org/jira/browse/FLINK-7421 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7420) Move all Avro code to flink-avro

2017-08-10 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-7420: --- Summary: Move all Avro code to flink-avro Key: FLINK-7420 URL: https://issues.apache.org/jira/browse/FLINK-7420 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7419) Shade jackson dependency in flink-avro

2017-08-10 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-7419: --- Summary: Shade jackson dependency in flink-avro Key: FLINK-7419 URL: https://issues.apache.org/jira/browse/FLINK-7419 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7417) Create flink-shaded-jackson

2017-08-10 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-7417: --- Summary: Create flink-shaded-jackson Key: FLINK-7417 URL: https://issues.apache.org/jira/browse/FLINK-7417 Project: Flink Issue Type: Sub-task Compon

[jira] [Created] (FLINK-7418) Replace all uses of jackson with flink-shaded-jackson

2017-08-10 Thread Stephan Ewen (JIRA)
Stephan Ewen created FLINK-7418: --- Summary: Replace all uses of jackson with flink-shaded-jackson Key: FLINK-7418 URL: https://issues.apache.org/jira/browse/FLINK-7418 Project: Flink Issue Type:

[jira] [Created] (FLINK-7416) Implement Netty receiver outgoing pipeline for credit-based

2017-08-10 Thread zhijiang (JIRA)
zhijiang created FLINK-7416: --- Summary: Implement Netty receiver outgoing pipeline for credit-based Key: FLINK-7416 URL: https://issues.apache.org/jira/browse/FLINK-7416 Project: Flink Issue Type:

[jira] [Created] (FLINK-7415) Add comments for cassandra test class `BatchExample`

2017-08-10 Thread Hai Zhou (JIRA)
Hai Zhou created FLINK-7415: --- Summary: Add comments for cassandra test class `BatchExample` Key: FLINK-7415 URL: https://issues.apache.org/jira/browse/FLINK-7415 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-7414) Hardcode scala.version to 2.11 in flink-quickstart-scala

2017-08-10 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7414: --- Summary: Hardcode scala.version to 2.11 in flink-quickstart-scala Key: FLINK-7414 URL: https://issues.apache.org/jira/browse/FLINK-7414 Project: Flink

[jira] [Created] (FLINK-7413) Release Hadoop 2.8.x convenience binaries for 1.3.x

2017-08-10 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-7413: --- Summary: Release Hadoop 2.8.x convenience binaries for 1.3.x Key: FLINK-7413 URL: https://issues.apache.org/jira/browse/FLINK-7413 Project: Flink Issu

[jira] [Created] (FLINK-7412) optimise NettyMessage.TaskEventRequest#readFrom() to read from netty buffers directly

2017-08-10 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7412: -- Summary: optimise NettyMessage.TaskEventRequest#readFrom() to read from netty buffers directly Key: FLINK-7412 URL: https://issues.apache.org/jira/browse/FLINK-7412 Proje

[jira] [Created] (FLINK-7411) minor performance improvements in NettyMessage

2017-08-10 Thread Nico Kruber (JIRA)
Nico Kruber created FLINK-7411: -- Summary: minor performance improvements in NettyMessage Key: FLINK-7411 URL: https://issues.apache.org/jira/browse/FLINK-7411 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-7410) Add getName method to UserDefinedFunction

2017-08-10 Thread Hequn Cheng (JIRA)
Hequn Cheng created FLINK-7410: -- Summary: Add getName method to UserDefinedFunction Key: FLINK-7410 URL: https://issues.apache.org/jira/browse/FLINK-7410 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7409) WebRuntimeMonitor blocks serving threads

2017-08-10 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7409: Summary: WebRuntimeMonitor blocks serving threads Key: FLINK-7409 URL: https://issues.apache.org/jira/browse/FLINK-7409 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-7408) Extract WebRuntimeMonitor options from JobManagerOptions

2017-08-10 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-7408: Summary: Extract WebRuntimeMonitor options from JobManagerOptions Key: FLINK-7408 URL: https://issues.apache.org/jira/browse/FLINK-7408 Project: Flink Issue