flink使用sql-client-defaults.yml无效

希望在flink sql脚本启动时自动选择catalog,减少麻烦。于是乎配置sql-client-defaults.yaml:

catalogs:
  - name: hive_catalog
    type: iceberg
    catalog-type: hive
    property-version: 1
    cache-enabled: true
    uri: thrift://localhost:9083
    client: 5
    warehouse: hdfs://localhost:9000/user/hive/warehouse
    hive-conf-dir: /opt/hive/conf

发现没有效果。查了下资料,自flink1.14开始已经不使用sql-client-defaults.yaml了

改用启动sql脚本的方式:

sql-client.sh embedded -i /opt/flink/conf/sql-startup.sql shell

sql-startup.sql:

create catalog hive_catalog with(
'type'='iceberg',
'catalog-type'='hive',
'property-version'='1',
'cache-enabled'='true',
'uri'='thrift://localhost:9083',
'client'='5',
'warehouse'='hdfs://localhost:9000/user/hive/warehouse',
'hive-conf-dir'='/opt/hive/conf'
);

USE CATALOG hive_catalog;
-- create database hive_catalog.test;
use hive_catalog.test;

这样进入后就使用了自己的catalog并默认在test库了

还可执行多个脚本方式:

sql-client.sh embedded shell -i a.sql,b.sql

相关推荐

  1. <span style='color:red;'>Flink</span> <span style='color:red;'>SQL</span>

    Flink SQL

    2023-12-23 12:00:02      13 阅读
  2. flink学习-flink sql

    2023-12-23 12:00:02       6 阅读
  3. client-go使用方法

    2023-12-23 12:00:02       41 阅读
  4. Flink SQL使用watermark进阶功能

    2023-12-23 12:00:02       21 阅读

最近更新

  1. TCP协议是安全的吗?

    2023-12-23 12:00:02       18 阅读
  2. 阿里云服务器执行yum,一直下载docker-ce-stable失败

    2023-12-23 12:00:02       19 阅读
  3. 【Python教程】压缩PDF文件大小

    2023-12-23 12:00:02       18 阅读
  4. 通过文章id递归查询所有评论(xml)

    2023-12-23 12:00:02       20 阅读

热门阅读

  1. 【安全】audit的一些问题以及需要注意的地方

    2023-12-23 12:00:02       42 阅读
  2. 二分查找(红蓝染色法)

    2023-12-23 12:00:02       45 阅读
  3. 使用QT实现RTSP视频流传输编程

    2023-12-23 12:00:02       42 阅读