logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

Flink Recovery is suppressed by NoRestartBackoffTime Strategy

Recovery is suppressed by NoRestartBackoffTime Strategy 主键冲突1、错误场景首先我这个错误场景是使用flink连接mysql时报的错。2、错误原因导致这个报错的原因是因为,mysql表里面设置了主键,并且新插入的数据中在mysql中已经存在,所以才会导致主键冲突。3、解决方案方案一:第一种解决方案,就是在flink DDL中添加主键:prim

文章图片
#flink#策略模式#mysql
Flink Recovery is suppressed by NoRestartBackoffTime Strategy

Recovery is suppressed by NoRestartBackoffTime Strategy 主键冲突1、错误场景首先我这个错误场景是使用flink连接mysql时报的错。2、错误原因导致这个报错的原因是因为,mysql表里面设置了主键,并且新插入的数据中在mysql中已经存在,所以才会导致主键冲突。3、解决方案方案一:第一种解决方案,就是在flink DDL中添加主键:prim

文章图片
#flink#策略模式#mysql
kafka单节点创建 topic 超时

kafka单节点创建 topic 超时单节点kafka创建topic时报错:Timed out waiting for a node assignment. Call: createTopics经过检查是因为server.properties 配置文件的问题找到listeners=PLAINTEXT://localhost:9092 这一行之后注释掉,然后重启kafka即可。...

#大数据#intellij-idea#kafka
到底了