首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

NIFI启动源码解读

本文仅限于针对NIFI最常见的启动方式的分析,即使用以下命令启动nifi.sh start 本文是若干脚本解读和源码学习分析的导读和概括,每一步骤的详细研究需要到各个章节仔细研究。...nifi.sh脚本 我们启动NIFI是使用的nifi.sh脚本,那么一切自然就是从这里开始的。整个脚本分为三部分,第一部分是确定NIFI各个路径 目录的确定,设置环境变量,第二部分是方法区。...,接受脚本指令,启动停止NIFI进程(主类 org.apache.nifi.NiFi),自动重启NIFI,发送NIFI通知等等操作;关于RunNifi.java的详细研究请看:RunNiFi.java...NiFi.java 在RunNiFi.java源码解读中有提到,最终RunNiFi进程在主程序中启动了新的进程NiFi,并循环监听NIFI进程的状态,直到NIFI进程不在运行,RunNiFi主程序才结束...在JettyServer中发布了war包,启动了我们所看到的NIFI(画布、拖拽。。。)关于Nifi.java的详细研究请看:JettyServer.java

77110
您找到你想要的搜索结果了吗?
是的
没有找到

Hadoop启动异常的处理--DataNode启动

异常现象描述: hadoop格式化后,我们需要启动hdfs。然而,有些时候启动hdfs并不是那么顺利,往往会出现DataNode启动的现象。...启动hdfs后,执行jps命令查看,结果如下: hdfs启动异常.png 很显然,DataNode没有出现。作为存储数据的节点进程没有运行,肯定是有问题的。.../start-dfs.sh后,仍然是上面的结果, DataNode 没有启动。 尝试过的第二种方法: 执行..../stop-dfs.sh后,关闭hdfs,重新启动,结果跟上面一样,仍然是DataNode 没有启动。 再三折腾,删除掉存放数据的临时文件tmp,重新格式化Hadoop,格式化成功。.../start-dfs.sh 结果如下: 222.png NameNode和DataNode都已经正常启动了。 小结: 搭建环境是一件很费力但不一定有结果的事情,出现异常也在所难免。

3.2K30

大数据NiFi(十三):NiFi监控

NiFi监控在组件工具栏下的NiFi屏幕顶部附近有一个条形,称为状态栏。...它包含一些关于NiFi当前健康状况的重要统计数据:活动线程的数量可以指示NiFi当前的工作状态,排队统计数据表示当前在整个流程中排队的FlowFile数量以及这些FlowFiles的总大小。...需要解除禁用才能正常启动、停止处理器。可以通过“公告指示”来查看事件处理日志信息,默认级别是“WARN”级别,可以在处理器配置中设置,当有对应级别的事件信息产生时,才会显示。...二、对于每个组的监控情况如下“组件信息统计”中图表含义如下:配置的远程NiFi实例传输个数。禁用的远程NiFi实例传输个数。 组内正在运行的处理器个数。组内已经停止的处理器个数。组内无效处理器数量。

1.3K11

大数据NiFi(十七):NiFi术语

NiFi术语 一、DataFlow Manager DataFlow Manager(DFM)是NiFi用户,具有添加,删除和修改NiFi数据流组件的权限。...六、Controller Service 控制器服务是扩展点,在用户界面中由DFM添加和配置后,将在NiFi启动启动,并提供给其他组件(如处理器或其他控制器服务)需要的信息。...十一、Remote Process Group 远程组可以实现将数据从一个NiFi实例传输到另一个NIFI实例。...虽然NiFi提供了许多不同的机制来将数据从一个系统传输到另一个系统,但是如果将数据传输到另一个NiFi实例,远程进程组实现是最简单方法。...此外,NiFi在更新时会自动备份此文件,您可以使用这些备份来回滚配置,如果想要回滚,先停止NiFi,将flow.xml.gz替换为所需的备份,然后重新启动NiFi

1.6K11

大数据NiFi(十五):NiFi入门案例二

NiFi入门案例二需求:随机生成一些测试数据集,对生成的数据进行正则匹配,对匹配后的数据进行输出到外部文件中。...在弹框中输入“GenerateFlowFile” 2、配置“ReplaceText”处理器将接收“GenerateFlowFile”处理器生成的“hello world”数据,替换其中的“world”为“nifi...处理器的创建及配置参数参照案例一,这里直接给出“PutFile”处理器的配置,将替换后的FlowFile写入外部路径中“/root/test/matchFile”:​四、​​​​​​​​​​​​​​连接各个处理器,并且启动测试在连接...需要设置连接的配置关系,当“ReplaceText”处理器将匹配成功的数据写出到“PutFile”处理器:​设置当“ReplaceText”处理器匹配失败FlowFile自动终止关系: 完整的连接关系如下:启动...“GenerateFlowFile”处理器后:同时查看“Data Provenance”中数据如下: 启动“ReplaceText”处理器,查看处理的数据:启动“PutFile”处理器,NiFi集群对应的每个节点上都生成对应的数据

1.4K121

大数据NiFi(一):什么是NiFi

Apache NiFi 是为数据流设计,它支持高度可配置的指示图,来指示数据路由、转换和系统中流转关系,支持从多种数据源动态拉取数据。简单地说,NiFi是为自动化系统之间的数据流而生。...未来NiFi有可能替换Flume、Sqoop等大数据导数据的工具。NiFi官网地址:Apache NiFi一、NiFi背景介绍2006年NiFi由美国国家安全局(NSA)的Joe Witt创建。...NiFi初始的项目名称是Niagarafiles,当NiFi项目开源之后,一些早先在NSA的开发者们创立了初创公司Onyara,Onyara随之继续NiFi项目的开发并提供相关的支持。...NiFi旨在帮助解决这些现代数据流挑战。...三、​​​​​​​​​​​​​​NiFi特点Apache NiFi 是一个易于使用、功能强大而且可靠的数据拉取、数据处理和分发系统,用于自动化管理系统间的数据流。

2.2K81

大数据NiFi(三):NiFi关键特性

NiFi关键特性一、​​​​​​​​​​​​​​流管理保证交付:NIFI的核心理念是,即使在非常大的规模下,也必须保证交付。...基于背压的数据缓冲和背压释放NiFi支持所有排队数据的缓冲以及当这些队列达到指定限制时提供背压的能力,或者指定过期时间,当数据达到指定期限时丢弃数据的能力队列优先级NiFi允许设置一个或多个优先级方案,...用户访问系统安全NiFi允许双向SSL认证可以控制用户的登录权限(例如:只读权限、数据流管理者、系统管理员)。...这意味着每个NiFi集群都能够处理一个或多个组织的要求。...扩展和缩小NiFi还可以非常灵活地扩展和缩小。从NiFi框架的角度来看,如果要增加吞吐,可以在配置时增加"Scheduling"选项卡下processor的并发任务数。

1.3K61

Apache NIFI 架构

NiFi在主机操作系统上的JVM中执行。JVM上NiFi的主要组件如下: Web Server web服务器的目的是托管NiFi基于HTTP的命令和控制API。...Extensions 其他文档中描述了各种类型的NiFi扩展。这里的关键是扩展在JVM中操作和执行。...FlowFile Repository 流文件存储库是NiFi跟踪它所知道的关于当前在流中活动的给定流文件的状态的地方。存储库的实现是可插入的。默认方法是位于指定磁盘分区上的持久预写日志。...NiFi也可以在集群内运行。 从nifi1.0版本开始,采用了零前导聚类范式。NiFi集群中的每个节点对数据执行相同的任务,但每个节点对不同的数据集进行操作。...作为数据流管理器,您可以通过任何节点的用户界面(UI)与NiFi集群交互。您所做的任何更改都会复制到集群中的所有节点,从而允许多个入口点。

1.1K20

带你体验Apache NIFI新建数据同步流程(NIFI入门)

在解压的目录下,找到conf目录,编辑bootstrap.conf文件,修改NIFI的内存配置,默认的值比较小,比如这里我改成启动2g,最大10g java.arg.2=-Xms2g java.arg.3...=-Xmx10g 在解压的目录下,找到bin目录,可以看到里面有一些脚本 dump-nifi.bat nifi-env.bat nifi-env.sh nifi.sh run-nifi.bat...status-nifi.bat Linux或者Mac,使用nifi.sh start启动NIFInifi.sh stop停止NIFInifi.sh restart重启NIFI。...在解压的目录下,找到log目录,当看到类似于下面的内容时,NIFI启动成功了 2020-05-27 14:26:02,844 INFO [main] o.eclipse.jetty.server.AbstractConnector...Concurrent Tasks是说一次调度,这个组件最多可以同时启动多少个任务来处理数据。Execution是针对集群的,你可以先不用理解,它是设置组件只在主节点运行还是在所有节点运行。

3.2K31

大数据NiFi(六):NiFi Processors(处理器)

NiFi Processors(处理器)为了创建高效的数据流处理流程,需要了解可用的处理器(Processors )类型,NiFi提供了大约近300个现成的处理器。...每个新的NiFi版本都会有新的处理器,下面将按照功能对处理器分类,介绍一些常用的处理器。...具体可参照官网查看更多的处理器信息:http://nifi.apache.org/docs/nifi-docs/html/getting-started.html#what-processors-are-available...一、数据提取GetFile:将文件内容从本地磁盘(或网络连接的磁盘)流式传输到NiFi,然后删除原始文件。...每当新文件进入HDFS时,它将被复制到NiFi并从HDFS中删除。此处理器应将文件从一个位置移动到另一个位置,而不是用于复制数据。如果在集群中运行,此处理器需仅在主节点上运行。

1.9K122

大数据NiFi(七):NiFi集群页面管理节点操作

NiFi集群页面管理节点操作用户可以手动断开节点与集群的连接,节点也可能由于其他原因而断开连接,例如由于缺乏心跳。...二、卸载节点在断开节点上存储的数据可以通过“卸载”操作将数据重新均衡到集群其他节点上,节点卸载之后,页面上显示“Offloading”状态:可以在状态为“Offloading”的节点上重新启动NiFi服务或者点击...三、删除节点点击“Delete”删除当前集群的节点,该节点在页面中不再显示,并且重新启动删除节点上的NiFi服务后,当前节点会重新加入集群。...四、彻底删除节点当“删除节点”后,页面中不再显示当前节点信息,在当前节点重启NiFi服务后,该节点重新加入NiFi集群中,那么如何彻底在NiFi集群中删除一个节点呢?需要经过以下步骤:断开节点。...删除请求完成后,停止/删除主机上的NiFi服务,彻底删除当前节点NiFi。​

1.3K141
领券