[ 
https://issues.apache.org/jira/browse/FLINK-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15360228#comment-15360228
 ] 

ASF GitHub Bot commented on FLINK-2985:
---------------------------------------

Github user gallenvara commented on the issue:

    https://github.com/apache/flink/pull/2078
  
    @fhueske the failure of CI build is relevant with 
`testJoinWithDisjunctivePred` in `JoinITCase`. The case is `val joinT = 
ds1.join(ds2).filter('a === 'd && ('b === 'e || 'b === 'e - 10)).select('c, 
'g)`. I still don't quite understand why this case running failed after some 
debug work. And when i changed the filter condition with `('a === 'd && ('b === 
'e || 'b === 'h - 10))` (or replace with `'d` `'f`), it can work sucessfully 
without exception. 


> Allow different field names for unionAll() in Table API
> -------------------------------------------------------
>
>                 Key: FLINK-2985
>                 URL: https://issues.apache.org/jira/browse/FLINK-2985
>             Project: Flink
>          Issue Type: Improvement
>          Components: Table API & SQL
>            Reporter: Timo Walther
>            Priority: Minor
>
> The recently merged `unionAll` operator checks if the field names of the left 
> and right side are equal. Actually, this is not necessary. The union operator 
> in SQL checks only the types and uses the names of left side.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to