Aikataulutus ja koordinointi Oozie-työnkulut Hadoop-dummyissä

Kun olet luonut joukon työnkulkuja, voit käyttää sarjaa Oozie-koordinaattorin töitä aikataulun mukaan, kun he ovat teloitettiin. Sinulla on kaksi ajoitusvaihtoehtoa suoritukseen: tietty aika ja tietojen saatavuus tiettynä ajankohtana.

Oozie-koordinaattorin töiden aikapohjainen aikataulu

Oozie-koordinaattorin tehtävät voidaan aikatauluttaa suoritettavaksi tietyn ajan, mutta sen jälkeen, kun ne on käynnistetty, ne voidaan konfiguroida toimimaan määrätyin väliajoin. Seuraavassa esimerkissä näytetään koordinaattorityö, joka alkaa toimia tietyssä aloitusajassa ja päivämääränä:

… $ {workflowAppPath}

Oozie-koordinaattorin tehtävien aikatietojen ja tietojen saatavuusperusteinen aikataulutus

Oozie-koordinaattorin tehtävät voidaan myös ajoittaa suoritettavaksi tiettyyn aikaan, jos tietyt tiedostot tai hakemistot Ovat saatavilla. Seuraavassa luettelossa näkyy esimerkki koordinaattorista, joka käynnistyy tietyssä aloitusajassa ja päivämääränä, suoritetaan kerran päivässä, jos triggerDatasetDir: n tunnistama tietojoukko on olemassa ja toimii kunnes määritetty päättymisaika:

Oozie-koordinaattorin töiden suorittaminen

Oozie-työnkulkutietojen tavoin koordinaattorin tehtävät vaativat työtä. ominaisuustiedosto ja koordinaattori. xml-tiedosto on ladattava HDFS: ään. Jotta voit suorittaa Oozie-koordinaattorin työn Oozie-komentoriviliitännästä, anna seuraava komento samalla kun varmistat työn. ominaisuustiedosto on paikallisesti saatavilla:

$ oozie job -config sampleCoordinator / job. properties -run

Kun olet lähettänyt työn, koordinaattori tallennetaan Oozie-objekti-tietokantaan. Lähetyksen jälkeen Oozie palauttaa tunnuksen, jonka avulla voit seurata ja hallinnoida koordinaattorisi työpaikkaa: 0000001-00000001234567-oozie-C.

Tämän työn tilan tarkistamiseksi suorita komento

oozie job -info 0000001-00000001234567-oozie-C