场景
使用Flink，从阿里云的AMQP中获取数据，然后直接写入到InfluxDB中。即：
source：amqp
sink：influxdb
环境
Linux：Centos8.0
Hadoop：2.8.3
Flink：1.10.0
Java：1.8.0_77
InfluxDB：1.7.1
RocketMQ：4.6.1
数据流
踩坑1
错误日志如下：
复制代码
2020-03-16 09:38:01,555 INFO org.apache.flink.yarn.YarnClusterDescriptor - Found Web Interface rexel-ids003:9081 of application 'application_1584064740592_0003'.
Job has been submitted with JobID 72a5e1fc34a1998228644056567b03eb
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
