[jira] [Created] (FLINK-11086) flink-hadoop-compatibility tests fail for 3.x hadoop versions

Sebastian Klemke created FLINK-11086: Summary: flink-hadoop-compatibility tests fail for 3.x hadoop versions Key: FLINK-11086 URL: https://issues.apache.org/jira/browse/FLINK-11086 Project: Flink

[jira] [Created] (FLINK-8230) NPE in OrcRowInputFormat on nested structs

Sebastian Klemke created FLINK-8230: --- Summary: NPE in OrcRowInputFormat on nested structs Key: FLINK-8230 URL: https://issues.apache.org/jira/browse/FLINK-8230 Project: Flink Issue Type: Bu

[jira] [Created] (FLINK-8186) AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat

Sebastian Klemke created FLINK-8186: --- Summary: AvroInputFormat regression: fails to deserialize GenericRecords on cluster with hadoop27 compat Key: FLINK-8186 URL: https://issues.apache.org/jira/browse/FLINK-818

[jira] [Created] (FLINK-7579) Documentation of yarn.application-attempts is not accurate

Sebastian Klemke created FLINK-7579: --- Summary: Documentation of yarn.application-attempts is not accurate Key: FLINK-7579 URL: https://issues.apache.org/jira/browse/FLINK-7579 Project: Flink

[jira] [Created] (FLINK-7539) Make AvroOutputFormat default codec configurable

Sebastian Klemke created FLINK-7539: --- Summary: Make AvroOutputFormat default codec configurable Key: FLINK-7539 URL: https://issues.apache.org/jira/browse/FLINK-7539 Project: Flink Issue Ty

[jira] [Created] (FLINK-7002) Partitioning broken if enum is used in compound key specified using field expression

Sebastian Klemke created FLINK-7002: --- Summary: Partitioning broken if enum is used in compound key specified using field expression Key: FLINK-7002 URL: https://issues.apache.org/jira/browse/FLINK-7002

[jira] [Created] (FLINK-4015) FlinkKafkaProducer08 fails when partition leader changes

Sebastian Klemke created FLINK-4015: --- Summary: FlinkKafkaProducer08 fails when partition leader changes Key: FLINK-4015 URL: https://issues.apache.org/jira/browse/FLINK-4015 Project: Flink

[jira] [Created] (FLINK-3937) Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters

Sebastian Klemke created FLINK-3937: --- Summary: Make flink cli list, savepoint, cancel and stop work on Flink-on-YARN clusters Key: FLINK-3937 URL: https://issues.apache.org/jira/browse/FLINK-3937 Pr

[jira] [Created] (FLINK-3391) Typo in SavepointITCase

Sebastian Klemke created FLINK-3391: --- Summary: Typo in SavepointITCase Key: FLINK-3391 URL: https://issues.apache.org/jira/browse/FLINK-3391 Project: Flink Issue Type: Bug Repor

[jira] [Created] (FLINK-3390) Savepoint resume is not retried

Sebastian Klemke created FLINK-3390: --- Summary: Savepoint resume is not retried Key: FLINK-3390 URL: https://issues.apache.org/jira/browse/FLINK-3390 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-3304) AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode

Sebastian Klemke created FLINK-3304: --- Summary: AvroOutputFormat.setSchema() doesn't work in yarn-cluster mode Key: FLINK-3304 URL: https://issues.apache.org/jira/browse/FLINK-3304 Project: Flink

[jira] [Created] (FLINK-3190) Retry rate limits for DataStream API

Sebastian Klemke created FLINK-3190: --- Summary: Retry rate limits for DataStream API Key: FLINK-3190 URL: https://issues.apache.org/jira/browse/FLINK-3190 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-3188) Deletes in Kafka source should be passed on to KeyedDeserializationSchema

Sebastian Klemke created FLINK-3188: --- Summary: Deletes in Kafka source should be passed on to KeyedDeserializationSchema Key: FLINK-3188 URL: https://issues.apache.org/jira/browse/FLINK-3188 Project