yarnsession启动的flinksqlclient 如何用set设置utf-8呢?

yarnsession启动的flinksqlclient 如何用set设置utf-8呢?

展开
收起
wenti 2023-01-08 19:40:43 236 分享 版权
1 条回答
写回答
取消 提交回答
  • 在使用 yarnsession 模式启动 Flink SQL Client 时,可以使用以下方法设置 UTF-8 编码:

    SET execution.character-set='utf-8';
    步骤:

    启动 Flink SQL Client,如下所示:
    ./bin/sql-client.sh yarn-session
    在 SQL Client 提示符下,执行以下命令:
    SET execution.character-set='utf-8';
    现在,所有后续查询都将使用 UTF-8 编码。
    注意:

    确保在执行任何其他查询或操作之前设置编码。
    如果需要在会话中重新设置编码,请再次运行 SET execution.character-set='utf-8'; 命令。
    其他资源:

    Flink SQL Client 文档
    Flink 配置选项
    其他提示:

    还可以通过 Flink 配置文件 (flink-conf.yaml) 设置默认字符集,如下所示:
    execution.character-set: utf-8
    某些数据源或格式可能需要显式指定字符集。请参阅特定数据源或格式的文档以获取详细信息。

    2024-02-23 16:12:45
    赞同 展开评论

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

收录在圈子:
实时计算 Flink 版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。
还有其他疑问?
咨询AI助理