hadoop - hadoopストリーミングはノードIDを取得します

Question

Hadoopストリーミングでは、特定のタスクを処理するノードのIDを取得する方法はありますか？

例えとして、このスニペットはタスクの入力ファイルの名前を示します。

#!/usr/bin/env python
import os
map_input_file = str(os.environ["map_input_file"])

os.environ["map_node_id"]のようなものを探しています。ノードへの一意のハンドルはすべて機能します...

Answer 1

マッパー/リデューサーのソケットモジュールを使用するだけで、データノードのホスト名を取得できます。

import socket
...
node = socket.gethostname()