Flink SQL xxx is not serializable. The object probably contains or references non serializable field

Posted 2022-06-04 @SmartSi

Flink 版本：1.10.3

1. 现象

在执行如下自定义 Socket Connector 示例：

// 创建 Socket Source 表
String sourceSql = "CREATE TABLE socket_source_table (\\n" +
        "  word STRING COMMENT \'单词\'\\n" +
        ") WITH (\\n" +
        "  \'connector.type\' = \'socket\',\\n" +
        "  \'host\' = \'localhost\',\\n" +