[jira] [Created] (FLINK-4839) JobManager handle TaskManager's slot offering

Kurt Young created FLINK-4839: - Summary: JobManager handle TaskManager's slot offering Key: FLINK-4839 URL: https://issues.apache.org/jira/browse/FLINK-4839 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4838) remove STREAM keyword in StreamSQLExample

Manu Zhang created FLINK-4838: - Summary: remove STREAM keyword in StreamSQLExample Key: FLINK-4838 URL: https://issues.apache.org/jira/browse/FLINK-4838 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-4837) flink-streaming-akka source connector

Subhobrata Dey created FLINK-4837: - Summary: flink-streaming-akka source connector Key: FLINK-4837 URL: https://issues.apache.org/jira/browse/FLINK-4837 Project: Flink Issue Type: New

Flink Metrics

Hi, I am currently using flink 1.2 snapshot and instrumenting my pipeline with flink metrics. One small suggestion I have is currently the Meter interface only supports getRate() which is always the one minute rate. It would great if all the rates (1 min, 5 min & 15 min) are exposed to get a

[jira] [Created] (FLINK-4836) Implement Mini Cluster

Stephan Ewen created FLINK-4836: --- Summary: Implement Mini Cluster Key: FLINK-4836 URL: https://issues.apache.org/jira/browse/FLINK-4836 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-4835) Implement standalone High Availability Services

Stephan Ewen created FLINK-4835: --- Summary: Implement standalone High Availability Services Key: FLINK-4835 URL: https://issues.apache.org/jira/browse/FLINK-4835 Project: Flink Issue Type:

[jira] [Created] (FLINK-4834) Implement unified High Availability Services Abstraction

Stephan Ewen created FLINK-4834: --- Summary: Implement unified High Availability Services Abstraction Key: FLINK-4834 URL: https://issues.apache.org/jira/browse/FLINK-4834 Project: Flink Issue