logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

flink taskmanager 挂掉 报错No pooled slot available and request to ResourceManager for new slot failed

1、解决办法:调大taskmanager.memory.process.size 参数的数值。2、导致此问题的原因:taskmanager.memory.process.size 数值太小 task任务内存溢出导致 taskManager 挂掉,taskmanager 挂掉导致提交的任务没有可用的slot,所以报No pooled slot available andrequest to Reso

#java
flink1.12接受Kafka数据写入hive中,hive客户端不能查询数据

1、代码如下StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();env.setRuntimeMode(RuntimeExecutionMode.STREAMING);env.getConfig().registerKryoType(BusEventKafka.class);//e

#java#flink
kafka java客户端获取topic列表

需要加入的依赖jar包<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka_2.11</artifactId></dependency>代码如下:public static void main(String[] args) throws Interru

#kafka
到底了