This is an automated email from the ASF dual-hosted git repository.
hxb 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 0bbc7b1e9fe [FLINK-30191][python] Update net.sf.py4j:py4j dependency
to 0.10.9.7
0bbc7b1e9fe is described below
commit 0bbc7b1e9fed89b8c3e8ec67b7b0dad5999c2c01
Author: yunfengzhou-hub <[email protected]>
AuthorDate: Tue Jan 17 07:56:50 2023 +0800
[FLINK-30191][python] Update net.sf.py4j:py4j dependency to 0.10.9.7
This closes #21680.
---
NOTICE | 2 +-
flink-python/README.md | 2 +-
flink-python/dev/dev-requirements.txt | 2 +-
flink-python/lib/py4j-0.10.9.3-src.zip | Bin 83148 -> 0 bytes
flink-python/lib/py4j-0.10.9.7-src.zip | Bin 0 -> 86109 bytes
flink-python/pyflink/table/table_result.py | 8 ++++++--
flink-python/setup.py | 2 +-
flink-python/src/main/resources/META-INF/NOTICE | 2 +-
pom.xml | 2 +-
9 files changed, 12 insertions(+), 8 deletions(-)
diff --git a/NOTICE b/NOTICE
index 5a044c13b4d..ac7fec6af6d 100644
--- a/NOTICE
+++ b/NOTICE
@@ -18,7 +18,7 @@ This project bundles the following dependencies under the BSD
license.
See bundled license files for details.
- cloudpickle:2.1.0
-- net.sf.py4j:py4j:0.10.9.3
+- net.sf.py4j:py4j:0.10.9.7
This project bundles the following dependencies under SIL OFL 1.1 license
(https://opensource.org/licenses/OFL-1.1).
See bundled license files for details.
diff --git a/flink-python/README.md b/flink-python/README.md
index 85d55d12532..b90726fcabf 100644
--- a/flink-python/README.md
+++ b/flink-python/README.md
@@ -26,7 +26,7 @@ The auto-generated Python docs can be found at
[https://nightlies.apache.org/fli
## Python Requirements
-Apache Flink Python API depends on Py4J (currently version 0.10.9.3),
CloudPickle (currently version 2.1.0), python-dateutil(currently version
2.8.0), Apache Beam (currently version 2.38.0).
+Apache Flink Python API depends on Py4J (currently version 0.10.9.7),
CloudPickle (currently version 2.1.0), python-dateutil(currently version
2.8.0), Apache Beam (currently version 2.38.0).
## Development Notices
diff --git a/flink-python/dev/dev-requirements.txt
b/flink-python/dev/dev-requirements.txt
index f81907ab5d6..54e480d9a73 100755
--- a/flink-python/dev/dev-requirements.txt
+++ b/flink-python/dev/dev-requirements.txt
@@ -17,7 +17,7 @@ setuptools>=18.0
wheel
apache-beam==2.38.0
cython==0.29.24
-py4j==0.10.9.3
+py4j==0.10.9.7
python-dateutil==2.8.0
cloudpickle==2.1.0
avro-python3>=1.8.1,!=1.9.2,<1.10.0
diff --git a/flink-python/lib/py4j-0.10.9.3-src.zip
b/flink-python/lib/py4j-0.10.9.3-src.zip
deleted file mode 100644
index 82f0b89adea..00000000000
Binary files a/flink-python/lib/py4j-0.10.9.3-src.zip and /dev/null differ
diff --git a/flink-python/lib/py4j-0.10.9.7-src.zip
b/flink-python/lib/py4j-0.10.9.7-src.zip
new file mode 100644
index 00000000000..4d414b9ed18
Binary files /dev/null and b/flink-python/lib/py4j-0.10.9.7-src.zip differ
diff --git a/flink-python/pyflink/table/table_result.py
b/flink-python/pyflink/table/table_result.py
index 6c982676d43..c35ce08e8e3 100644
--- a/flink-python/pyflink/table/table_result.py
+++ b/flink-python/pyflink/table/table_result.py
@@ -141,7 +141,7 @@ class TableResult(object):
.. versionadded:: 1.11.0
"""
- return
TableSchema(j_table_schema=self._j_table_result.getTableSchema())
+ return TableSchema(j_table_schema=self._get_java_table_schema())
def get_result_kind(self) -> ResultKind:
"""
@@ -189,7 +189,7 @@ class TableResult(object):
.. versionadded:: 1.12.0
"""
- field_data_types =
self._j_table_result.getTableSchema().getFieldDataTypes()
+ field_data_types = self._get_java_table_schema().getFieldDataTypes()
j_iter = self._j_table_result.collect()
@@ -218,6 +218,10 @@ class TableResult(object):
"""
self._j_table_result.print()
+ def _get_java_table_schema(self):
+ TableSchema = get_gateway().jvm.org.apache.flink.table.api.TableSchema
+ return
TableSchema.fromResolvedSchema(self._j_table_result.getResolvedSchema())
+
class CloseableIterator(object):
"""
diff --git a/flink-python/setup.py b/flink-python/setup.py
index f684099e129..dca4e1961ea 100644
--- a/flink-python/setup.py
+++ b/flink-python/setup.py
@@ -308,7 +308,7 @@ try:
'pyflink.examples': ['*.py', '*/*.py'],
'pyflink.bin': ['*']}
- install_requires = ['py4j==0.10.9.3', 'python-dateutil==2.8.0',
'apache-beam==2.38.0',
+ install_requires = ['py4j==0.10.9.7', 'python-dateutil==2.8.0',
'apache-beam==2.38.0',
'cloudpickle==2.1.0',
'avro-python3>=1.8.1,!=1.9.2,<1.10.0',
'pytz>=2018.3', 'fastavro>=1.1.0,<1.4.8',
'requests>=2.26.0',
'protobuf>=3.19.0,<=3.21',
diff --git a/flink-python/src/main/resources/META-INF/NOTICE
b/flink-python/src/main/resources/META-INF/NOTICE
index 0d6835668c2..f94a4fce153 100644
--- a/flink-python/src/main/resources/META-INF/NOTICE
+++ b/flink-python/src/main/resources/META-INF/NOTICE
@@ -33,7 +33,7 @@ This project bundles the following dependencies under the
Apache Software Licens
This project bundles the following dependencies under the BSD license.
See bundled license files for details
-- net.sf.py4j:py4j:0.10.9.3
+- net.sf.py4j:py4j:0.10.9.7
- com.google.protobuf:protobuf-java:3.21.7
This project bundles the following dependencies under the MIT license.
(https://opensource.org/licenses/MIT)
diff --git a/pom.xml b/pom.xml
index 02af94cf4c4..d27fb927343 100644
--- a/pom.xml
+++ b/pom.xml
@@ -153,7 +153,7 @@ under the License.
<powermock.version>2.0.9</powermock.version>
<hamcrest.version>1.3</hamcrest.version>
<assertj.version>3.23.1</assertj.version>
- <py4j.version>0.10.9.3</py4j.version>
+ <py4j.version>0.10.9.7</py4j.version>
<beam.version>2.38.0</beam.version>
<protoc.version>3.21.7</protoc.version>
<okhttp.version>3.14.9</okhttp.version>
