如何在特定条件下触发oozie作业?

qij5mzcb  于 2021-06-03  发布在  Hadoop
关注(0)|答案(2)|浏览(325)

我有一个文件夹,在那里我的所有应用程序日志文件得到存储。如果在文件夹中创建了新的日志文件,我的oozie应该立即触发一个flume作业,它将把我的日志文件放入hdfs。
在文件夹中创建新日志文件时如何触发oozie作业?在这个主题上的任何帮助都是非常感谢的!!!

s71maibg

s71maibg1#

我认为更多的是如何将文件放入hdfs中。您可以始终拥有一个参数化的oozie作业,可以使用ooziejavaapi调用该作业,并将在hdfs上创建的文件的名称从客户端传入hdfs本身,除非是流式处理。
每次启动oozie工作流时,它都在一个单独的线程上运行,这将允许您使用不同的参数调用多个oozie示例。

kmb7vmvb

kmb7vmvb2#

oozie不是这样工作的。oozie是一个调度器,有点像cron。首先,指定工作流应运行的频率,然后可以添加文件可用性要求作为附加要求。

相关问题