我正在尝试访问通过oozie java Action 配置设置的属性,但是我没有获得我一直在寻找的值,想知道我是否可以对此获得任何帮助? 我的工作流程 ........... <action name="ref-record-load"> <java> <configuration> <property> <name>oozie.launcher.mapred.child.java.opts</name> <value>-Xmx4g…

2020年11月28日 0条评论 77点热度 阅读全文

我是Java新手,使用Java代码运行oozie作业时遇到了一些麻烦。我无法在代码中找出问题。一些帮助将不胜感激。这是我的代码 import java.util.Properties; import org.apache.oozie.client.OozieClient; import org.apache.oozie.client.WorkflowJob; public class oozie { public static void main(String[] args) { OozieClient wc = …

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

我一直在遇到异常,因为Oozie向类路径添加了错误版本的httpcore jar。我尝试了其他选择,例如 oozie.launcher.mapreduce.task.classpath.user.precedence oozie.launcher.mapreduce.user.classpath.first oozie.launcher.mapreduce.task.classpath.user.precedence完全不响应,当我使用oozie.launcher.mapreduce.user.classpath.…

2020年11月14日 0条评论 51点热度 阅读全文

我编写了一个mapreduce类,在执行该mapreduce代码时正在使用一个计数器,但出现此错误 java.lang.IncompatibleClassChangeError: Found interface org.apache.hadoop.mapreduce.Counter, but class was expected at MyProg.run(Unknown Source) at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70) at …

2020年11月12日 0条评论 100点热度 阅读全文

我的hadoop版本是2.7.1,我的oozie版本是3.3.2。我已经成功创建了oozie.war文件。但是,当我尝试使用以下命令在hdfs中创建共享库时, oozie-setup.sh sharelib create -fs hdfs://training-21:54310 我得到以下异常, Stack trace for the error was (for debug purposes): -------------------------------------- org.apache.oozie.ser…

2020年11月12日 0条评论 48点热度 阅读全文

我正在尝试使用javacode启动oozie作业,但无法执行相同操作。以下代码为几行代码提供了异常“unhandled type oozieClientException” String jobId = wc.run(conf); 我是Java新手,正在寻求帮助。这是我的代码: OozieClient wc = new OozieClient("http://host.com:11000/oozie"); Properties conf = wc.createConfiguration(); conf.setPro…

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

我希望o调用我的ExampleDecision.java,而不是在oozie工作流xml中设置作业驱动程序配置(例如Inputformat映射器类等)。 ExampleDecision主要方法将负责作业设置和配置。怎么做 ? OOZIE_COOK_BOOK中的 II Java-Main Action决策节点是否为插图等于java ExampleDecision <strings...>并将作业作为普通的Java作业提交 要么 它等于Hadoop jar SomeJar.ExampleDecision &…

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

我正在通过oozie java action运行一个测试hbase java程序。遇到以下错误: Failing Oozie Launcher, Main class [HbaseTest], main() threw exception, org/apache/hadoop/hbase/HBaseConfiguration java.lang.NoClassDefFoundError: org/apache/hadoop/hbase/HBaseConfiguration at HbaseTest.main(Hba…

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

我有两个用Oozieworkflow.xml编写的Java操作。我想将我的第一个Java Action 的输出传递给下一个Java Action 以供重用。 我知道这需要使用“oozie.action.output.properties”来完成。在第一个 Action 中,我将输出参数设置为“buildFileName”,如下所示: File file = new File(System.getProperty("oozie.action.output.properties")); LOGGER.info("Sys…

2020年11月4日 0条评论 71点热度 阅读全文

我正在尝试为某个历史日期安排一个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点热度 阅读全文