[jira] [Created] (FLINK-8019) Flink streaming job stopped at consuming Kafka data

2017-11-07 Thread Weihua Jiang (JIRA)
Weihua Jiang created FLINK-8019: --- Summary: Flink streaming job stopped at consuming Kafka data Key: FLINK-8019 URL: https://issues.apache.org/jira/browse/FLINK-8019 Project: Flink Issue Type: B

Remove the HDFS directory in org.apache.flink.util.FileUtils.deletePathIfEmpty

2017-11-07 Thread 马庆祥
Hi,all, I enable checkpoint with the configuration in the below figure . [image: 内嵌图片 1] it works, but keep getting the below exception: [image: 内嵌图片 2] I want to know if the below commit is to resolve the above problem, but the exception still appears. [hotfix] [core] Fix FileUtils.deletePathI

[jira] [Created] (FLINK-8018) RMQ does not support disabling queueDeclare, when the user has no declaration permissions, it cannot connect

2017-11-07 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-8018: - Summary: RMQ does not support disabling queueDeclare, when the user has no declaration permissions, it cannot connect Key: FLINK-8018 URL: https://issues.apache.org/jira/browse/FLINK-80

[jira] [Created] (FLINK-8017) High availability cluster-id option incorrect in documentation

2017-11-07 Thread Dan Kelley (JIRA)
Dan Kelley created FLINK-8017: - Summary: High availability cluster-id option incorrect in documentation Key: FLINK-8017 URL: https://issues.apache.org/jira/browse/FLINK-8017 Project: Flink Issue

[jira] [Created] (FLINK-8016) Add documentation for KafkaJsonTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8016: Summary: Add documentation for KafkaJsonTableSink Key: FLINK-8016 URL: https://issues.apache.org/jira/browse/FLINK-8016 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-8015) Add Kafka011JsonTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8015: Summary: Add Kafka011JsonTableSink Key: FLINK-8015 URL: https://issues.apache.org/jira/browse/FLINK-8015 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-8014) Add Kafka010JsonTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8014: Summary: Add Kafka010JsonTableSink Key: FLINK-8014 URL: https://issues.apache.org/jira/browse/FLINK-8014 Project: Flink Issue Type: Improvement Com

[jira] [Created] (FLINK-8013) Check of AggregateFunction merge function signature is too strict.

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8013: Summary: Check of AggregateFunction merge function signature is too strict. Key: FLINK-8013 URL: https://issues.apache.org/jira/browse/FLINK-8013 Project: Flink

[jira] [Created] (FLINK-8012) Table with time attribute cannot be written to CsvTableSink

2017-11-07 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8012: Summary: Table with time attribute cannot be written to CsvTableSink Key: FLINK-8012 URL: https://issues.apache.org/jira/browse/FLINK-8012 Project: Flink Is

[jira] [Created] (FLINK-8011) Set dist flink-python dependency to provided

2017-11-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8011: --- Summary: Set dist flink-python dependency to provided Key: FLINK-8011 URL: https://issues.apache.org/jira/browse/FLINK-8011 Project: Flink Issue Type:

Call for responses: Apache Flink user survey 2017

2017-11-07 Thread Till Rohrmann
Hi everyone, data Artisans is running a second annual Apache Flink user survey [1] in order to understand Flink usage and the needs of the community. This survey will help to shape the Flink roadmap and make Flink the best that it can be for users. We'll publish a report with a summary of finding

[jira] [Created] (FLINK-8010) Bump remaining flink-shaded dependencies

2017-11-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8010: --- Summary: Bump remaining flink-shaded dependencies Key: FLINK-8010 URL: https://issues.apache.org/jira/browse/FLINK-8010 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8009) flink-dist contains flink-runtime's transitive hadoop dependencies

2017-11-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8009: --- Summary: flink-dist contains flink-runtime's transitive hadoop dependencies Key: FLINK-8009 URL: https://issues.apache.org/jira/browse/FLINK-8009 Project: Flink

[jira] [Created] (FLINK-8008) PojoTypeInfo should not sort fields

2017-11-07 Thread Muhammad Imran Tariq (JIRA)
Muhammad Imran Tariq created FLINK-8008: --- Summary: PojoTypeInfo should not sort fields Key: FLINK-8008 URL: https://issues.apache.org/jira/browse/FLINK-8008 Project: Flink Issue Type: I

[jira] [Created] (FLINK-8007) Move TestMeter class to test scope

2017-11-07 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8007: --- Summary: Move TestMeter class to test scope Key: FLINK-8007 URL: https://issues.apache.org/jira/browse/FLINK-8007 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8006) flink-daemon.sh: line 103: binary operator expected

2017-11-07 Thread Alejandro (JIRA)
Alejandro created FLINK-8006: - Summary: flink-daemon.sh: line 103: binary operator expected Key: FLINK-8006 URL: https://issues.apache.org/jira/browse/FLINK-8006 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-8005) Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues

2017-11-07 Thread Gary Yao (JIRA)
Gary Yao created FLINK-8005: --- Summary: Snapshotting FlinkKafkaProducer011 fails due to ClassLoader issues Key: FLINK-8005 URL: https://issues.apache.org/jira/browse/FLINK-8005 Project: Flink Issue

[jira] [Created] (FLINK-8004) Sample code in Debugging & Monitoring Metrics documentation section is not valid java

2017-11-07 Thread Andreas Hecke (JIRA)
Andreas Hecke created FLINK-8004: Summary: Sample code in Debugging & Monitoring Metrics documentation section is not valid java Key: FLINK-8004 URL: https://issues.apache.org/jira/browse/FLINK-8004