自定义TableSink

时隔两年再次发一篇Blog，记录一下这个Flink测试过程中遇到各种问题，一个简单的Job竟然耗费了6个小时才完成。Job要求如下： 自定义 TableSource，从标准输入中按行读取数据，每行按逗号分隔字段。表的 schema 为 （id int, name string, age int） 自定义 TableSink，将 Table 数据写到标准输