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

[Jun Zhang]

hi??jinsong??
                    
 
     ???????????????? ??????????????????????????????????????????????10??
??????????????sql   select * from  mytable limit 1;
hive??mytable??????10??????????????????10??????????????????????????
     ??2020??03??2?? 16:38??JingsongLee<lzljs3620...@aliyun.com.INVALID&gt; 
?????? 
 
  ????????Batch??????????Hive table??

Best,
Jingsong Lee


------------------------------------------------------------------
From:like <likeg...@163.com&gt;
Send Time:2020??3??2??(??????) 16:35
To:lzljs3620...@aliyun.com <lzljs3620...@aliyun.com&gt;
Subject:?????? ????Flink1.10.0????hive??source??????????

  
?????????? StreamTableEnvironment????????????????????????
??2020??3??2?? 16:16??JingsongLee<lzljs3620...@aliyun.com&gt; ?????? &nbsp; 
 ??????????????????????????????????????

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

Best,
Jingsong Lee

------------------------------------------------------------------
From:like <likeg...@163.com&gt;
Send Time:2020??3??2??(??????) 15:35
To:user-zh@flink.apache.org <user-zh@flink.apache.org&gt;; 
lzljs3620...@aliyun.com <lzljs3620...@aliyun.com&gt;
Subject:?????? ????Flink1.10.0????hive??source??????????


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

??2020??3??2?? 15:18??JingsongLee<lzljs3620...@aliyun.com.INVALID&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 <likeg...@163.com&gt;
Send Time:2020??3??2??(??????) 14:58
To:user-zh@flink.apache.org <user-zh@flink.apache.org&gt;
Subject:????Flink1.10.0????hive??source??????????

hi????????

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