oozie

    0熱度

    2回答

    我想創建一個應該可用於Oozie工作流程中所有操作的變量。我試圖創建它,如下所示。但是EL表達式並沒有得到評估,導致EL表達式本身的可變current_ts值。有人可以請點亮這個嗎? <workflow-app xmlns="uri:oozie:workflow:0.4" name="no-op-wf"> <parameters> <property> <name>

    0熱度

    2回答

    我想要做的就是將工作流和作業元數據(如開始日期,結束日期和狀態)提供給配置單元表,供BI工具用於可視化目的。我希望能夠監測例如某個工作流程在某些時間段內是否失敗,成功率... 爲此,我需要訪問相同的數據Hue能夠在作業瀏覽器和Oozie中顯示儀表板。例如,我正在尋找專門針對工作流程的名稱,提交者,狀態,開始和結束時間。我想這樣做的原因是,在我看來,這個工具缺乏一般概述和良好的搜索。 這個想法是,一

    0熱度

    1回答

    我試圖通過shell腳本觸發Oozie作業。但在shell腳本的執行我得到下面的錯誤: "command not found" error in the line: ooziejob =$(oozie job -oozie http://oozieserver:port/oozie -config /root/SqoopWrapper1/sqoop_job.properties -run); 我由

    1熱度

    1回答

    我正在使用Oozie 4.1.0。我部署了一個自定義操作,它擴展了Java操作。現在我需要部署另一個版本除此之外。 XSD將是相同的,但操作代碼有變化。 我會把更新後的動作放到一個自定義的包中,並且會對動作XSD進行版本化。我猜這個類型名稱也應該在自定義操作的構造函數中進行更改,因爲這需要是唯一的,就我所判斷的代碼而言。 但是那麼我怎樣才能引用我的工作流XML中使用新版本的相同操作名稱? 什麼是處

    0熱度

    1回答

    oozie是否在工作流程開始時執行所有準備步驟(如刪除)? 即使給定動作從未「調用」,它是否運行所有準備步驟? 我體驗到它刪除了一些我的數據文件夾,但我從來沒有在準備步驟被指定時調用動作。而且它似乎在第一個被調用的動作(它沒有準備步驟)之後被刪除。

    0熱度

    1回答

    我有一個jar文件,它有sqoop作業來讀寫數據到mysql中。 我想用oozie工作流程運行jar,下面是運行jar的命令。 yarn jar aa-datalake.jar root root Orders avro aa-dl-rawzone 對於這種行爲,我需要使用?

    1熱度

    1回答

    做完家庭作業到處搜尋,但沒有找到任何解決方案 java.lang.NoSuchFieldError: IS_SECURITY_ENABLED 的CDH包裹包含衝突罐(JSP-API -2.1-6.1.14.jar,jasper-runtime-5.5.23.jar)。 jsp-api-2.1-6.1.14.jar和jasper-runtime-5.5.23.jar包含不同版本的org.apache

    0熱度

    1回答

    我正在使用Hue/Oozie創建工作流程。我遇到的問題是多次,現在我有一個工作流程,然後由工作已經導致了引發錯誤編輯: OozieClientException: org.apache.oozie.DagEngineException: E0701: XML schema error, cvc-complex-type.2.4.a: Invalid content was found starti

    0熱度

    1回答

    我正在查找命令,以使用通配符獲取給定名稱的所有workflowIds列表。 我使用下面的命令來獲取詳細信息,當我知道從workflow.xml完整的工作流名稱 oozie jobs -oozie http://hadoopoozie.global.tesco.org:11000/oozie -filter name="workflow name" 在這裏,我應該如何使用過濾器命令時,我只知道

    1熱度

    1回答

    我正在嘗試使用Cloudera oozie進行簡單的ssh作業。 job.properties: nameNode=hdfs://localhost:8020 jobTracker=localhost:8032 queueName=default examplesRoot=examples oozie.wf.application.path=${nameNode}/user/${user