change test file

tensnsorflow/multi.py

@@ -147,9 +147,17 @@ if __name__ == '__main__':
     # validate_date, value_map, app_list_map = feature()
     # get_predict(validate_date, value_map, app_list_map)
 
-    spark = SparkSession.builder.getOrCreate()
-    d = spark.textFile("hdfs://172.16.32.4:8020/strategy/esmm/tr").collect()
-    print(d)
+    import subprocess
+
+    p = subprocess.Popen("hdfs dfs -ls /strategy/esmm/tr |  awk '{print $8}",
+                         shell=True,
+                         stdout=subprocess.PIPE,
+                         stderr=subprocess.STDOUT)
+
+    for line in p.stdout.readlines():
+        print(line)
+    # d = spark.textFile("hdfs://172.16.32.4:8020/strategy/esmm/tr").collect()
+    # print(d)