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

Tue, 03 Mar 2020 21:32:23 -0800 

??????????????????????????????sql??????????????????????sql??????????hive??????????????????????????????????????????sql??????????????????????????????????????
                           
              
                    
 
     
 
     ??2020??03??4?? 13:25??JingsongLee<[email protected]&gt; ?????? 
 
  Hi jun,


Jira: https://issues.apache.org/jira/browse/FLINK-16413
FYI


Best,
Jingsong Lee


------------------------------------------------------------------
From:JingsongLee <[email protected]&gt;
Send Time:2020??3??3??(??????) 19:06
To:Jun Zhang <[email protected]&gt;; [email protected] 
<[email protected]&gt;
Cc:[email protected] <[email protected]&gt;; like 
<[email protected]&gt;
Subject:Re: ????Flink1.10.0????hive??source??????????


Hi jun,

??????????~ ??????????????~ ??????????JIRA

Best,
Jingsong Lee


------------------------------------------------------------------
From:Jun Zhang <[email protected]&gt;
Send Time:2020??3??3??(??????) 18:45
To:[email protected] <[email protected]&gt;; JingsongLee 
<[email protected]&gt;
Cc:[email protected] <[email protected]&gt;; like 
<[email protected]&gt;
Subject:?????? ????Flink1.10.0????hive??source??????????


&nbsp;
hi??jinsong??
&nbsp;???????????????? ??????????????????????????????????????????????10??
??????????????sql&nbsp;&nbsp; select * from&nbsp; mytable limit 1;
hive??mytable??????10??????????????????10??????????????????????????
??2020??03??2?? 16:38??JingsongLee<[email protected]&gt; 
??????&nbsp;&nbsp;&nbsp; ????????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;&nbsp; 
&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;&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????????

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

回复