[jira] [Created] (FLINK-4725) BucketingSink throws NPE while restoring state if basePath does not exist

2016-10-01 Thread Jordan Ganoff (JIRA)
Jordan Ganoff created FLINK-4725: Summary: BucketingSink throws NPE while restoring state if basePath does not exist Key: FLINK-4725 URL: https://issues.apache.org/jira/browse/FLINK-4725 Project: Flin

[jira] [Created] (FLINK-4724) When executed in YARN wrong log4j & logback configuration file is used

2016-10-01 Thread Melmoth (JIRA)
Melmoth created FLINK-4724: -- Summary: When executed in YARN wrong log4j & logback configuration file is used Key: FLINK-4724 URL: https://issues.apache.org/jira/browse/FLINK-4724 Project: Flink Iss

[jira] [Created] (FLINK-4723) Unify definition of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer

2016-10-01 Thread Tzu-Li (Gordon) Tai (JIRA)
Tzu-Li (Gordon) Tai created FLINK-4723: -- Summary: Unify definition of committed offsets to Kafka / ZK for Kafka 0.8 and 0.9 consumer Key: FLINK-4723 URL: https://issues.apache.org/jira/browse/FLINK-4723

[jira] [Created] (FLINK-4722) Consumer group concept not working properly with FlinkKafkaConsumer09

2016-10-01 Thread Sudhanshu Sekhar Lenka (JIRA)
Sudhanshu Sekhar Lenka created FLINK-4722: - Summary: Consumer group concept not working properly with FlinkKafkaConsumer09 Key: FLINK-4722 URL: https://issues.apache.org/jira/browse/FLINK-4722