[FLINK-5206] [py] Use random file names in tests

This closes apache#2973.
fullcontact · Dec 12, 2016 · 4befbb8 · 4befbb8
1 parent 36bf993
commit 4befbb8
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/flink-libraries/flink-python/src/test/python/org/apache/flink/python/api/test_main.py b/flink-libraries/flink-python/src/test/python/org/apache/flink/python/api/test_main.py
@@ -25,6 +25,7 @@
 from flink.plan.Constants import Order, WriteMode
 from flink.plan.Constants import INT, STRING
 import struct
+from uuid import uuid4
 from utils import Id, Verify
 
 if __name__ == "__main__":
@@ -58,14 +59,17 @@
  #CSV Source/Sink
  csv_data = env.read_csv("src/test/python/org/apache/flink/python/api/data_csv", (INT, INT, STRING))
 
- csv_data.write_csv("/tmp/flink/result1", line_delimiter="\n", field_delimiter="|", write_mode=WriteMode.OVERWRITE)
+ out = "flink_python_" + str(uuid4())
+ csv_data.write_csv("/tmp/flink/" + out, line_delimiter="\n", field_delimiter="|", write_mode=WriteMode.OVERWRITE)
 
- d8.write_csv("/tmp/flink/result2", line_delimiter="\n", field_delimiter="|", write_mode=WriteMode.OVERWRITE)
+ out = "flink_python_" + str(uuid4())
+ d8.write_csv("/tmp/flink/" + out, line_delimiter="\n", field_delimiter="|", write_mode=WriteMode.OVERWRITE)
 
  #Text Source/Sink
  text_data = env.read_text("src/test/python/org/apache/flink/python/api/data_text")
 
- text_data.write_text("/tmp/flink/result2", WriteMode.OVERWRITE)
+ out = "flink_python_" + str(uuid4())
+ text_data.write_text("/tmp/flink/" + out, WriteMode.OVERWRITE)
 
  #Types
  env.from_elements(bytearray(b"hello"), bytearray(b"world"))\