tringSchema())).name("flink-conncetors-kafka");
// .addSink(SinkProducer);
//.print();
System.out.println("4");
env.execute("WordCount from Kafka data");
=
感谢！
..@163.com
>
> 发件人： zhangjunjie1...@163.com
> 发送时间： 2019-10-21 11:05
> 收件人： user-zh
> 抄送： zhangjunjie1130
> 主题： Flink提jar包部署到Yarn上报错
> 您好：
> 我的程序是从kafka取数，然后Flink处理后有写入kafka；本地运行正常，上传到Yarn集群上报错，
>Flink版本是：1.7.2
>
> 错误是：
> 2019-10-21 09:52:30,054 INFO
>
参考：http://mail-archives.apache.org/mod_mbox/flink-user-zh/201905.mbox/%3c2019052911134683852...@wsmtec.com%3E
hery...@163.com
发件人： zhangjunjie1...@163.com
发送时间： 2019-10-21 11:05
收件人： user-zh
抄送： zhangjunjie1130
主题： Flink提jar包部署到Yarn上报错
您好：
我的程序是从kafka取数，然后Flink处理后有写入kafka；本地运行正常，上传到
您好：
我的程序是从kafka取数，然后Flink处理后有写入kafka；本地运行正常，上传到Yarn集群上报错，
Flink版本是：1.7.2
错误是：
2019-10-21 09:52:30,054 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Checkpoint
triggering task Source: Custom Source -> Flat Map -> Map -> Map -> Sink:
flink-conncetors-kafka (
