Domanda

Ho definito un lavoro di coordinatore di Oozie come segue:

<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>

Come puoi vedere, ho definito la frequenza come 15 minuti e concorrenza come 1.

Tuttavia, il lavoro funziona ogni 5 minuti e lancia 4 istanze del mio flusso di lavoro allo stesso tempo, come si vede nello screenshot seguente:

Oozie screenshot

Non capisco perché questo stia accadendo, apprezzerei davvero alcune intuizioni!

È stato utile?

Soluzione

In questo caso immagino che il tuo orario di inizio fosse in passato: se guardi la colonna di istanza materializzata vedrai che hanno un intervallo di 15 minuti tra allora. Ciò che Oozie sta facendo nel caso in cui il tempo di inizio è in passato è che effettivamente "lo schema posteriore" di tutte le attività fino al momento corrente, generando ogni istanza materializzata a 5 minuti di distanza.

Autorizzato sotto: CC-BY-SA insieme a attribuzione
Non affiliato a StackOverflow
scroll top