[jira] [Created] (FLINK-4188) Support for outer joins on DataStream

2016-07-10 Thread Ignacio N. Lucero Ascencio (JIRA)
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

2016-07-10 Thread Ignacio N. Lucero Ascencio (JIRA)
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

2016-07-10 Thread Robert Metzger (JIRA)
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)