Java bug搬运工，小数据攻城狮^O^
发简信
IP属地：广东
Levels of Abstraction Flink提供了不同级别的抽象 来开发 批处理/流计算。 最底层的抽象只提供了有状态数据流。底层次有状数据流通过 Process ...
Tasks and Operator Chains 对于分布式计算，Flink 把operator subtasks 运行子任务串连在一起，组合成Tasks。每个线程执行一个...
Flink 程序是可以在分布式数据集上实现类似常规数据加工操作的框架 (例如：filtering, mapping, updating state, joining, gro...
Apache Flink是一个可以在有限流数据流和无限流基础上进行有状态计算的大数据处理框架。Flink从下到上提供了不同层级的API抽象，并为常见的用例提供了专用的开发库。...
从源码编译Flink需要在本地安装以下基础组件. 系统环境: MacOS - Darwin localhost 19.5.0 Darwin Kernel Version 19...
Git Tag 操作 查看Tag 创建Tag tag 需要单独创建，并单独推送至远程服务器。而且Tag 也可以给之前push的版本打标签，不一定非得是当前版本。 删除Tag ...
在服务器上拉取gitlab中的工程，结果报以一错误: 原因是pull工程时认证失败。解决:使用: git clone https://username:password@gi...
要学习一个Spark源码，想在学习过程中加一些注释，便于日后自己回忆、与同事分享。所以下载了Spark源码，并上传到自己github。在向远程push代码的时候，报上面错误。...
开发 Spark 程序，需要格式化日志输出， 由于log4j2的性能比 log4j1.x，及 logback 好，因此配置了log4j2.xml 日志输出配置文件。写程序程序...
业务需要，开发一个自动添加 监控 flume 进程的 crontab 任务。大概思路是 如果用户配置了 crontab 那么把所有 crontab 内容先输出到一个文件中，之...
业务开发中由于数据库设计有缺陷, 导致一个列中存储了多个值。这种情况下，在业务开发过程中， 需要将列转换为行。进行操作。如:image.png Goole 得: 参考连接:M...
MySql__为用户赋于主从同步的权限 在配置Otter的时候报错: 经查询是同步账户没有权限。使用同步账户在MySql中执行 'show master status'，出现...
本机MySql创建Otter配置表出错: MySql建表语句是: 解决方案是设置: SET SQL_MODE = 'ALLOW_INVALID_DATES';
MySql__Mac下打开BinLog. 查看是否开启 log_bin. 在my.cnf配置文件中打开 bin_log 选项 【我在本机配置了双实例，所以log-bin-in...
