Programação e Coordenação Oozie Workflows em Hadoop

Depois de criar um conjunto de fluxos de trabalho, você pode usar uma série de empregos coordenador Oozie para agendar quando são executados. Você tem duas opções de agendamento para execução: um tempo específico e da disponibilidade de dados em conjunto com um certo tempo.

programação baseada no tempo para empregos coordenador Oozie

empregos coordenador Oozie pode ser programado para executar em um determinado momento, mas depois que eles são iniciados, eles podem ser configurados para serem executados em intervalos especificados. O exemplo a seguir mostra um trabalho do coordenador que começa a funcionar em um horário de início e data especificadas:

...$ {} WorkflowAppPath

agendamento com base em disponibilidade de tempo e de dados para trabalhos coordenador Oozie

empregos coordenador Oozie também pode ser programado para executar em um determinado momento se os arquivos de dados especificados ou diretórios estão disponíveis. A listagem a seguir mostra um exemplo de um coordenador que começa a funcionar em um horário de início e data especificadas, é executado uma vez por dia, se o conjunto de dados identificada por triggerDatasetDir existe, e vai até o fim do tempo especificado:

...$ {} TriggerDatasetDir$ {} StartTime$ {} WorkflowAppPath

Executar trabalhos coordenador Oozie

Semelhante a trabalhos de fluxo de trabalho Oozie, empregos coordenador requer um arquivo job.properties, eo arquivo coordinator.xml precisa ser carregado no HDFS. Para executar uma tarefa de coordenador Oozie a partir da interface de linha de comando Oozie, emitir um comando como o seguinte, assegurando que o arquivo job.properties é localmente acessíveis:

$ Job Oozie -config sampleCoordinator / job.properties -run

Depois de submeter o trabalho, o coordenador é armazenado no banco de dados objeto Oozie. Aquando da apresentação, Oozie retorna um identificador para que você possa monitorar e administrar o seu coordenador - trabalho: 0.000.001-00000001234567-Oozie-C.

Para verificar o status deste trabalho, executar o comando

trabalho Oozie -info 0.000.001-00000001234567-Oozie-C