介绍flink在本地运行和on yarn运行时的日志配置。 很多现代框架都是用门面模式进行日志输出，例如使用Slf4j中的接口输出日志，具体实现...

最近做了一个log抽取的项目，采用log4j+flume实现，在此分享记录一下。 准备 什么是flume？ flume是一个提供高可用的，高可靠...

spark on yarn运行时会加载的jar包有如下： spark-submit中指定的--jars $SPARK_HOME/jars下的ja...

谈谈MapReduce的概念、Hadoop MapReduce和Spark基于MR的实现 什么是MapReduce？ MapReduce是一种分...

Spark Streaming源码流程解析。 写在前面 以下是我自己梳理了一遍Spark Streaming程序运行的流程，过程可能有点细、有点...