对于单节点设置，Flink已准备好开箱即用，您无需更改默认配置即可开始使用. 开箱即用的配置将使用您的默认Java安装.您可以手动设置环境变量JAVA_HOME或配置项env.java.home中conf/flink-con...

JobManager高可用性（HA）JobManager协调每个Flink部署。它负责调度和资源管理。 默认情况下，每个Flink群集都有一个JobManager实例。这会产生单点故障（SPOF）：如果JobManager崩溃，则无法...

独立群集此页面提供有关如何在静态（但可能是异构）集群上以完全分布式方式运行Flink的说明。 要求软件要求Flink可在所有类UNIX环境中运行，例如Linux，Mac OS X和Cygwin（适用于Windows），并期望集群由一个...

Flink可在Linux，Mac OS X和Windows上运行。为了能够运行Flink，唯一的要求是安装一个有效的**Java 8.x.** 在Linux，Mac OS X上设置：下载并启动Flink您可以通过发出以下命令来检查J...

一、组件堆栈作为软件堆栈，Flink是一个分层系统。堆栈的不同层构建在彼此之上，并提高它们接受的程序表示的抽象级别： 在运行时层中的形式接收节目JobGraph。JobGraph是一个通用的并行数据流，具有消耗和生成数据流的任意任务...

一、数据流编程模型抽象层次Flink提供不同级别的抽象来开发流/批处理应用程序。 最低级抽象只提供有状态流。它 通过Process Function(过程函数)嵌入到DataStream API(流式传输)中。它允许用户...

一、Flink介绍既然有了Apache Spark，为什么还要使用Apache Flink？ 因为Flink是一个纯流式计算引擎，而类似于Spark这种微批的引擎，只是Flink流式引擎的一个特例。 Flink是一款分布式的计算引擎，...

介绍Jira是Atlassian公司出品的一款事务管理软件。无论是“需求”，还是“BUG”，或是“任务”，都是“事务”的一种，所以Jira可以胜任非常多的角色：需求管理、缺陷跟踪、任务管理等等……因为Jira提供了专门的Scrum视图...

这里分享一些自己学习过程中觉得不错的资料和开发工具。 经典书籍 《hadoop 权威指南(第四版)》 2017年 《Kafka权威指南》 2017年 《从Paxos到Zookeeper 分布式一致性原理与实践》 2015年 《Sp...

一、简介在提交大数据作业到集群上运行时，通常需要先将项目打成JAR包。这里以Maven为例，常用打包方式如下： 不加任何插件，直接使用mvn package打包； 使用maven-assembly-plugin插件； 使用maven...