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
  
 

文章来源: wenyusuran.blog.csdn.net，作者：文宇肃然，版权归原作者所有，如需转载，请联系作者。

原文链接：wenyusuran.blog.csdn.net/article/details/122184715