前言

本文基于 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 源码做深度解析的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。