删除某一时间前的数据

修改目录路径,执行下面的代码

  1. old_version=$(hadoop fs -ls /home/pqchen/checkpoints/ | awk 'BEGIN{ five_days_ago=strftime("%F", systime()-5*24*3600) }{ split($8,arr,"/"); if(arr[7]<five_days_ago){printf "%s\n", $8} }');
  2. arr=(${old_version// / });
  3. for version in ${arr[@]}
  4. do
  5. hadoop fs -rmr $version
  6. done