# coding=UTF-8
import os
def distcp():
nncheck = os.system('lsof -i:8020')
dncheck = os.system('lsof -i:50010')
if nncheck == 256 and (dncheck == 256):
os.system("su - hdfs hadoop-daemon.sh start namenode")
os.system("su - hdfs hadoop-daemon.sh start datanode")
else:
os.system("hadoop distcp -f hdfs://192.168.66.128:8020/user/hive/warehouse/test.db hdfs://192.168.66.129:8020/user/hive/warehouse/test.db")
if __name__ == "__main__":
distcp()