[jira] [Created] (FLINK-9279) PythonPlanBinderTest flakey

Stephan Ewen created FLINK-9279: --- Summary: PythonPlanBinderTest flakey Key: FLINK-9279 URL: https://issues.apache.org/jira/browse/FLINK-9279 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-9278) Allow restore savepoint with some SQL queries added/removed

Adrian Hains created FLINK-9278: --- Summary: Allow restore savepoint with some SQL queries added/removed Key: FLINK-9278 URL: https://issues.apache.org/jira/browse/FLINK-9278 Project: Flink

[jira] [Created] (FLINK-9277) Reduce noisiness of SlotPool logging

Stephan Ewen created FLINK-9277: --- Summary: Reduce noisiness of SlotPool logging Key: FLINK-9277 URL: https://issues.apache.org/jira/browse/FLINK-9277 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9276) Improve error message when TaskManager fails

Stephan Ewen created FLINK-9276: --- Summary: Improve error message when TaskManager fails Key: FLINK-9276 URL: https://issues.apache.org/jira/browse/FLINK-9276 Project: Flink Issue Type:

[jira] [Created] (FLINK-9275) Set more distinctive output flusher thread names

Nico Kruber created FLINK-9275: -- Summary: Set more distinctive output flusher thread names Key: FLINK-9275 URL: https://issues.apache.org/jira/browse/FLINK-9275 Project: Flink Issue Type:

[jira] [Created] (FLINK-9274) Add thread name to Kafka Partition Discovery

Nico Kruber created FLINK-9274: -- Summary: Add thread name to Kafka Partition Discovery Key: FLINK-9274 URL: https://issues.apache.org/jira/browse/FLINK-9274 Project: Flink Issue Type:

Re: Flink streaming job on yarn-cluster

From a first glance, this sounds like a version conflict, most likely in the Hadoop jars. Can you try running it with the Hadoop-free Flink release? Best, Aljoscha > On 26. Apr 2018, at 03:26, Qi Yu wrote: > > Can you provide more detail about this problem. e.g the version