[jira] [Created] (FLINK-3110) Add support for the partition-centric iterations

2015-12-04 Thread Vasia Kalavri (JIRA)
Vasia Kalavri created FLINK-3110: Summary: Add support for the partition-centric iterations Key: FLINK-3110 URL: https://issues.apache.org/jira/browse/FLINK-3110 Project: Flink Issue Type: Ne

[jira] [Created] (FLINK-3111) Short lived client interaction logs warning in job manager

2015-12-04 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-3111: -- Summary: Short lived client interaction logs warning in job manager Key: FLINK-3111 URL: https://issues.apache.org/jira/browse/FLINK-3111 Project: Flink Issue Ty

[jira] [Created] (FLINK-3112) Remove unused RecordModelPostPass class

2015-12-04 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-3112: Summary: Remove unused RecordModelPostPass class Key: FLINK-3112 URL: https://issues.apache.org/jira/browse/FLINK-3112 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-3113) Remove unused global order methods from GenericDataSinkBase

2015-12-04 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-3113: Summary: Remove unused global order methods from GenericDataSinkBase Key: FLINK-3113 URL: https://issues.apache.org/jira/browse/FLINK-3113 Project: Flink Is

[jira] [Created] (FLINK-3114) RemoteEnvironment: Read cluster's default parallelism

2015-12-04 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3114: - Summary: RemoteEnvironment: Read cluster's default parallelism Key: FLINK-3114 URL: https://issues.apache.org/jira/browse/FLINK-3114 Project: Flink

[jira] [Created] (FLINK-3115) Update Elasticsearch connector to 2.X

2015-12-04 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3115: - Summary: Update Elasticsearch connector to 2.X Key: FLINK-3115 URL: https://issues.apache.org/jira/browse/FLINK-3115 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-3116) Remove RecordOperator

2015-12-04 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-3116: --- Summary: Remove RecordOperator Key: FLINK-3116 URL: https://issues.apache.org/jira/browse/FLINK-3116 Project: Flink Issue Type: Improvement C

[jira] [Created] (FLINK-3117) Storm Tick Tuples are not supported

2015-12-04 Thread Maximilian Michels (JIRA)
Maximilian Michels created FLINK-3117: - Summary: Storm Tick Tuples are not supported Key: FLINK-3117 URL: https://issues.apache.org/jira/browse/FLINK-3117 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3118) Check if MessageFunction implements ResultTypeQueryable

2015-12-04 Thread Martin Junghanns (JIRA)
Martin Junghanns created FLINK-3118: --- Summary: Check if MessageFunction implements ResultTypeQueryable Key: FLINK-3118 URL: https://issues.apache.org/jira/browse/FLINK-3118 Project: Flink I

Fwd: DATA TRANSFORMATION PROBLEM

2015-12-04 Thread JOHN MILLER
-- Forwarded message -- From: JOHN MILLER Date: Fri, Dec 4, 2015 at 10:24 AM Subject: DATA TRANSFORMATION PROBLEM To: i...@data-artisans.com *Greetings* *I am writing to obtain an approach to resolve a data transformation problem The problem is that I want to format a new da

[jira] [Created] (FLINK-3119) Remove dependency on Tuple from HadoopOutputFormat

2015-12-04 Thread Nick Dimiduk (JIRA)
Nick Dimiduk created FLINK-3119: --- Summary: Remove dependency on Tuple from HadoopOutputFormat Key: FLINK-3119 URL: https://issues.apache.org/jira/browse/FLINK-3119 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-3120) Set number of event loop thread and number of buffer pool arenas to same number

2015-12-04 Thread Ufuk Celebi (JIRA)
Ufuk Celebi created FLINK-3120: -- Summary: Set number of event loop thread and number of buffer pool arenas to same number Key: FLINK-3120 URL: https://issues.apache.org/jira/browse/FLINK-3120 Project: Fl

[jira] [Created] (FLINK-3121) Watermark forwarding does not work for sources not producing any data

2015-12-04 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3121: - Summary: Watermark forwarding does not work for sources not producing any data Key: FLINK-3121 URL: https://issues.apache.org/jira/browse/FLINK-3121 Project: Flink