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)