yuemeng created FLINK-11057:
-------------------------------

             Summary: 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


{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}



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

Reply via email to