Schemaläggning och koordinering av Oozie-arbetsflöden i Hadoop-dummies

När du har skapat en uppsättning arbetsflöden kan du använda en serie Oozie-koordinatorjobb att schemalägga när de är avrättades. Du har två schemaläggningsalternativ för körning: en viss tid och tillgången till data i samband med en viss tid.

Tidsbaserad schemaläggning för Oozie-koordinatorjobb

Oozie-koordinatorjobb kan schemaläggas att köras vid en viss tid, men efter att de har startat kan de sedan konfigureras att köras med angivna intervaller. Följande exempel visar ett koordinatjobb som börjar köra vid en angiven starttid och ett datum:

… $ {workflowAppPath}

Tid och data tillgänglighetsbaserad schemaläggning för Oozie-koordinatorjobb

Oozie-koordinatorjobb kan också schemaläggas att utföras vid en viss tidpunkt om specificerade datafiler eller kataloger finns tillgängliga. Följande lista visar ett exempel på en koordinator som börjar köra vid en angiven starttid och datum, exekveras en gång om dagen om datasatsen identifierad av triggerDatasetDir existerar, och går fram till den angivna sluttiden:

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

Löpande Oozie-koordinatorjobb

På samma sätt som Oozie-arbetsflödesjobb kräver koordinatjobb ett jobb. egenskaper fil och samordnaren. xml-filen måste laddas i HDFS. För att köra ett Oozie-koordinatjobb från Oozie-kommandoradsgränssnittet, utfärda ett kommando som följande samtidigt som du säkerställer jobbet. Egenskapsfilen är lokalt tillgänglig:

$ oozie jobbkonfig samordnare / jobb. Properties -run

När du skickat in jobbet sparas koordinatorn i Oozie-objektdatabasen. Vid inlämning returnerar Oozie en identifierare så att du kan övervaka och administrera din samordnare - jobb: 0000001-00000001234567-oozie-C.

För att kontrollera statusen för det här jobbet, kör kommandot

oozie job-info 0000001-00000001234567-oozie-C