?????? ????Flink1.10.0????hive??source??????????

Tue, 03 Mar 2020 02:46:57 -0800 

hi??jinsong??
                    
 
     ???????????????? ??????????????????????????????????????????????10??
??????????????sql   select * from  mytable limit 1;
hive??mytable??????10??????????????????10??????????????????????????
     ??2020??03??2?? 16:38??JingsongLee<[email protected]&gt; 
?????? 
 
  ????????Batch??????????Hive table??

Best,
Jingsong Lee


------------------------------------------------------------------
From:like <[email protected]&gt;
Send Time:2020??3??2??(??????) 16:35
To:[email protected] <[email protected]&gt;
Subject:?????? ????Flink1.10.0????hive??source??????????

  
?????????? StreamTableEnvironment????????????????????????
??2020??3??2?? 16:16??JingsongLee<[email protected]&gt; ?????? &nbsp; 
 ??????????????????????????????????????

????????????????Batch??????????????????????

Best,
Jingsong Lee

------------------------------------------------------------------
From:like <[email protected]&gt;
Send Time:2020??3??2??(??????) 15:35
To:[email protected] <[email protected]&gt;; 
[email protected] <[email protected]&gt;
Subject:?????? ????Flink1.10.0????hive??source??????????


????????????????????????????????????????????source??????????????????????????????????????????????????
 
 

??2020??3??2?? 15:18??JingsongLee<[email protected]&gt; ?????? 
&nbsp; Hi, 

1.10????Hive 
source??????????????????????????????????????????flink-conf.yaml????????????????
- table.exec.hive.infer-source-parallelism=true (????????????????)
- table.exec.hive.infer-source-parallelism.max=1000 (??????????????????)

Sink??????????????????????????????????Shuffle??????????????????????

Best,
Jingsong Lee


------------------------------------------------------------------
From:like <[email protected]&gt;
Send Time:2020??3??2??(??????) 14:58
To:[email protected] <[email protected]&gt;
Subject:????Flink1.10.0????hive??source??????????

hi????????

 
??????flink1.10.0????hive????????????????????????????????????????????????????sink??????????????????
??source??????????????????????????source??????????????????????????????1000????????????????????????????????
 &nbsp;&nbsp;

回复