oozie

3熱度

2回答

在一個目錄中是否可以有兩個oozie workflow.xml文件？如果是的話，我該如何指導oozie亞軍哪一個運行？

1熱度

1回答

我開發了一個使用ToolRunner的MapReduce應用程序。基於用戶傳遞的參數和配置屬性，應用程序以某種方式設置作業：選擇特定的輸入/輸出格式，選擇映射器和減速器類等。此邏輯在run(String[] args)方法中由我的主該類實現Configured和Tool。 Oozie支持MapReduce動作節點，但問題是我無法將它們與我的自定義ToolRunner應用程序一起使用。 MapRed

2熱度

1回答

如何在以前的工作流程完成時觸發Oozie工作流程

我正在使用Oozie工作流程從不同的Oracle服務器導入多個表。目前，我已經爲這些表格中的每一個開發了一個工作流程，以便將它們合併到Hadoop中。這是一個基本的sqoop，然後做一些轉換和創建配置單元表。我遇到困難的地方在於，我想安排一個工作流程來運行，這很好。（我已經這樣做了），然後我希望剩下的工作流在完成前一個時執行。我一直在尋找捆綁包，但還沒有設法找到解決方案。我希望你們中的一些人

0熱度

1回答

Ozzie Inputformat MapReduce API

我正嘗試用自定義的輸入格式創建一個OOZIE作業。我使用新的API，並且已經設置： <property> <name>mapred.mapper.new-api</name> <value>true</value> </property> <property> <name>mapred.reducer.new-api</name>

1熱度

2回答

OOZIE中的多輸入路徑配置

我正嘗試在oozie中配置Mapreduce作業。該作業有兩種不同的輸入格式和兩個輸入數據文件夾。我用這篇文章How to configure oozie workflow for multi-input path with multiple mappers 並添加這些屬性來我workflow.xml： <property> <name>mapred.input.dir.form

3熱度

3回答

oozie：如何在相應的工作流中使用oozie coodinator屬性？

我有運行作爲調用worflow協調一個Oozie的工作，在協調有其採用協調EL功能，像這樣的一些配置屬性 - $ {} oozieAppDir /copyLogs.wf.xml <configuration> <property> <name>filename3</name> <value>${coord:formatTime(coord:dateOffse

2熱度

1回答

Oozie的 - 創建的未知文件名

協調程序，我想使文件列表上的協調應用程序，但我只知道他們的名字parttern： /數據/觸發/謨/ * 我想解決以下HDFS網址： /data/trigger/projet/ffff_2013-01-01 /data/trigger/projet/aaaa_2013-01-02 /data/trigger/projet/bbbb_2013-01-03 當我嘗試下面的代碼，Oozie的未檢

-1熱度

1回答

單節點hadoop集羣上的實驗練習

我已經使用cloudera的虛擬機設置了一個單節點hadoop集羣節點集羣，並且需要在實驗練習中給出以下示例，請幫助指出一些示例用例我可以使用運行在以下幾方面 1實驗練習跑步Sqoop導入和 2 Sqoop出口 3創建配置單元表直接 4從Sqoop 5創建配置單元表 6查詢配置單元表 7運行Oozie的工作流程中使用 9水槽

0熱度

2回答

Oozie的 - E0803：IO錯誤

蔭試圖在Hortonworks分佈下執行的map-reduce Oozie的例子...... 不過它的功能可是... 首先，這裏有我的自定義的Hadoop CONFIGS（從Ambari）。我不得不修改核心XML改正我的「模擬」的問題...... hadoop.proxyuser.oozie.groups=* hadoop.proxyuser.oozie.hosts=* 工作得很好，但現在我

2熱度

1回答

Cloudera - Oozie無法從workflow.xml中獲取屬性

我正在嘗試實踐oozie工作流。我的做法是從ftp獲取文件並將其上傳到cloudera - HDFS。以下是我的Java代碼： public class UploadHDFS extends Configured implements Tool { private static final Logger LOGGER = LoggerFactory.getLogger(UploadHD