创建flink环境接收kafka消息，然后创建StreamTableEnvirment把处理后的数据插入hive，这样的花会启动两个flink job 求解。
可以把计算程序逻辑代码发布成一个jar包就可以了