This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.12 by this push:
new 6b3529c [hotfix][python] Fix expressions.without_columns to make
tails as vararg
6b3529c is described below
commit 6b3529c86e73eac3936b7f1458ccf1431a622fbe
Author: Dian Fu <[email protected]>
AuthorDate: Fri Dec 18 20:14:44 2020 +0800
[hotfix][python] Fix expressions.without_columns to make tails as vararg
---
flink-python/pyflink/table/expressions.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-python/pyflink/table/expressions.py
b/flink-python/pyflink/table/expressions.py
index 38a1823..34c880e 100644
--- a/flink-python/pyflink/table/expressions.py
+++ b/flink-python/pyflink/table/expressions.py
@@ -492,7 +492,7 @@ def with_columns(head, *tails) -> Expression:
return _binary_op("withColumns", head, tails)
-def without_columns(head, tails) -> Expression:
+def without_columns(head, *tails) -> Expression:
"""
Creates an expression that selects all columns except for the given range
of columns. It can
be used wherever an array of expression is accepted such as function
calls, projections, or