This is an automated email from the ASF dual-hosted git repository. dianfu pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 7eaa2741cc3fdf81b72740d4abdc1db74b641c47 Author: Dian Fu <[email protected]> AuthorDate: Sun Apr 24 13:45:18 2022 +0800 [hotfix][python][tests] Remove useless test utility methods --- flink-python/pyflink/testing/test_case_utils.py | 16 ---------------- 1 file changed, 16 deletions(-) diff --git a/flink-python/pyflink/testing/test_case_utils.py b/flink-python/pyflink/testing/test_case_utils.py index 8abe31f8e4c..a8cbc2a292a 100644 --- a/flink-python/pyflink/testing/test_case_utils.py +++ b/flink-python/pyflink/testing/test_case_utils.py @@ -29,7 +29,6 @@ from py4j.java_gateway import JavaObject from pyflink.common import JobExecutionResult from pyflink.datastream.execution_mode import RuntimeExecutionMode -from pyflink.table.sources import CsvTableSource from pyflink.datastream.stream_execution_environment import StreamExecutionEnvironment from pyflink.find_flink_home import _find_flink_home, _find_flink_source_root from pyflink.table.table_environment import TableEnvironment @@ -111,21 +110,6 @@ class PyFlinkTestCase(unittest.TestCase): py_list.append(actual.get(i)) return py_list - @classmethod - def prepare_csv_source(cls, path, data, data_types, fields): - if os.path.isfile(path): - os.remove(path) - csv_data = "" - for item in data: - if isinstance(item, list) or isinstance(item, tuple): - csv_data += ",".join([str(element) for element in item]) + "\n" - else: - csv_data += str(item) + "\n" - with open(path, 'w') as f: - f.write(csv_data) - f.close() - return CsvTableSource(path, fields, data_types) - class PyFlinkStreamTableTestCase(PyFlinkTestCase): """
