[ https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15770115#comment-15770115 ]
Anton Mushin edited comment on FLINK-5256 at 12/22/16 2:06 PM: --------------------------------------------------------------- Yes, [here|https://github.com/apache/flink/compare/master...ex00:FLINK-5256-tests] my branch where i run test. Now I get next message {noformat} org.junit.ComparisonFailure: Different elements in arrays: expected 15 elements and received 15 expected: [1,null, 2,null, 2,null, 3,null, 3,null, 3,null, 4,3, 4,3, 4,3, 4,3, 5,3, 5,3, 5,3, 5,3, 5,3] received: [1,3, 2,3, 2,3, 3,3, 3,3, 3,3, 4,3, 4,3, 4,3, 4,3, 5,3, 5,3, 5,3, 5,3, 5,3] Expected :1,null Actual :1,3 {noformat} I understand what is the cause, but I can't fix it yet was (Author: anmu): Yes, [here|https://github.com/apache/flink/compare/master...ex00:FLINK-5256-tests] my branch where i run test. Now I get next message {noformat} org.junit.ComparisonFailure: Different elements in arrays: expected 15 elements and received 15 expected: [1,null, 2,null, 2,null, 3,null, 3,null, 3,null, 4,3, 4,3, 4,3, 4,3, 5,3, 5,3, 5,3, 5,3, 5,3] received: [1,3, 2,3, 2,3, 3,3, 3,3, 3,3, 4,3, 4,3, 4,3, 4,3, 5,3, 5,3, 5,3, 5,3, 5,3] Expected :1,null Actual :1,3 {noformat} I understand what is the cause, but can't fix it yet > Extend DataSetSingleRowJoin to support Left and Right joins > ----------------------------------------------------------- > > Key: FLINK-5256 > URL: https://issues.apache.org/jira/browse/FLINK-5256 > Project: Flink > Issue Type: Improvement > Components: Table API & SQL > Affects Versions: 1.2.0 > Reporter: Fabian Hueske > Assignee: Anton Mushin > > The {{DataSetSingleRowJoin}} is a broadcast-map join that supports arbitrary > inner joins where one input is a single row. > I found that Calcite translates certain subqueries into non-equi left and > right joins with single input. These cases can be handled if the > {{DataSetSingleRowJoin}} is extended to support outer joins on the > non-single-row input, i.e., left joins if the right side is single input and > vice versa. -- This message was sent by Atlassian JIRA (v6.3.4#6332)