hdfs dfs -rmr $cdns_hadoop_base_dir/dt=$ydate
hdfs dfs -mkdir $cdns_hadoop_base_dir/dt=$ydate
cat nodeList| while read nodename
do
hdfs dfs -mkdir $cdns_hadoop_base_dir/dt=$ydate/node=$nodename
ls *$nodename*lzo > cdnsFileListLzo
while read query_log
do
( hdfs dfs -put $query_log $cdns_hadoop_base_dir/dt=$ydate/node=$nodename
rm $query_log -rf
yarn jar ${hadooplzojar} ${hadooplzoclass} $cdns_hadoop_base_dir/dt=$ydate/node=$nodename/$query_log ) &
done < cdnsFileListLzo
wait
done