?????? flink 1.13.1 sql hive is_generic = false ??????????????????????

Mon, 26 Jul 2021 01:54:49 -0700 

??????flink 1.12.0??????????????




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2021??7??26??(??????) ????4:43
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: flink 1.13.1 sql hive is_generic = false ??????????????????????



??????

????????????????hive dialect????????

On Mon, Jul 26, 2021 at 2:44 PM Asahi Lee <[email protected]&gt; wrote:

&gt; hi!
&gt; ??????flink 
1.13.1??????????sql????hive????????????????????????????????????????????????????????????
&gt; ??????????hive 2.3.6??????????flink-sql-connector-hive-2.3.6????????
&gt;
&gt;
&gt; package com.meritdata.cloud.flink.test;
&gt;
&gt;
&gt; import org.apache.flink.table.api.EnvironmentSettings;
&gt; import org.apache.flink.table.api.TableEnvironment;
&gt;
&gt;
&gt; public class Test {
&gt;
&gt;
&gt; &amp;nbsp; &amp;nbsp; public static void main(String[] args) {
&gt;
&gt;
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; EnvironmentSettings bbSettings 
=
&gt; EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; TableEnvironment 
tableEnvironment =
&gt; TableEnvironment.create(bbSettings);
&gt;
&gt;
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; 
tableEnvironment.executeSql("create catalog
&gt; myhive with (" +
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; 
&amp;nbsp; &amp;nbsp; " 'type' = 'hive',
&gt; " +
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; 
&amp;nbsp; &amp;nbsp; "
&gt; 'default-database' = 'default', " +
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; 
&amp;nbsp; &amp;nbsp; ")");
&gt;
&gt;
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; 
tableEnvironment.executeSql("use catalog
&gt; myhive");
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; 
tableEnvironment.executeSql("create table if
&gt; not exists q1 " +
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; 
&amp;nbsp; &amp;nbsp; "( id string ) " +
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; 
&amp;nbsp; &amp;nbsp; "with
&gt; ('is_generic' = 'false')");
&gt;
&gt;
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; /**
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;* 
hive????????????????????, ????????
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;* desc formatted q1;
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;*
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;* col_name&amp;nbsp; 
&amp;nbsp; &amp;nbsp; &amp;nbsp;
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; data_type&amp;nbsp; &amp;nbsp; &amp;nbsp; 
&amp;nbsp; &amp;nbsp; &amp;nbsp;
&gt; &amp;nbsp;comment
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;*
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;*
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;* Table Parameters:
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;* 
flink.is_generic&amp;nbsp; &amp;nbsp; false
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;* 
flink.schema.0.data-type&amp;nbsp;
&gt; VARCHAR(2147483647)
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;* 
flink.schema.0.name&amp;nbsp; &amp;nbsp;id
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;* 
transient_lastDdTime 1627279802
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;*
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp; &amp;nbsp;*/
&gt;
&gt;
&gt; &amp;nbsp; &amp;nbsp; }
&gt;
&gt;
&gt;
&gt;
&gt; }



-- 
Best regards!
Rui Li

回复