?????? flinksql????????????????????

Mon, 29 Jun 2020 20:23:57 -0700 

??????????????????????????


??????????hive 
table??????????????????????dag??????????????????????????????hive??????hive????????3??????????????subtask??????????????????????
https://s1.ax1x.com/2020/06/30/N4qxNq.png


????????????subtask????????????????running????????????????????????19??????????????????????????SUCCESS??????????




------------------ ???????? ------------------
??????:&nbsp;"Rui Li"<[email protected]&gt;;
????????:&nbsp;2020??6??30??(??????) ????11:01
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: flinksql????????????????????



????????????????????????????Hive table source??????bounded
stream??????hive????????????????stream????????????????????????????????????????

On Tue, Jun 30, 2020 at 10:39 AM MuChen <[email protected]&gt; wrote:

&gt; ????????????????????????
&gt;
&gt;
&gt; $ grep -v \# sql-client-defaults.yaml |grep -v ^$ 
catalogs:&nbsp;&nbsp;&nbsp; - name:
&gt; myhive&nbsp;&nbsp;&nbsp;&nbsp; type: hive&nbsp;&nbsp;&nbsp;&nbsp; 
hive-conf-dir: /home/fsql/hive/conf
&gt;&nbsp; default-database: default execution:&nbsp;&nbsp; planner: 
blink&nbsp;&nbsp; type: streaming
&gt;&nbsp; time-characteristic: event-time&nbsp;&nbsp; 
periodic-watermarks-interval: 200
&gt;&nbsp; result-mode: table&nbsp;&nbsp; max-table-result-rows: 
1000000&nbsp;&nbsp; parallelism: 4
&gt;&nbsp; max-parallelism: 128&nbsp;&nbsp; min-idle-state-retention: 0
&gt;&nbsp; max-idle-state-retention: 0&nbsp;&nbsp; current-catalog: 
myhive&nbsp;&nbsp; current-database:
&gt; default&nbsp;&nbsp; restart-strategy:&nbsp;&nbsp;&nbsp;&nbsp; type: 
fixed-delay deployment:
&gt;&nbsp; response-timeout: 5000&nbsp;&nbsp; gateway-address: ""&nbsp;&nbsp; 
gateway-port: 0
&gt;
&gt;
&gt;
&gt;
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; ??????:&amp;nbsp;"zhisheng"<[email protected]&amp;gt;;
&gt; ????????:&amp;nbsp;2020??6??30??(??????) ????9:05
&gt; ??????:&amp;nbsp;"user-zh"<[email protected]&amp;gt;;
&gt;
&gt; ????:&amp;nbsp;Re: flinksql????????????????????
&gt;
&gt;
&gt;
&gt; ??????????????????????????
&gt;
&gt; Yichao Yang <[email protected]&amp;gt; ??2020??6??29?????? ????6:58??????
&gt;
&gt; &amp;gt; Hi
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; ??????????????????????hive 
table????????????????????????????????????????????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; Best,
&gt; &amp;gt; Yichao Yang
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; 
------------------&amp;amp;nbsp;????????&amp;amp;nbsp;------------------
&gt; &amp;gt; ??????:&amp;amp;nbsp;"MuChen"<[email protected]&amp;amp;gt;;
&gt; &amp;gt; ????????:&amp;amp;nbsp;2020??6??29??(??????) ????4:53
&gt; &amp;gt; 
??????:&amp;amp;nbsp;"user-zh"<[email protected]&amp;amp;gt;;
&gt; &amp;gt;
&gt; &amp;gt; ????:&amp;amp;nbsp;flinksql????????????????????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; hi,????????
&gt; &amp;gt;
&gt; &amp;gt; ????????yarn-session??bin/yarn-session.sh -jm 1g -tm 4g -s 4 -qu
&gt; root.flink -nm
&gt; &amp;gt; fsql-cli&amp;amp;amp;nbsp; 2&amp;amp;amp;gt;&amp;amp;amp;amp;1 
&amp;amp;amp;amp;
&gt; &amp;gt;
&gt; &amp;gt; ????????sql-client????????????sql??
&gt; &amp;gt;
&gt; &amp;gt; 
????????????????kafka????????hive??????join????????????????????mysql????&amp;amp;amp;nbsp;
&gt; &amp;gt;
&gt; &amp;gt; 
????????????????????????????????????????????????????????????????succeeded??????????????
&gt; &amp;gt; https://s1.ax1x.com/2020/06/29/Nf2dIA.png
&gt; &amp;gt;
&gt; &amp;gt; ????????????INFO????????????15:34??????????????????????
&gt; &amp;gt; 2020-06-29 14:53:20,260 INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.api.common.io.LocatableInputSplitAssigner&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; - Assigning remote split to host uhadoop-op3raf-core12 2020-06-29
&gt; &amp;gt; 14:53:22,845 INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; - Source: HiveTableSource(vid, q70) TablePath: 
dw.video_pic_title_q70,
&gt; &amp;gt; PartitionPruned: false, PartitionNums: null (1/1) (68c24aa5
&gt; &amp;gt; 9c898cefbb20fbc929ddbafd) switched from RUNNING to FINISHED.
&gt; 2020-06-29
&gt; &amp;gt; 15:34:52,982 INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.runtime.entrypoint.ClusterEntrypoint&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; - Shutting YarnSessionClusterEntrypoint down with application 
status
&gt; &amp;gt; SUCCEEDED. Diagnostics null. 2020-06-29 15:34:52,984 
INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; - Shutting down rest endpoint. 2020-06-29 15:34:53,072 
INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; - Removing cache directory
&gt; &amp;gt; /tmp/flink-web-cdb67193-05ee-4a83-b957-9b7a9d85c23f/flink-web-ui
&gt; 2020-06-29
&gt; &amp;gt; 15:34:53,073 INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; - http://uhadoop-op3raf-core1:44664 lost leadership 2020-06-29
&gt; &amp;gt; 15:34:53,074 INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; - Shut down complete. 2020-06-29 15:34:53,074 INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.yarn.YarnResourceManager&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; - Shut down cluster because application is in SUCCEEDED, 
diagnostics
&gt; null.
&gt; &amp;gt; 2020-06-29 15:34:53,076 INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.yarn.YarnResourceManager&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; - Unregister application from the YARN Resource Manager with final
&gt; status
&gt; &amp;gt; SUCCEEDED. 2020-06-29 15:34:53,088 INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; - Waiting for application to be successfully unregistered. 
2020-06-29
&gt; &amp;gt; 15:34:53,306 INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent&amp;amp;nbsp;
&gt; &amp;gt; - Closing components. 2020-06-29 15:34:53,308 INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess&amp;amp;nbsp;
&gt; &amp;gt; - Stopping SessionDispatcherLeaderProcess. 2020-06-29 15:34:53,309
&gt; &amp;gt; INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; - Stopping dispatcher akka.tcp://flink@uhadoop-op3raf-core1
&gt; :38817/user/dispatcher.
&gt; &amp;gt; 2020-06-29 15:34:53,310 INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; - Stopping all currently running jobs of dispatcher
&gt; &amp;gt; akka.tcp://flink@uhadoop-op3raf-core1:38817/user/dispatcher.
&gt; 2020-06-29
&gt; &amp;gt; 15:34:53,311 INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.flink.runtime.jobmaster.JobMaster&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; - Stopping the JobMaster for job default: insert into
&gt; &amp;gt; rt_app.app_video_cover_abtest_test ... 2020-06-29 15:34:53,322
&gt; INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl&amp;amp;nbsp; -
&gt; &amp;gt; Interrupted while waiting for queue
&gt; &amp;gt;
&gt; 
java.lang.InterruptedException&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; at
&gt; &amp;gt;
&gt; 
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; at
&gt; &amp;gt;
&gt; 
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048)&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; at
&gt; &amp;gt;
&gt; 
java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; at
&gt; &amp;gt;
&gt; 
org.apache.hadoop.yarn.client.api.async.impl.AMRMClientAsyncImpl$CallbackHandlerThread.run(AMRMClientAsyncImpl.java:287)
&gt; &amp;gt; 2020-06-29 15:34:53,324 INFO&amp;amp;nbsp;
&gt; &amp;gt;
&gt; 
org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy&amp;amp;nbsp;
&gt; &amp;gt; - Opening proxy : uhadoop-op3raf-core12:23333
&gt; &amp;gt;
&gt; &amp;gt; &amp;amp;nbsp;
&gt; &amp;gt; ps:&amp;amp;amp;nbsp;
&gt; &amp;gt;
&gt; &amp;gt; 1. kafka????????????????????
&gt; &amp;gt; 2. flink????1.10.0
&gt; &amp;gt; ??????????????????????????SUCCEEDED????
&gt; &amp;gt;
&gt; &amp;gt; ??????????
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt;
&gt; &amp;gt; ????????????????????????????????sql??????
&gt; &amp;gt; #&amp;amp;nbsp; -- 
??????5??????????????vid??vid_group???????????????????????????????????????????? 
--
&gt; &amp;gt; ??5????????5????????????????mysql insert into
&gt; rt_app.app_video_cover_abtest_test&amp;amp;nbsp;
&gt; &amp;gt; select&amp;amp;nbsp; begin_time,&amp;amp;nbsp; vid,&amp;amp;nbsp;
&gt; vid_group,&amp;amp;nbsp; max(dv),&amp;amp;nbsp;
&gt; &amp;gt; max(click),&amp;amp;nbsp; max(vv),&amp;amp;nbsp; max(effectivevv)
&gt; from(&amp;amp;nbsp;
&gt; &amp;gt; select&amp;amp;nbsp;&amp;amp;nbsp; t1.begin_time
&gt; begin_time,&amp;amp;nbsp;&amp;amp;nbsp; t1.u_vid
&gt; &amp;gt; vid,&amp;amp;nbsp;&amp;amp;nbsp; t1.u_vid_group
&gt; vid_group,&amp;amp;nbsp;&amp;amp;nbsp; dv,&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; click,&amp;amp;nbsp;&amp;amp;nbsp; 
vv,&amp;amp;nbsp;&amp;amp;nbsp; if(effectivevv is
&gt; null,0,effectivevv)
&gt; &amp;gt; effectivevv&amp;amp;nbsp; from&amp;amp;nbsp; 
(&amp;amp;nbsp;&amp;amp;nbsp; --
&gt; dv??click??vv&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; select&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; CAST(TUMBLE_START(bjdt,INTERVAL '5' MINUTE)
&gt; &amp;gt; AS STRING) begin_time,&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp; 
cast(u_vid as
&gt; bigint)
&gt; &amp;gt; u_vid,&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; u_vid_group,&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; sum(if(concat(u_mod,'-',u_ac)='emptylog-video_display' and
&gt; &amp;gt; u_c_module='M011',1,0)) 
dv,&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; sum(if(concat(u_mod,'-',u_ac)='emptylog-video_click' and
&gt; &amp;gt; u_c_module='M011',1,0)) 
click,&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; sum(if(concat(u_mod,'-',u_ac)='top-hits' and 
u_f_module='M011',1,0))
&gt; &amp;gt; vv&amp;amp;nbsp;&amp;amp;nbsp; FROM
&gt; rt_ods.ods_applog_vidsplit&amp;amp;nbsp;&amp;amp;nbsp; where u_vid is
&gt; &amp;gt; not null and 
trim(u_vid)<&amp;amp;amp;gt;''&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; and u_vid_group is
&gt; &amp;gt; not null and trim(u_vid_group) not in
&gt; ('','-1')&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp; and
&gt; &amp;gt; (&amp;amp;nbsp; (concat(u_mod,'-',u_ac) in
&gt; &amp;gt; ('emptylog-video_display','emptylog-video_click')&amp;amp;nbsp; 
and
&gt; &amp;gt; u_c_module='M011')&amp;amp;nbsp; or&amp;amp;nbsp;
&gt; (concat(u_mod,'-',u_ac)='top-hits' and
&gt; &amp;gt; 
u_f_module='M011')&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; )&amp;amp;nbsp;&amp;amp;nbsp; group
&gt; &amp;gt; by&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp; 
TUMBLE(bjdt, INTERVAL '5'
&gt; &amp;gt; MINUTE),&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp; cast(u_vid as
&gt; bigint),&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; u_vid_group&amp;amp;nbsp; ) t1&amp;amp;nbsp; left 
join&amp;amp;nbsp;
&gt; (&amp;amp;nbsp;&amp;amp;nbsp; --
&gt; &amp;gt; effectivevv&amp;amp;nbsp;&amp;amp;nbsp; 
select&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; begin_time,&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; u_vid,&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; u_vid_group,&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp; count(1)
&gt; effectivevv&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; from&amp;amp;nbsp;&amp;amp;nbsp; 
(&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; select&amp;amp;nbsp; begin_time,&amp;amp;nbsp;
&gt; &amp;gt; u_vid,&amp;amp;nbsp; u_vid_group,&amp;amp;nbsp; 
u_diu,&amp;amp;nbsp;
&gt; u_playid,&amp;amp;nbsp; m_pt,&amp;amp;nbsp;
&gt; &amp;gt; q70&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp; 
from&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; dw.video_pic_title_q70
&gt; &amp;gt; a&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp; 
join&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; (&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; select&amp;amp;nbsp;&amp;amp;nbsp; 
CAST(TUMBLE_START(bjdt,INTERVAL '5'
&gt; MINUTE) AS STRING)
&gt; &amp;gt; begin_time,&amp;amp;nbsp; cast(u_vid as bigint) 
u_vid,&amp;amp;nbsp;
&gt; u_vid_group,&amp;amp;nbsp;
&gt; &amp;gt; u_diu,&amp;amp;nbsp; u_playid,&amp;amp;nbsp; max(u_playtime)
&gt; m_pt&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; FROM
&gt; 
rt_ods.ods_applog_vidsplit&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
 where
&gt; u_vid is not
&gt; &amp;gt; null and trim(u_vid)<&amp;amp;amp;gt;''&amp;amp;nbsp; and 
u_vid_group is not
&gt; null and
&gt; &amp;gt; trim(u_vid_group) not in ('','-1')&amp;amp;nbsp; and
&gt; &amp;gt; concat(u_mod,'-',u_ac)='emptylog-video_play_speed'&amp;amp;nbsp; 
and
&gt; &amp;gt; u_f_module='M011'&amp;amp;nbsp; and
&gt; 
u_playtime&amp;amp;amp;gt;0&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; group by&amp;amp;nbsp;&amp;amp;nbsp; TUMBLE(bjdt, INTERVAL '5'
&gt; MINUTE),&amp;amp;nbsp; cast(u_vid as
&gt; &amp;gt; bigint),&amp;amp;nbsp; u_vid_group,&amp;amp;nbsp; 
u_diu,&amp;amp;nbsp;
&gt; u_playid&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp; )
&gt; &amp;gt; b&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp; on
&gt; a.vid=b.u_vid&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp; group 
by&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; begin_time,&amp;amp;nbsp; u_vid,&amp;amp;nbsp; 
u_vid_group,&amp;amp;nbsp;
&gt; u_diu,&amp;amp;nbsp;
&gt; &amp;gt; u_playid,&amp;amp;nbsp; m_pt,&amp;amp;nbsp; 
q70&amp;amp;nbsp;&amp;amp;nbsp; )
&gt; temp&amp;amp;nbsp;&amp;amp;nbsp; where
&gt; &amp;gt; m_pt&amp;amp;amp;gt;=q70&amp;amp;nbsp;&amp;amp;nbsp; group
&gt; by&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; &amp;gt; begin_time,&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp;
&gt; u_vid,&amp;amp;nbsp;&amp;amp;nbsp;&amp;amp;nbsp; u_vid_group&amp;amp;nbsp; 
)
&gt; &amp;gt; t2&amp;amp;nbsp; on 
t1.begin_time=t2.begin_time&amp;amp;nbsp;&amp;amp;nbsp; and
&gt; &amp;gt; t1.u_vid=t2.u_vid&amp;amp;nbsp;&amp;amp;nbsp; and
&gt; t1.u_vid_group=t2.u_vid_group
&gt; &amp;gt; )t3&amp;amp;nbsp;&amp;amp;nbsp; group by 
begin_time,&amp;amp;nbsp; vid,&amp;amp;nbsp;
&gt; vid_group ;



-- 
Best regards!
Rui Li

回复