``` version: "3.2" services: jobmanager: image: flink:latest ports: - "8081:8081" command: jobmanager environment: - | FLINK_PROPERTIES= jobmanager.rpc.addre...
docker-compose运行Flink
docker-compose运行kafka
``` version: '3.2' services: zoo1: image: confluentinc/cp-zookeeper:7.3.2 hostname: zoo1 container_name: zoo1 ports: - "2181:2181" environment: ZOOKEEPER_CLI...
使用idea配置一个maven的flink项目消费kafka数据进行流式处理
## 创建项目 idea新建项目，Archetype选择：org.apache.maven.archetypes:maven-archetype-quickstart 项目创建好之后，pom依赖补充一些flink相关的，日志相关的和打包...
Mac安装老版本的系统
我的mac电脑有点老，随着系统的升级感觉越来越不好用了，想了想，也看到网上别人的评价，感觉那个Mojave系统还是不错的，想降级到这个系统。 直接在苹果商店搜索 “macOS...
MacOS移除系统升级提醒
**1.系统配置-软件更新-高级，帮里面的勾选都去掉** **2.移除系统配置上面那个升级的小提示** ``` defaults write com.apple.systempreferences AttentionPrefBundleIDs...
Flink消费kafka，对同一个数据源进行多维度的实时分析处理
我的诉求是，我现在kafka上面有个实时是数据流，他是一个接口的请求日志。 我现在想要实时分析出来每个接口的访问频次和延迟，我还想按照系统的维度统计访问频次和延迟...
Flink面试，看这篇就足够了
概述 2019 年是大数据实时计算领域最不平凡的一年，2019 年 1 月阿里巴巴 Blink （内部的 Flink 分支版本）开源，大数据领域一夜间从 Spark 独步天下走向了两强争霸的时...
硬核！一文学完Flink流计算常用算子,Flink算子大全
**直入正题！** Flink和Spark类似，也是一种一站式处理的框架；既可以进行批处理（DataSet），也可以进行实时处理（DataStream）。 所以下面将Flink的算子分为两大类：...
python脚本监控家里电视是否开机及开机时常
家里小朋友放学会自己打开电视看，需要控制小朋友看电视时常，写一个脚本来进行监控。 ``` #!/usr/bin/python # -*- coding: UTF-8 -*- import subprocess import time ...
Flink 原理与实现：Window 机制
Flink 认为 Batch 是 Streaming 的一个特例，所以 Flink 底层引擎是一个流式引擎，在上面实现了流处理和批处理。而窗口（window）就是从 Streaming 到 Batch 的一个桥梁...
