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 ce37fc902b6d26de74c6a6fcbbf042f7887bacf6
Author: Dian Fu <dia...@apache.org>
AuthorDate: Fri Apr 8 14:19:20 2022 +0800
[hotfix][python][tests] Cleanup the API completeness test
---
flink-python/pyflink/table/tests/test_environment_completeness.py | 1 -
flink-python/pyflink/table/tests/test_table_completeness.py | 6 ++----
2 files changed, 2 insertions(+), 5 deletions(-)
diff --git a/flink-python/pyflink/table/tests/test_environment_completeness.py
b/flink-python/pyflink/table/tests/test_environment_completeness.py
index cfbba824fc2..307f9a2a66f 100644
--- a/flink-python/pyflink/table/tests/test_environment_completeness.py
+++ b/flink-python/pyflink/table/tests/test_environment_completeness.py
@@ -39,7 +39,6 @@ class
EnvironmentAPICompletenessTests(PythonAPICompletenessTestCase, PyFlinkTest
return {
'getCompletionHints',
'fromValues',
- 'create',
# See FLINK-25986
'loadPlan',
'compilePlanSql',
diff --git a/flink-python/pyflink/table/tests/test_table_completeness.py
b/flink-python/pyflink/table/tests/test_table_completeness.py
index 8c85ff7d63f..f7683401a54 100644
--- a/flink-python/pyflink/table/tests/test_table_completeness.py
+++ b/flink-python/pyflink/table/tests/test_table_completeness.py
@@ -36,14 +36,12 @@ class
TableAPICompletenessTests(PythonAPICompletenessTestCase, PyFlinkTestCase):
@classmethod
def excluded_methods(cls):
- # row-based operators should be supported when UDFs supported in
python.
# getSchema method returns a TableSchema, the implementation of
TableSchema requires a
# complete type system, which does not exist currently. It will be
implemented after
# FLINK-12408 is merged. So we exclude this method for the time being.
# Also FLINK-25986 are excluded.
- return {'map', 'flatMap', 'flatAggregate', 'aggregate',
'leftOuterJoinLateral',
- 'createTemporalTableFunction', 'joinLateral',
'getQueryOperation', 'limit',
- 'getResolvedSchema', 'insertInto', 'printExplain'}
+ return {'createTemporalTableFunction', 'getQueryOperation',
'getResolvedSchema',
+ 'insertInto', 'printExplain'}
@classmethod
def java_method_name(cls, python_method_name):
