[jira] [Created] (FLINK-4188) Support for outer joins on DataStream
Ignacio N. Lucero Ascencio created FLINK-4188: - Summary: Support for outer joins on DataStream Key: FLINK-4188 URL: https://issues.apache.org/jira/browse/FLINK-4188 Project: Flink Issue Type: New Feature Components: DataStream API Reporter: Ignacio N. Lucero Ascencio Priority: Minor It would be nice to have support for outer joins on DataStream. DataSet supports all the outer joins (left, right, full) but DataStream only provides the inner join. It has been pointed out that an outer join can be achieved with a coGroup, but I am of the opinion that having first-class support for outer joins would be nicer. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-4187) Support for outer joins on DataStream
Ignacio N. Lucero Ascencio created FLINK-4187: - Summary: Support for outer joins on DataStream Key: FLINK-4187 URL: https://issues.apache.org/jira/browse/FLINK-4187 Project: Flink Issue Type: New Feature Components: DataStream API Reporter: Ignacio N. Lucero Ascencio Priority: Minor It would be nice to have support for outer joins on DataStream. DataSet supports all the outer joins (left, right, full) but DataStream only provides the inner join. It has been pointed out that an outer join can be achieved with a coGroup, but I am of the opinion that having first-class support for outer joins would be nicer. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (FLINK-4186) Expose Kafka metrics through Flink metrics
Robert Metzger created FLINK-4186: - Summary: Expose Kafka metrics through Flink metrics Key: FLINK-4186 URL: https://issues.apache.org/jira/browse/FLINK-4186 Project: Flink Issue Type: Improvement Components: Kafka Connector Affects Versions: 1.1.0 Reporter: Robert Metzger Assignee: Robert Metzger Currently, we expose the Kafka metrics through Flink's accumulators. We can now use the metrics system in Flink to report Kafka metrics. -- This message was sent by Atlassian JIRA (v6.3.4#6332)