?????? flink 1.12 Cancel Job??????????(??)

[????]

????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????job????????????????????????????????????????????


| |
????
|
|
liuha...@163.com
|
??????????????????????
??2021??1??5?? 09:04????????<25977...@qq.com> ??????
??????flink-sql????????????????????????????????????????????????????????jar????????????????????????MemoryStateBackend??????????????23:57-kill????????????job????????00:30????azkaban????????????????????????????????????????00:30??????????????????????????????????????????????kill??????????????????NodeManager??????????????????????????????????00:30????????????????????????????????????????????????????????????????????????????????????????????????????????1000??????????????900??????????????????????????????????????????????????????????????|insert
 into app_bs_drainage_place
|SELECT
|     do.GrouporgName,
|     du.Name,
|     COUNT(DISTINCT dooi.Code) AS TotalSingular,
|    md5(concat(do.GrouporgName,du.Name,cast(current_date as String))) as uuids,
|    current_date as As_Of_Date
|FROM dw_od_order_info dooi
|  INNER JOIN dw_worktask_info dwi ON dwi.CustomerId = dooi.CustomerId AND 
dwi.HandlerPersonId = dooi.UserId and dwi.As_Of_Date=current_date
|  INNER JOIN dim_cc_media_placement_label_relation dmplr ON 
dmplr.MediaPlacementId = dwi.PlacementId
|  INNER JOIN dim_cc_media_label dcml ON dmplr.LabelId = dcml.Id AND dcml.Name 
IN ('????????', '??????')
|  INNER JOIN dim_user du ON dooi.UserId = du.Id
| INNER JOIN dim_org do ON dooi.UserOrgId = do.Grouporgid AND 
left(do.GrouporgName, 2) = '????'
| WHERE dooi.As_Of_Date=current_date and dooi.Status <&gt; 60 AND dooi.Status 
<&gt; 120 AND dooi.OrgType = 1
| GROUP BY do.GrouporgName,du.Name




------------------&nbsp;????????&nbsp;------------------
??????: "??????"<hinobl...@gmail.com&gt;;
????????: 2021??1??4??(??????) ????10:06
??????: "user-zh"<user-zh@flink.apache.org&gt;;
????: Re: flink 1.12 Cancel Job??????????(??)



????SQL????????????????????????????????
????????????????????????????????????????????2????????????????????????????????????????????
????????????????????????????????????????????/??????????????????????????????????????????????

?????? <25977...@qq.com&gt; ??2021??1??4?????? ????8:45??????

&gt; 
??????????????yarn-cluster????????23:50??????/opt/module/hadoop3.2.1/bin/yarn
&gt; application -kill
&gt; 
application_1609656886263_0043??kill??job????????1:30??????????????????????????????????????????kill-job??????????????state??????????????????????????????
&gt;
&gt;
&gt;
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; ??????: "??????"<hinobl...@gmail.com&amp;gt;;
&gt; ????????: 2020??12??29??(??????) ????9:35
&gt; ??????: "user-zh"<user-zh@flink.apache.org&amp;gt;;
&gt; ????: Re: flink 1.12 Cancel Job??????????(??)
&gt;
&gt;
&gt;
&gt; ??????????????????????taskManager??taskManager??&amp;nbsp; 
taskManager??????????????????????????????????????????
&gt; taskManager 
??????????cancel??taskManager????????????????????????????????????
&gt; ????????yarn??????per-job??????????
&gt;
&gt; ?????? <25977...@qq.com&amp;gt; ??2020??12??29?????? ????9:00??????
&gt;
&gt; &amp;gt; ????????????flink
&gt; &amp;gt;
&gt; 
sql????Cancel????????????????????????????????Cancel????????????????????????IDEA??????????????????????????Checkpoints????????????????????Cancel????????????????job????????TaskManager??????