Planlegging og koordinering av Oozie-arbeidsflyter i Hadoop-dummies

Når du har opprettet et sett arbeidsflyter, kan du bruke en rekke Oozie koordinator jobber til å planlegge når de er henrettet. Du har to planleggingsalternativer for utførelse: en bestemt tid og tilgjengeligheten av data i forbindelse med en bestemt tid.

Tidsbasert planlegging for Oozie-koordinator jobber

Oozie koordinator jobber kan planlegges å utføres på et bestemt tidspunkt, men etter at de er startet, kan de deretter konfigureres til å kjøre med bestemte intervaller. Følgende eksempel viser en koordinatorjobb som starter med en bestemt starttid og dato:

… $ {workflowAppPath}

Tid og data tilgjengelighet-basert planlegging for Oozie koordinator jobber

Oozie koordinator jobber kan også planlegges å utføres på et bestemt tidspunkt hvis spesifiserte datafiler eller kataloger er tilgjengelig. Følgende liste viser et eksempel på en koordinator som starter med en bestemt starttid og dato, utføres en gang om dagen hvis datasettet identifisert av triggerDatasetDir eksisterer, og går til den angitte sluttiden:

… $ {triggerDatasetDir} $ {startTime} $ {workflowAppPath}

Kjører Oozie koordinator jobber

I likhet med Oozie arbeidsflyt jobber koordinator jobber en jobb. eiendomsfil og koordinator. xml-filen må lastes inn i HDFS. For å kjøre en Oozie-koordinator jobb fra Oozie-kommandolinjegrensesnittet, utsted en kommando som følgende mens du sikrer jobben. Egenskapsfilen er lokalt tilgjengelig:

$ oozie jobb-konfigert samordner / jobb. Egenskaper -kjøring

Når du har sendt inn jobben, lagres koordinatoren i Oozie-objektdatabasen. Ved innsending returnerer Oozie en identifikator som gjør at du kan overvåke og administrere koordinator - jobb: 0000001-00000001234567-oozie-C.

For å sjekke statusen for denne jobben, kjør kommandoen

oozie job-info 0000001-00000001234567-oozie-C