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

Posted 2022-01-29 文宇肃然

前言

本文基于 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