[ 
https://issues.apache.org/jira/browse/FLINK-11057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

yuemeng updated FLINK-11057:
----------------------------
    Description: 
{code:java}
select action , count ( * ) as cnt from user_action where action in ( 'view' , 
'impress' , 'sysaction' , 'commentimpress' , 'play' , 'click' , 'page' , 
'abtestreqsuss' , 'bannerimpress' , 'abtestserver' , 'active' , 'search' , 
'activeclient' , 'like' , 'zan' , 'adclick' , 'login' , 'comment' , 
'subscribeartist' , 'subscribevideo' , 'subscribedjradio' , 'share' , 'private' 
, 'register' , 'downloadall' , 'forward' , 'newdj' , 'recommendimpress' , 
'hotkeywordimpress' , 'nogetad' , 'add' , 'subscribe' , 'follow' , 'new' ) 
group by tumble ( proctime , interval '60' SECOND ) , action
{code}

sql such as this will be cause a stream inner join logical.
but if i reduce the the element of parentheses,it can't cause the stream inner 
join logical


  was:
{code}

select action , count ( * ) as cnt from user_action where action in ( 'view' , 
'impress' , 'sysaction' , 'commentimpress' , 'play' , 'click' , 'page' , 
'abtestreqsuss' , 'bannerimpress' , 'abtestserver' , 'active' , 'search' , 
'activeclient' , 'like' , 'zan' , 'adclick' , 'login' , 'comment' , 
'subscribeartist' , 'subscribevideo' , 'subscribedjradio' , 'share' , 'private' 
, 'register' , 'downloadall' , 'forward' , 'newdj' , 'recommendimpress' , 
'hotkeywordimpress' , 'nogetad' , 'add' , 'subscribe' , 'follow' , 'new' ) 
group by tumble ( proctime , interval '60' SECOND ) , action

{code}


> where in grammar will cause stream inner join loigcal
> -----------------------------------------------------
>
>                 Key: FLINK-11057
>                 URL: https://issues.apache.org/jira/browse/FLINK-11057
>             Project: Flink
>          Issue Type: Bug
>            Reporter: yuemeng
>            Priority: Critical
>
> {code:java}
> select action , count ( * ) as cnt from user_action where action in ( 'view' 
> , 'impress' , 'sysaction' , 'commentimpress' , 'play' , 'click' , 'page' , 
> 'abtestreqsuss' , 'bannerimpress' , 'abtestserver' , 'active' , 'search' , 
> 'activeclient' , 'like' , 'zan' , 'adclick' , 'login' , 'comment' , 
> 'subscribeartist' , 'subscribevideo' , 'subscribedjradio' , 'share' , 
> 'private' , 'register' , 'downloadall' , 'forward' , 'newdj' , 
> 'recommendimpress' , 'hotkeywordimpress' , 'nogetad' , 'add' , 'subscribe' , 
> 'follow' , 'new' ) group by tumble ( proctime , interval '60' SECOND ) , 
> action
> {code}
> sql such as this will be cause a stream inner join logical.
> but if i reduce the the element of parentheses,it can't cause the stream 
> inner join logical



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to