[jira] [Created] (FLINK-5037) Instability in AbstractUdfStreamOperatorLifecycleTest

Aljoscha Krettek created FLINK-5037: --- Summary: Instability in AbstractUdfStreamOperatorLifecycleTest Key: FLINK-5037 URL: https://issues.apache.org/jira/browse/FLINK-5037 Project: Flink Iss

[jira] [Created] (FLINK-5038) Errors in the "cancelTask" method prevent closeables from being closed early

Stephan Ewen created FLINK-5038: --- Summary: Errors in the "cancelTask" method prevent closeables from being closed early Key: FLINK-5038 URL: https://issues.apache.org/jira/browse/FLINK-5038 Project: Fli

[DISCUSS] Changing Window Cleanup Semantics

Hi, I recently created https://issues.apache.org/jira/browse/FLINK-4994 to address what I think is a flaw in the window cleanup semantics. This has the possibility of affecting people so I'd like to get some opinions and also give people a heads-up. Before going into what I'm proposing in the issu

[jira] [Created] (FLINK-5039) Avro GenericRecord support is broken

Bruno Dumon created FLINK-5039: -- Summary: Avro GenericRecord support is broken Key: FLINK-5039 URL: https://issues.apache.org/jira/browse/FLINK-5039 Project: Flink Issue Type: Bug Comp

[jira] [Created] (FLINK-5040) Set correct input channel types with eager scheduling

Ufuk Celebi created FLINK-5040: -- Summary: Set correct input channel types with eager scheduling Key: FLINK-5040 URL: https://issues.apache.org/jira/browse/FLINK-5040 Project: Flink Issue Type: B

[jira] [Created] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

Stefan Richter created FLINK-5041: - Summary: Implement savepoint backwards compatibility 1.1 -> 1.2 Key: FLINK-5041 URL: https://issues.apache.org/jira/browse/FLINK-5041 Project: Flink Issue

[jira] [Created] (FLINK-5042) Convert old savepoints to new savepoints

Stefan Richter created FLINK-5042: - Summary: Convert old savepoints to new savepoints Key: FLINK-5042 URL: https://issues.apache.org/jira/browse/FLINK-5042 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-5043) Converting keyed state from Flink 1.1 backend implementations to their new counterparts in 1.2

Stefan Richter created FLINK-5043: - Summary: Converting keyed state from Flink 1.1 backend implementations to their new counterparts in 1.2 Key: FLINK-5043 URL: https://issues.apache.org/jira/browse/FLINK-5043

[jira] [Created] (FLINK-5044) Converting operator and function state from Flink 1.1 for all changed operators in 1.2

Stefan Richter created FLINK-5044: - Summary: Converting operator and function state from Flink 1.1 for all changed operators in 1.2 Key: FLINK-5044 URL: https://issues.apache.org/jira/browse/FLINK-5044

[jira] [Created] (FLINK-5045) Latency markers emitted after output buffer pool destroyed

Ufuk Celebi created FLINK-5045: -- Summary: Latency markers emitted after output buffer pool destroyed Key: FLINK-5045 URL: https://issues.apache.org/jira/browse/FLINK-5045 Project: Flink Issue Ty

[jira] [Created] (FLINK-5046) Avoid redundant serialization when creating the TaskDeploymentDescriptor

Till Rohrmann created FLINK-5046: Summary: Avoid redundant serialization when creating the TaskDeploymentDescriptor Key: FLINK-5046 URL: https://issues.apache.org/jira/browse/FLINK-5046 Project: Flink

[jira] [Created] (FLINK-5047) Add tumbling group-windows for batch tables

Jark Wu created FLINK-5047: -- Summary: Add tumbling group-windows for batch tables Key: FLINK-5047 URL: https://issues.apache.org/jira/browse/FLINK-5047 Project: Flink Issue Type: Sub-task

RE: Apache Flink and Kudu integration

Hi, I am starting a PoC to do that. I will try to develop both source and sink. I will let you know asap I have something ;-) Best -Original Message- From: Márton Balassi [mailto:balassi.mar...@gmail.com] Sent: viernes, 28 de octubre de 2016 8:50 To: dev@flink.apache.org Subject: Re: Ap