shizhengchao created FLINK-23096: ------------------------------------ Summary: HiveParser could not attach the sessionstate of hive Key: FLINK-23096 URL: https://issues.apache.org/jira/browse/FLINK-23096 Project: Flink Issue Type: Bug Components: Connectors / Hive Affects Versions: 1.13.1 Reporter: shizhengchao
My sql code is as follows: {code:java} //代码占位符 CREATE CATALOG myhive WITH ( 'type' = 'hive', 'default-database' = 'default', 'hive-conf-dir' = '/home/service/upload-job-file/1624269463008' ); use catalog hive; set 'table.sql-dialect' = 'hive'; create view if not exists view_test as select cast(goods_id as string) as goods_id, cast(depot_id as string) as depot_id, cast(product_id as string) as product_id, cast(tenant_code as string) as tenant_code from edw.dim_yezi_whse_goods_base_info/*+ OPTIONS('streaming-source.consume-start-offset'='dayno=20210621') */; {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)