flink1.10通过sql的形式连接kafka,处理数据写出到kafka,然后我里面大概是10个这样的逻辑,insert into sink
select
...,10个sql都是直接sink的,运行几分钟就报错,org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.TimeoutException:
Topic boss.nlp.hbase.feature-sync-60 not present in metadata after 60000 ms.
但是我吧这个10个select语句union后在sink到kafka,没有这个问题,这个有什么合理的解释吗



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复