[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 Reporter: Kurt Young Assignee: Kurt Young JobManager receives the TaskManager's slot offers, and decide which slots to accept. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[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 Components: Examples, Table API & SQL Reporter: Manu Zhang Priority: Minor After FLINK-4546, "STREAM" keyword should be removed from SQL query in StreamSQLExample -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[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 Feature Components: Streaming Connectors Reporter: Subhobrata Dey Hello, This issue is created to propose the idea of having a flink-streaming-akka source connector. The source connector can be used to receive messages from an Akka feeder or publisher actor & these messages can then be processed using flink streaming. The source connector has the following features. 1. It can supports several different message formats like iterable data, bytes array & data with timestamp. 2. It can send back acknowledgements to the feeder actor. Thanks & regards, Subhobrata -- This message was sent by Atlassian JIRA (v6.3.4#6332)
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 better picture in terms of performance. Also is there any reason why timers are not part of flink metrics core? Regards, Govind
[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
Components: Cluster Management
Environment: FLIP-6 feature branch
Reporter: Stephan Ewen
This task is to implement the embedded mini cluster (similar to the
{{LocalFlinkMiniCluster}} based on the new components developed in "Flink
Improvement Proposal 6"
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[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: Sub-task
Components: Cluster Management
Environment: FLIP-6 feature branch
Reporter: Stephan Ewen
Assignee: Stephan Ewen
This is a version of the {{HighAvailabilityServices}} that is in fact not
highly available and used for setups where everything runs in one process (mini
clusters) and simple setups (non-ha)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[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 Type: New Feature Components: Cluster Management Environment: FLIP-6 feature branch Reporter: Stephan Ewen -- This message was sent by Atlassian JIRA (v6.3.4#6332)
