Discussion :

[DevNico]

Bonjour,

J'ai des soucis avec les valeurs que prennent la donnée process_id pour les jobs que je lance via un job maître.

En gros, il s'agit de traitements d'intégration temps réel, lancés en boucle via un job maître.
Je traite en tout 32 bases, donc 32 traitements, qui sont lancés sur 10 threads.

J'utilise l'option "Store temp data on disk" sur certains lookups dans mes tMaps.
Lors de l'exécution, des fichiers temporaires sont donc créés de la forme : {NomJob}_tMapData_{Process_id}_{NomLookup}_KeysData_0.bin

Et il semblerait que de temps en temps, 2 des jobs lancés en même temps récupèrent le même process_id.
Du coup, du coup le premier qui se termine vire les fichiers temporaires, et le deuxième plante.


Est-ce que quelqu'un aurait déjà été confronté à ce genre de problème ?
Je n'ai rien trouvé sur le BugTracker ou le forum Talend

Merci,
Nicolas

[atb]

Salut, Il me semble que cela n’est pas faisable. En fouinant un peu dans le code Talend. Pour une jointure entre deux composants toracleinput dans un tmap, on a ça :

org.talend.designer.components.lookup.persistent.PersistentRowSorterIterator<SortableRow_row1> fsi_row1 = new org.talend.designer.components.lookup.persistent.PersistentRowSorterIterator<SortableRow_row1>("C:/CB" + "/" + jobName + "_tMapData_" + pid + "_row1",
2000000) {
public SortableRow_row1 createRowInstance() {
return new SortableRow_row1();

C:\CB correspond à mon répertoire temporaire.

Je dirais qu’il y a que le répertoire en paramètre. Le reste est en dur dans le code. A mon avis le plus facile c’est d’essayer de les mettre dans des jobs différents (chaque tmap avec cette option dans un job). Ou aller trifouiller dans les fichiers source de Talend, plus exactement dans le tmap pour changer le code généré