1、Caused by: : : Could not find Flink job
找不到job,flink假死重启下服务
2、: The main method caused an error: Field types of query result and registered TableSink do not match.
字段类型不匹配,在用concat这种,要都是string格式。
concat(CURRENT_DATE,’’,name) 会报错,改成下面的这种
concat(
cast(CURRENT_DATE as string),’’,name
)