oozie

1熱度

1回答

我正在構建一個應用程序以將數據從MYSQL數據庫提取到配置單元表。應用程序將計劃每天執行。第一個操作是讀取Hive表來加載導入表信息，例如名稱，類型等，並在要導入的文件中創建表的列表。接下來是一個Sqoop操作，以按順序爲每個表傳輸數據。是否有可能創建一個shell腳本Oozie動作，它將遍歷表列表並按順序爲每個表啓動oozie子工作流Sqoop動作？你能提供一些參考嗎？還有更好的方法的任何建

0熱度

1回答

如何每天同時安排Oozie協調員？

我想建立一個簡單的Oozie協調器，無限期地每天中午運行。這是設置它的正確方法嗎？ <coordinator-app name="${jobName}" frequency="${coord:days(1)}" start="2000-01-01T12:00Z" end="3000-01-01T12:00Z" timezone="UTC" xmlns="uri:oozie:coordinator:

1熱度

1回答

使用HAProxy負載平衡器的Oozie HA配置

我試圖使用Cloudera Manager 5來啓用Oozie HA。該過程非常簡單。我所要做的就是爲配置的負載均衡器提供一個主機名：端口，Cloudera Manager將創建一個額外的Oozie服務器。我在主機XXX.XXX.XXX.246上已經有一個Oozie服務器，而我的其他Oozie服務器應該在主機XXX.XXX.XXX.247上。應該在主機XXX.XXX.XXX.248上配置HAPr

2熱度

1回答

oozie shell的動作與火花提交

我想從殼包裝運行火花提交。而作業從命令行運行良好，但通過oozie進行調度時失敗。 Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/hadoop/fs/FSDataInputStream at org.apache.spark.deploy.SparkSubmitArguments.handle(Spar

0熱度

1回答

Oozie的電子郵件行動逃生標籤

我們有以下Oozie的電子郵件操作 <email xmlns="uri:oozie:email-action:0.1"> <to>some-email</to> <subject>some subject Failure</subject> <body> Error (Code) Message:(${wf:errorCode(wf:lastErrorNo

0熱度

1回答

自動控制運行類似Oozie作業的數量

我已經設置了Oozie工作流程頻率每1分鐘。如果以前的工作流程尚未完成，是否有配置設置或停止產生類似Oozie工作流程的方法？謝謝

2熱度

1回答

從失敗節點重新運行的Oozie協調器動作

我正在嘗試使用下面的命令重新運行oozie協調器動作。 oozie job -rerun <co-ordinator id> -action <action id> -Doozie.wf.rerun.fail.nodes=true 但它正在執行，而不是從一開始從故障節點的點執行它的作用。協調員忽略'oozie.wf.rerun.fail.nodes = true'選項。我想提供一些選擇嗎？

5熱度

1回答

爲Oozie的工作流

（根據Why does the oozie luncher consume 2 yarn containers?）我有1900芯和11TB RAM羣集運行單個應用程序主。我有工作流的下一個結構，用於我的Oozie的WF：約300-400mg subworkflows與將（由叉控制節點）並行運行相同的結構在這些子流一個接一個運行幾個任務（java的行動，火花任務，外殼動作）一些支流可

0熱度

1回答

E0701：XML模式錯誤，CVC圖案有效Oozie的錯誤

我試圖運行Oozie的工作流程，但我得到了以下錯誤： E0701: XML schema error, cvc-pattern-valid: Value 'mockup and mapping table update' is not facet-valid with respect to pattern '([a-zA-Z_]([\-_a-zA-Z0-9])*){1,39}' for type

0熱度

1回答

爲什麼oozie hive2操作失敗？

我們正在將現有的（生產CDH 5.8集羣）oozie + hive2作業遷移到新的CDH 5.8集羣。不幸的是，遷移後，hive2操作失敗，出現以下錯誤。 Error: Could not open client transport with JDBC Uri: jdbc:hive2://xxxxx.yyy.net:10000/default: Peer indicated failure: DI