????????????????????SqlParser.parseStmtlist()????sql????SqlNode
toString()??????????????unicode????????
------------------ ???????? ------------------
??????:
"user-zh"
<[email protected]>;
????????: 2021??8??4??(??????) ????3:06
??????: "user-zh"<[email protected]>;
????: Re: flink 1.13.1 ????hive??????????hive sql????????
??1.1.0????????????????????insert????????????????????????????????????????????
On Mon, Aug 2, 2021 at 3:05 PM Asahi Lee <[email protected]> wrote:
> hive 1.1.0????
>
>
>
>
> ------------------&nbsp;????????&nbsp;------------------
> ??????:
>
"user-zh"
>
<
> [email protected]&gt;;
> ????????:&nbsp;2021??8??2??(??????) ????12:23
> ??????:&nbsp;"user-zh"<[email protected]&gt;;
>
> ????:&nbsp;Re: flink 1.13.1 ????hive??????????hive sql????????
>
>
>
> ????????????????????????????????????hive??????????????
>
> On Fri, Jul 30, 2021 at 3:00 PM Asahi Lee <[email protected]&gt;
> wrote:
>
> &gt; CREATE TABLE `cosldatacenter.ods_emp_maindata_iadc_paramvalue`(
> &gt; &amp;nbsp; `paramvalue_id` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `platform_id` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `equipment_id` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `param_id` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `param_value` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `remark` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `create_time` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `creator` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `update_time` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `update_person` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `record_flag` double COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `subject_id` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `output_unit` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `show_seq` double COMMENT '')
> &gt; COMMENT ''
> &gt; ROW FORMAT SERDE&amp;nbsp;
> &gt; &amp;nbsp;
'org.apache.hadoop.hive.ql.io.orc.OrcSerde'&amp;nbsp;
> &gt; WITH SERDEPROPERTIES (&amp;nbsp;
> &gt; &amp;nbsp; 'field.delim'=',',&amp;nbsp;
> &gt; &amp;nbsp; 'serialization.format'=',')&amp;nbsp;
> &gt; STORED AS INPUTFORMAT&amp;nbsp;
> &gt; &amp;nbsp; 'org.apache.hadoop.hive.ql.io
> .orc.OrcInputFormat'&amp;nbsp;
> &gt; OUTPUTFORMAT&amp;nbsp;
> &gt; &amp;nbsp; 'org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat'
> &gt; LOCATION
> &gt; &amp;nbsp;
> &gt;
>
'hdfs://hadoop02:8020/user/hive/warehouse/cosldatacenter.db/ods_emp_maindata_iadc_paramvalue'
> &gt; TBLPROPERTIES (
> &gt; &amp;nbsp; 'COLUMN_STATS_ACCURATE'='false',&amp;nbsp;
> &gt; &amp;nbsp; 'last_modified_by'='root',&amp;nbsp;
> &gt; &amp;nbsp; 'last_modified_time'='1621834335',&amp;nbsp;
> &gt; &amp;nbsp; 'numFiles'='0',&amp;nbsp;
> &gt; &amp;nbsp; 'numRows'='-1',&amp;nbsp;
> &gt; &amp;nbsp; 'rawDataSize'='-1',&amp;nbsp;
> &gt; &amp;nbsp; 'totalSize'='0',&amp;nbsp;
> &gt; &amp;nbsp; 'transient_lastDdlTime'='1621834335')
> &gt;
> &gt;
> &gt;
> &gt; CREATE TABLE `cosldatacenter.ods_emp_md_large_equip`(
> &gt; &amp;nbsp; `large_equip_id` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `equip_name` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `equip_type` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `equip_function` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `equip_board` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `ship_yard` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `manufacturer_date` string COMMENT
'',&amp;nbsp;
> &gt; &amp;nbsp; `enqueue_date` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `dockrepair_date` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `scrap_date` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `enqueue_mode` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `work_for_org` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `work_in_org` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `old_age` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `create_time` date COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `creator` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `update_time` date COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `update_person` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `record_flag` double COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `data_timestamp` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `work_unit_id` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `work_status` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `work_location` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `work_area` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `equip_code` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `shi_main_power` double COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `shi_total_len` double COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `shi_type_width` double COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `shi_type_depth` double COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `shi_design_draft` double COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `shi_total_tonnage` double COMMENT
'',&amp;nbsp;
> &gt; &amp;nbsp; `shi_load_tonnage` double COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `remark` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `unit_classification1` string COMMENT
'',&amp;nbsp;
> &gt; &amp;nbsp; `unit_classification2` string COMMENT '')
> &gt; COMMENT ''
> &gt; ROW FORMAT SERDE&amp;nbsp;
> &gt; &amp;nbsp;
'org.apache.hadoop.hive.ql.io.orc.OrcSerde'&amp;nbsp;
> &gt; WITH SERDEPROPERTIES (&amp;nbsp;
> &gt; &amp;nbsp; 'field.delim'=',',&amp;nbsp;
> &gt; &amp;nbsp; 'serialization.format'=',')&amp;nbsp;
> &gt; STORED AS INPUTFORMAT&amp;nbsp;
> &gt; &amp;nbsp; 'org.apache.hadoop.hive.ql.io
> .orc.OrcInputFormat'&amp;nbsp;
> &gt; OUTPUTFORMAT&amp;nbsp;
> &gt; &amp;nbsp; 'org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat'
> &gt; LOCATION
> &gt; &amp;nbsp;
> &gt;
>
'hdfs://hadoop02:8020/user/hive/warehouse/cosldatacenter.db/ods_emp_md_large_equip'
> &gt; TBLPROPERTIES (
> &gt; &amp;nbsp; 'COLUMN_STATS_ACCURATE'='false',&amp;nbsp;
> &gt; &amp;nbsp; 'last_modified_by'='root',&amp;nbsp;
> &gt; &amp;nbsp; 'last_modified_time'='1621834338',&amp;nbsp;
> &gt; &amp;nbsp; 'numFiles'='0',&amp;nbsp;
> &gt; &amp;nbsp; 'numRows'='-1',&amp;nbsp;
> &gt; &amp;nbsp; 'rawDataSize'='-1',&amp;nbsp;
> &gt; &amp;nbsp; 'totalSize'='0',&amp;nbsp;
> &gt; &amp;nbsp; 'transient_lastDdlTime'='1621834338')
> &gt;
> &gt;
> &gt;
> &gt; CREATE TABLE `cosldatacenter.ods_emp_maindata_iadc_paramdef`(
> &gt; &amp;nbsp; `param_id` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `iadc_id` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `param_code` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `param_en` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `param_cn` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `output_standard` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `output_unit` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `param_type` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `param_value` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `remark` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `create_time` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `creator` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `update_time` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `update_person` string COMMENT '',&amp;nbsp;
> &gt; &amp;nbsp; `record_flag` double COMMENT '')
> &gt; COMMENT ''
> &gt; ROW FORMAT SERDE&amp;nbsp;
> &gt; &amp;nbsp;
'org.apache.hadoop.hive.ql.io.orc.OrcSerde'&amp;nbsp;
> &gt; WITH SERDEPROPERTIES (&amp;nbsp;
> &gt; &amp;nbsp; 'field.delim'=',',&amp;nbsp;
> &gt; &amp;nbsp; 'serialization.format'=',')&amp;nbsp;
> &gt; STORED AS INPUTFORMAT&amp;nbsp;
> &gt; &amp;nbsp; 'org.apache.hadoop.hive.ql.io
> .orc.OrcInputFormat'&amp;nbsp;
> &gt; OUTPUTFORMAT&amp;nbsp;
> &gt; &amp;nbsp; 'org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat'
> &gt; LOCATION
> &gt; &amp;nbsp;
> &gt;
>
'hdfs://hadoop02:8020/user/hive/warehouse/cosldatacenter.db/ods_emp_maindata_iadc_paramdef'
> &gt; TBLPROPERTIES (
> &gt; &amp;nbsp; 'COLUMN_STATS_ACCURATE'='false',&amp;nbsp;
> &gt; &amp;nbsp; 'last_modified_by'='root',&amp;nbsp;
> &gt; &amp;nbsp; 'last_modified_time'='1621834335',&amp;nbsp;
> &gt; &amp;nbsp; 'numFiles'='0',&amp;nbsp;
> &gt; &amp;nbsp; 'numRows'='-1',&amp;nbsp;
> &gt; &amp;nbsp; 'rawDataSize'='-1',&amp;nbsp;
> &gt; &amp;nbsp; 'totalSize'='0',&amp;nbsp;
> &gt; &amp;nbsp; 'transient_lastDdlTime'='1621834335')
> &gt;
> &gt;
> &gt;
> &gt; CREATE TABLE `cosldatacenter.dw_riginfoparam`(
> &gt; &amp;nbsp; `large_equip_id` string,&amp;nbsp;
> &gt; &amp;nbsp; `equip_code` string,&amp;nbsp;
> &gt; &amp;nbsp; `equip_name` string,&amp;nbsp;
> &gt; &amp;nbsp; `enqueue_date` string,&amp;nbsp;
> &gt; &amp;nbsp; `shi_total_len` double,&amp;nbsp;
> &gt; &amp;nbsp; `shi_type_width` double,&amp;nbsp;
> &gt; &amp;nbsp; `shi_type_depth` double,&amp;nbsp;
> &gt; &amp;nbsp; `moonpool` string,&amp;nbsp;
> &gt; &amp;nbsp; `maxwindvelocity` string,&amp;nbsp;
> &gt; &amp;nbsp; `maxwaveheight` string,&amp;nbsp;
> &gt; &amp;nbsp; `airgap` string,&amp;nbsp;
> &gt; &amp;nbsp; `maxopewaterdepth` string,&amp;nbsp;
> &gt; &amp;nbsp; `drilldepthcap` string,&amp;nbsp;
> &gt; &amp;nbsp; `drillvl` string,&amp;nbsp;
> &gt; &amp;nbsp; `drillwater` string,&amp;nbsp;
> &gt; &amp;nbsp; `potablewater` string)
> &gt; ROW FORMAT SERDE&amp;nbsp;
> &gt; &amp;nbsp;
'org.apache.hadoop.hive.ql.io.orc.OrcSerde'&amp;nbsp;
> &gt; WITH SERDEPROPERTIES (&amp;nbsp;
> &gt; &amp;nbsp; 'field.delim'=',',&amp;nbsp;
> &gt; &amp;nbsp; 'serialization.format'=',')&amp;nbsp;
> &gt; STORED AS INPUTFORMAT&amp;nbsp;
> &gt; &amp;nbsp; 'org.apache.hadoop.hive.ql.io
> .orc.OrcInputFormat'&amp;nbsp;
> &gt; OUTPUTFORMAT&amp;nbsp;
> &gt; &amp;nbsp; 'org.apache.hadoop.hive.ql.io.orc.OrcOutputFormat'
> &gt; LOCATION
> &gt; &amp;nbsp;
> &gt;
>
'hdfs://hadoop02:8020/user/hive/warehouse/cosldatacenter.db/dw_riginfoparam'
> &gt; TBLPROPERTIES (
> &gt; &amp;nbsp; 'COLUMN_STATS_ACCURATE'='false',&amp;nbsp;
> &gt; &amp;nbsp; 'numFiles'='1',&amp;nbsp;
> &gt; &amp;nbsp; 'numRows'='-1',&amp;nbsp;
> &gt; &amp;nbsp; 'rawDataSize'='-1',&amp;nbsp;
> &gt; &amp;nbsp; 'totalSize'='1564',&amp;nbsp;
> &gt; &amp;nbsp; 'transient_lastDdlTime'='1627353556')
> &gt;
> &gt;
> &gt;
> &gt;
> &gt;
> &gt;
> &gt;
> &gt;
------------------&amp;nbsp;????????&amp;nbsp;------------------
> &gt; ??????:
>
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
> "user-zh"
>
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
> <
> &gt; [email protected]&amp;gt;;
> &gt; ????????:&amp;nbsp;2021??7??30??(??????) ????11:18
> &gt;
??????:&amp;nbsp;"user-zh"<[email protected]&amp;gt;;
> &gt;
> &gt; ????:&amp;nbsp;Re: flink 1.13.1 ????hive??????????hive
sql????????
> &gt;
> &gt;
> &gt;
> &gt; ??????
> &gt;
> &gt; ??????????insert??????????????????DDL??????????????show create
table????????????????
> &gt;
> &gt; On Thu, Jul 29, 2021 at 9:03 PM Asahi Lee
<[email protected]
> &amp;gt;
> &gt; wrote:
> &gt;
> &gt; &amp;gt; hi!
> &gt; &amp;gt;
??????????????else??????????????sql????????????????Invalid table alias or column
> reference
> &gt; 'u'
> &gt; &amp;gt; ??????sql????????'u'????????
> &gt; &amp;gt; CREATE CATALOG `tempo_df_hive_default_catalog` WITH(
> &gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; 'type' =
'hive',
> &gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp;
'default-database' = 'default'
> &gt; &amp;gt; );
> &gt; &amp;gt; USE CATALOG tempo_df_hive_default_catalog;
> &gt; &amp;gt; CREATE TABLE IF NOT EXISTS
`default`.`tempo_blackhole_table`
> (
> &gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp;f0 INT
> &gt; &amp;gt; );
> &gt; &amp;gt; insert into cosldatacenter.dw_riginfoparam
> &gt; &amp;gt; select&amp;amp;nbsp;
> &gt; &amp;gt; c.LARGE_EQUIP_ID,
> &gt; &amp;gt; c.EQUIP_CODE,
> &gt; &amp;gt; c.EQUIP_NAME,
> &gt; &amp;gt; c.ENQUEUE_DATE,
> &gt; &amp;gt; c.SHI_TOTAL_LEN,
> &gt; &amp;gt; c.SHI_TYPE_WIDTH,
> &gt; &amp;gt; c.SHI_TYPE_DEPTH,
> &gt; &amp;gt; case when b.param_cn = '????????' then a.param_value
else null
> end as
> &gt; Moonpool,
> &gt; &amp;gt; case when b.param_cn = '????????' then a.param_value
else null
> end as
> &gt; &amp;gt; MaxWindvelocity,
> &gt; &amp;gt; case when b.param_cn = '????????????' then
a.param_value else null
> end as
> &gt; &amp;gt; MaxWaveheight,
> &gt; &amp;gt; case when b.param_cn = '????' then a.param_value
else null end
> as
> &gt; Airgap,
> &gt; &amp;gt; case when b.param_cn = '????????????????' then
a.param_value else
> null end as
> &gt; &amp;gt; MaxOpeWaterdepth,
> &gt; &amp;gt; case when b.param_cn = '????????????' then
a.param_value else null
> end as
> &gt; &amp;gt; DrilldepthCap,
> &gt; &amp;gt; case when b.param_cn = '????????????' then
a.param_value else null
> end as
> &gt; &amp;gt; DrillVL,
> &gt; &amp;gt; case when b.param_cn = '??????' then a.param_value
else null
> end as
> &gt; &amp;gt; DrillWater,
> &gt; &amp;gt; case when b.param_cn = '??????' then a.param_value
else null
> end as
> &gt; &amp;gt; PotableWater
> &gt; &amp;gt; from cosldatacenter.ods_emp_maindata_iadc_paramvalue
> a&amp;amp;nbsp;
> &gt; &amp;gt; inner join
cosldatacenter.ods_emp_maindata_iadc_paramdef b on
> &gt; a.param_id =
> &gt; &amp;gt; b.param_id
> &gt; &amp;gt; inner join cosldatacenter.ods_emp_md_large_equip c on
> &gt; &amp;gt; a.SUBJECT_ID=c.LARGE_EQUIP_ID;
> &gt; &amp;gt; INSERT INTO `default`.`tempo_blackhole_table` SELECT
1 ;
> &gt; &amp;gt;
> &gt; &amp;gt;
> &gt; &amp;gt;
> &gt; &amp;gt;
> &gt; &amp;gt;
> &gt; &amp;gt; org.apache.hadoop.hive.ql.parse.SemanticException:
Line
> 2:178 Invalid
> &gt; &amp;gt; table alias or column reference 'u': (possible
column names
> are:
> &gt; &amp;gt; a.paramvalue_id, a.platform_id, a.equipment_id,
a.param_id,
> &gt; a.param_value,
> &gt; &amp;gt; a.remark, a.create_time, a.creator, a.update_time,
> a.update_person,
> &gt; &amp;gt; a.record_flag, a.subject_id, a.output_unit,
a.show_seq,
> b.param_id,
> &gt; &amp;gt; b.iadc_id, b.param_code, b.param_en, b.param_cn,
> b.output_standard,
> &gt; &amp;gt; b.output_unit, b.param_type, b.param_value, b.remark,
> b.create_time,
> &gt; &amp;gt; b.creator, b.update_time, b.update_person,
b.record_flag,
> &gt; c.large_equip_id,
> &gt; &amp;gt; c.equip_name, c.equip_type, c.equip_function,
c.equip_board,
> &gt; c.ship_yard,
> &gt; &amp;gt; c.manufacturer_date, c.enqueue_date,
c.dockrepair_date,
> c.scrap_date,
> &gt; &amp;gt; c.enqueue_mode, c.work_for_org, c.work_in_org,
c.old_age,
> &gt; c.create_time,
> &gt; &amp;gt; c.creator, c.update_time, c.update_person,
c.record_flag,
> &gt; c.data_timestamp,
> &gt; &amp;gt; c.work_unit_id, c.work_status, c.work_location,
c.work_area,
> &gt; c.equip_code,
> &gt; &amp;gt; c.shi_main_power, c.shi_total_len, c.shi_type_width,
> c.shi_type_depth,
> &gt; &amp;gt; c.shi_design_draft, c.shi_total_tonnage,
c.shi_load_tonnage,
> c.remark,
> &gt; &amp;gt; c.unit_classification1, c.unit_classification2)
> &gt; &amp;gt;
> &gt; &amp;gt;
> &gt; &amp;gt;
> &gt; &amp;gt;
> &gt; &amp;gt;
>
------------------&amp;amp;nbsp;????????&amp;amp;nbsp;------------------
> &gt; &amp;gt; ??????:
> &gt;
>
&amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;
> &gt; "user-zh"
> &gt;
>
&amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;
> &gt; <
> &gt; &amp;gt; [email protected]&amp;amp;gt;;
> &gt; &amp;gt; ????????:&amp;amp;nbsp;2021??7??29??(??????)
????3:32
> &gt; &amp;gt;
??????:&amp;amp;nbsp;"user-zh"<[email protected]
> &amp;amp;gt;;
> &gt; &amp;gt;
> &gt; &amp;gt; ????:&amp;amp;nbsp;Re: flink 1.13.1
????hive??????????hive sql????????
> &gt; &amp;gt;
> &gt; &amp;gt;
> &gt; &amp;gt;
> &gt; &amp;gt; ????????sql??????????????????ELSE????
> &gt; &amp;gt;
> &gt; &amp;gt; ??????
> &gt; &amp;gt; Leonard
> &gt; &amp;gt;
> &gt; &amp;gt;
> &gt; &amp;gt; &amp;amp;gt; ?? 2021??7??27????20:04??Asahi Lee
> <[email protected]&amp;amp;gt;
> &gt; ??????
> &gt; &amp;gt; &amp;amp;gt;
> &gt; &amp;gt; &amp;amp;gt; CASE
> &gt; &amp;gt;
> &gt;
>
&amp;amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;
> &gt; WHEN mipd.`param_cn` = '????????' THEN
> &gt; &amp;gt;
> &gt;
>
&amp;amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp;
> &gt; mipv.`param_value`&amp;amp;amp;nbsp;
> &gt; &amp;gt;
&amp;amp;gt;&amp;nbsp;&amp;nbsp;&amp;nbsp; END AS `Moonpool`
> &gt;
> &gt;
> &gt;
> &gt; --
> &gt; Best regards!
> &gt; Rui Li
>
>
>
> --
> Best regards!
> Rui Li
--
Best regards!
Rui Li
