Arnaud Linz created FLINK-16509:
---
Summary: FlinkKafkaConsumerBase tries to log a context that may
not have been initialized and fails
Key: FLINK-16509
URL: https://issues.apache.org/jira/browse/FLINK-16509
Arnaud Linz created FLINK-10832:
---
Summary: StreamExecutionEnvironment.execute() does not return when
all sources end
Key: FLINK-10832
URL: https://issues.apache.org/jira/browse/FLINK-10832
Project: Flin
Arnaud Linz created FLINK-8580:
--
Summary: No easy way (or issues when trying?) to handle multiple
yarn sessions and choose at runtime the one to submit a ha streaming job
Key: FLINK-8580
URL: https://issues.apache.or
Arnaud Linz created FLINK-6289:
--
Summary: ExecutionEnvironment.readTextFile() can read gzip files &
directories but not both
Key: FLINK-6289
URL: https://issues.apache.org/jira/browse/FLINK-6289
Project:
Arnaud Linz created FLINK-5305:
--
Summary: Documentation of collect() should mention parameter
akka.framesize
Key: FLINK-5305
URL: https://issues.apache.org/jira/browse/FLINK-5305
Project: Flink
Arnaud Linz created FLINK-2617:
--
Summary: ConcurrentModificationException when using
HCatRecordReader to access a hive table
Key: FLINK-2617
URL: https://issues.apache.org/jira/browse/FLINK-2617
Project:
Arnaud Linz created FLINK-2589:
--
Summary: Threads created in TimeTriggerPolicy don't end properly
Key: FLINK-2589
URL: https://issues.apache.org/jira/browse/FLINK-2589
Project: Flink
Issue Type:
Arnaud Linz created FLINK-2580:
--
Summary: HadoopDataOutputStream does not expose enough methods of
org.apache.hadoop.fs.FSDataOutputStream
Key: FLINK-2580
URL: https://issues.apache.org/jira/browse/FLINK-2580
Arnaud Linz created FLINK-2579:
--
Summary: StreamExecutionEnvironment & ExecutionEnvironment do not
share interface but have a lot in common
Key: FLINK-2579
URL: https://issues.apache.org/jira/browse/FLINK-2579
