- 博客(7)
- 资源 (1)
- 收藏
- 关注
RSS订阅原创 flink的时间窗口和计数窗口
val env = StreamExecutionEnvironment.getExecutionEnvironmentenv.setParallelism(1)val inputdata: DataStream[String] = env.socketTextStream("hadoop102", 6666)//时间窗口 滚动窗口 10秒执行一次每次执行10以内的数据 数据执行不重叠inputdata.map(p=>{ val s = p.split(",") (
2020-12-22 08:23:29
1100
原创 kafka安装的日志问题Error while executing topic command : Replication factor: 2 larger than available broker
kafka 安装出现的问题kafka在男装玩第一个的虚拟机的时候会出现Error while executing topic command : Replication factor: 2 larger than available brokers: 1.意思是：“执行主题命令时出错：复制因子：2大于可用代理：1”。##您看一下不在后台启动的结果 ，/opt/kafka_2.12-1.0.0/bin/kafka-server-start.sh /opt/kafka_2.12-1.0.0/conf
2020-10-31 08:25:27
1896
原创 ES(elasticsearch)搜索引擎 - 配置整合
<dependency> <groupId>org.elasticsearch</groupId> <artifactId>elasticsearch</artifactId> <version>5.6.8</version> </dependency> <dependency> <groupId>org.elasticsearch.client&...
2020-10-17 10:34:14
352
原创 redis或kafka的序列化问题
javax.servlet.ServletException: org.springframework.web.util.NestedServletException: Request processing failed; nested exception is org.springframework.data.redis.serializer.SerializationException: Cannot deserialize; nested exception is org.springframew..
2020-10-06 20:17:27
165
原创 redis与kafka基础
初识Redis一. 为什么在多线程并发情况下，以Redis实现的“自增ID工具”能保证ID按顺序自增长且不重复:此处的自增ID工具用的是redis的增加score方法 , 每调用一次 , redis的key ‘id’ 就自增1 , 返回值为增加后的数值 , 故获取id的动作不会有重复值./** * “自增ID工具” * @description: * @author: Jeff * @date: 2020年9月21日 * @return */public Long getId(){
2020-09-28 00:01:38
160
原创 kafka及redis基础
初识Redis一. 为什么在多线程并发情况下，以Redis实现的“自增ID工具”能保证ID按顺序自增长且不重复:此处的自增ID工具用的是redis的增加score方法 , 每调用一次 , redis的key ‘id’ 就自增1 , 返回值为增加后的数值 , 故获取id的动作不会有重复值./** * “自增ID工具” * @description: * @author: Jeff * @date: 2020年9月21日 * @return */public Long getId(){
2020-09-27 23:58:50
1482
空空如也
TA创建的收藏夹 TA关注的收藏夹
TA关注的人