comment trouver l'ID de chaque tâche de carte?

Question

Je veux obtenir l'identifiant de chaque tâche de mappeur et de réducteur car je veux marquer la sortie de ces mappeurs et réducteurs en fonction de l'identifiant du mappeur et du réducteur. Comment puis-je récupérer les identifiants de chacun?

Merci

Answer 1

vous pouvez le faire en utilisant: org.apache.hadoop.mapreduce.MapContext :: getTaskAttemptID().

Answer 2

Vous pouvez imprimer taskId dans les fonctions de carte, de configuration, etc. en utilisant le code suivant.

context.getTaskAttemptID().getTaskID();