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 源码做深度解析的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。