Pregunta

He definido un trabajo coordinador de Oozie de la siguiente manera:

<coordinator-app name="edu-apollogrp-DFE" frequency="${coord:minutes(15)}" start="${start}" end="${end}" timezone="${timezone}" xmlns="uri:oozie:coordinator:0.1">
    <controls>
            <concurrency>1</concurrency>
    </controls>
    <action>
            <workflow>
                    <app-path>${nameNode}/user/${user}/oozie/apps/DFE/queryGenerator-wf</app-path>
                    <configuration>
                            <property>
                                    <name>nameNode</name>
                                    <value>${nameNode}</value>
                            </property>
                            <property>
                                    <name>jobTracker</name>
                                    <value>${jobTracker}</value>
                            </property>

                    </configuration>
            </workflow>
    </action>
</coordinator-app>

Como puede ver, he definido la frecuencia como 15 minutos y la concurrencia como 1.

Sin embargo, el trabajo se ejecuta cada 5 minutos y lanza 4 instancias de mi flujo de trabajo al mismo tiempo, como se ve en la siguiente captura de pantalla:

Oozie screenshot

No entiendo por qué está sucediendo esto, ¡realmente agradecería algunas ideas!

¿Fue útil?

Solución

En este caso, imagino que su hora de inicio fue en el pasado: si mira la columna de instancia materializada, verá que tienen un intervalo de 15 minutos entre entonces. Lo que Oozie está haciendo en el caso de que la hora de inicio sea en el pasado es que efectivamente "reduzca" todas las tareas hasta la hora actual, generando cada instancia materializada con 5 minutos de diferencia.

Licenciado bajo: CC-BY-SA con atribución
No afiliado a StackOverflow
scroll top