Flink从入门到精通100篇（二十四）-对Flink SQL Client 源码做深度解析

前言

本文基于 Flink 1.12-SNAPSHOT，使用sql client命令行提交insert语句进行整个流程的分析。

sql-client.sh embedded --update "INSERT INTO user_log_sink2 SELECT * FROM user_log"

Initialize the environment

主类：org.apache.flink.table.client.SqlClient#main

public static void main(String[] args) {
  if (args.length < 1) {
   CliOptionsParser.printHelpClient();
   return;
  }  switch (args[0]) {   case MODE_EMBEDDED:
    // remove mode
    final String[] modeArgs = Arrays.copyOfRange(args, 1, args.length);
    final CliOptions options = CliOptionsParser.parseEmbeddedModeClient(modeArgs);
    if (options.isPrintHelp()) {
     CliOptionsParser.printHelpEmbeddedModeClient();
    } else {
     try {
      final SqlClient client = new SqlClient(true, options);
      client.start();
     } catch (SqlClientException e) {
      // make space in terminal
      System.out.println();
      System.out.println();
      LO

Flink从入门到精通100篇（二十四）-对Flink SQL Client 源码做深度解析相关推荐

Flink从入门到精通100篇（十四）-Flink开发IDEA环境搭建与测试
一.IDEA开发环境 1.pom文件设置 <properties><maven.compiler.source>1.8</maven.compiler.source> ...
Flink从入门到精通100篇（十五）-Flink SQL FileSystem Connector 分区提交与自定义小文件合并策略
前言本文先通过源码简单过一下分区提交机制的两个要素--即触发(trigger)和策略(policy)的实现,然后用合并小文件的实例说一下自定义分区提交策略的方法. PartitionCommitTr ...
Flink从入门到精通100篇（十二）-如何分析和定位 Flink 作业 OOM 问题？
前言生产环境,我们的 Flink 作业偶尔会出现 heap OOM,那么当出现这种情况我们会怎么办?通常来说会通过 jmap 命令去将作业的 heap dump 一份文件出来,可是 jmap 导出的 ...
Flink从入门到精通100篇（十八）-CentOS环境中搭建Flink分布式集群
一. Flink的下载安装包下载地址:http://flink.apache.org/downloads.html ,选择对应Hadoop的Flink版本下载 [admin@node21 soft ...
Flink从入门到精通100篇（十）-双亲委派模型与 Flink 的类加载策略
前言我们知道,在 JVM 中,一个类加载的过程大致分为加载.链接(验证.准备.解析).初始化5个阶段.而我们通常提到类的加载,就是指利用类加载器(ClassLoader)通过类的全限定名来获取定义此 ...
Flink从入门到精通100篇（十九）-基于 Flink 的大规模准实时数据分析平台的建设实践
前言如何基于 Flink 搭建大规模准实时数据分析平台?在 Flink Forward Asia 2019 上,来自 Lyft 公司实时数据平台的徐赢博士和计算数据平台的高立博士分享了 Lyft 基 ...
Flink从入门到精通100篇（十七）-Spark/Flink广播如何实现作业配置动态更新？
前言在实时计算作业中,往往需要动态改变一些配置,举几个栗子: 实时日志ETL服务,需要在日志的格式.字段发生变化时保证正常解析: 实时NLP服务,需要及时识别新添加的领域词与停用词: 实时风控服务, ...
Flink从入门到精通100篇（二十一）-万字长文详解 Flink 中的 CopyOnWriteStateTable
前言现如今想阅读 HashMap 源码实际上比较简单,因为网上一大堆博客去分析 HashMap 和 ConcurrentHashMap.本文详细分析 CopyOnWriteStateTable 源码 ...
Flink从入门到精通100篇（二十三）-Flink实战应用案例：如何清理过期的 Checkpoint 目录？
目录 Flink Checkpoint 目录的清除策略生产环境应该选择哪种清除策略生产环境必须定期脚本清理 Checkpoint 和 Savepoint 目录 RocksDB 增量 Checkpo ...

Flink从入门到精通100篇（二十四）-对Flink SQL Client 源码做深度解析

前言

Initialize the environment

Flink从入门到精通100篇（二十四）-对Flink SQL Client 源码做深度解析相关推荐

最新文章

热门文章