[jira] [Created] (FLINK-23096) HiveParser could not attach the sessionstate of hive

["shizhengchao (Jira)" <ji...@apache.org>]

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)