我正在尝试为某个历史日期安排一个oozie协调员,例如 start-date = 2013-02-01T00:00Z end-date = 2013-03-15T00:00Z frequency = 1 day Oozie应该立即开始/落实这几天的所有行动 2013-02-01T00:00Z 2013-02-02T00:00Z 2013-02-03T00:00Z 2013-02-04T00:00Z ... ... 2013-03-15T00:00Z 但是,除了这些以外,Oozie每天都会生成/执行一项操作,因此我必…

2020年10月23日 0条评论 58点热度 阅读全文

我有一个运行关键任务的应用程序。我正在尝试将Oozie配置为使用Java操作运行此作业。我的 Action 如下 <workflow-app name="Wworkflow" xmlns="uri:oozie:workflow:0.4"> <start to="TestWw"/> <action name="TestWw"> <java> <job-tracker>${jobTracker}</job-tracker> <name-nod…

2020年8月18日 0条评论 72点热度 阅读全文

我有一个oozie协调员和工作流程工作,当我的工作流程 Action 之一完成时,我需要一段时间后再说50分钟,然后开始下一个 Action 。我可以从oozie工作流或oozie协调器配置它,以等待一段时间来执行下一个 Action (取决于上一个 Action 和上一个启动的一些异步任务)。 协调器XML <coordinator-app name="ods-ds-cms-coordinator" start="${startTime}" end="${endTime}" frequency="${coo…

2020年6月1日 0条评论 61点热度 阅读全文

我按照以下步骤在Linux机器上安装了 oozie 4.1.0 http://gauravkohli.com/2014/08/26/apache-oozie-installation-on-hadoop-2-4-1/ hadoop version - 2.6.0 maven - 3.0.4 pig - 0.12.0 群集设置- MASTER NODE runnig -名称节点,Resourcemanager,代理服务器。 从节点运行 -Datanode,Nodemanager。 当我运行单个工作流程作业时,它会成功…

2019年9月7日 0条评论 80点热度 阅读全文

错误记录 [INFO] BUILD FAILURE [INFO] ------------------------------------------------------------------------ [INFO] Total time: 14:13.610s [INFO] Finished at: Mon Aug 03 04:57:58 IST 2015 [INFO] Final Memory: 115M/243M [INFO] -------------------------------------…

2019年9月5日 0条评论 43点热度 阅读全文

所以我一直在玩Oozie Java api,一切都很好,很花俏,直到遇到以下问题为止。尝试运行以下Java代码时: OozieClient oc = new OozieClient(OOZIE_URL); Properties conf = oc.createConfiguration(); conf.setProperty(OozieClient.APP_PATH, PATH_TO_WF); String jobId = oc.run(conf); while(oc.getJobInfo(jobId).getSt…

2019年8月19日 0条评论 49点热度 阅读全文

我正在使用工作流程:0.5“运行我的MR作业。我的用例是为输出创建基于密钥的目录结构。这是我的配置文件: ` <configuration> <!-- These are important. --> <property> <name>mapred.mapper.new-api</name> <value>true</value> </property> <property> <name>mapr…

2019年7月30日 0条评论 40点热度 阅读全文

我是一个初学者,尝试使用Java学习map-reduce。我正在尝试使用oozie协调器运行单词计数示例。我遇到了投放错误。如果有人帮助我解决这个错误,那将是非常不错的。 "Error: java.lang.ClassCastException: wordCountTest.WordCountTest cannot be cast to org.apache.hadoop.mapreduce.Mapper" 这是我的WordCountTest.java代码段: package wordCountTest; impo…

2019年7月2日 0条评论 42点热度 阅读全文

我已经设置了一个Oozie java Action 工作流,我打算使用一个Oozie协调器来计划。 Java操作运行一个Camus Job,我将其jar和属性配置文件放在了工作流/ lib目录中。关于如何将-P参数传递给它的任何想法?目前,我正在执行以下操作: <workflow-app xmlns="uri:oozie:workflow:0.5" name="camus-wf"> <start to="camusJob"/> <action name="camusJob"> &…

2019年5月3日 0条评论 57点热度 阅读全文

我有一个使用kerberos身份验证进行身份验证的应用程序。应用程序运行良好。但是我想知道_HOST值,当我触发oozie工作流程时。有什么可能的方式可以从JAVA程序或工作流.xml中的oozie操作中找到_HOST的值 <property> <name>hive.metastore.kerberos.principal</name> <value>hive/_HOST@EXAMPLE.COM</value> <description>The…

2019年1月20日 0条评论 132点热度 阅读全文