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
The following commit(s) were added to refs/heads/master by this push:
new d92ef4f1105 [hotfix][python] Fix flake8 check E302 error for blank
lines (#19821)
d92ef4f1105 is described below
commit d92ef4f11053f1131c4743047b284ec5690e736d
Author: Ada Wang <[email protected]>
AuthorDate: Fri May 27 15:40:16 2022 +0800
[hotfix][python] Fix flake8 check E302 error for blank lines (#19821)
---
flink-python/pyflink/table/tests/test_udf.py | 1 +
1 file changed, 1 insertion(+)
diff --git a/flink-python/pyflink/table/tests/test_udf.py
b/flink-python/pyflink/table/tests/test_udf.py
index 6b4d7798a61..91e418e9083 100644
--- a/flink-python/pyflink/table/tests/test_udf.py
+++ b/flink-python/pyflink/table/tests/test_udf.py
@@ -801,6 +801,7 @@ class PyFlinkEmbeddedThreadTests(UserDefinedFunctionTests,
PyFlinkBatchTableTest
super(PyFlinkEmbeddedThreadTests, self).setUp()
self.t_env.get_config().set("python.execution-mode", "thread")
+
# test specify the input_types
@udf(input_types=[DataTypes.BIGINT(), DataTypes.BIGINT()],
result_type=DataTypes.BIGINT())
def add(i, j):
