# 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()