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 48e3a77b621 [FLINK-39997][python] Upgrade pemja to 0.6.2 (#28550)
48e3a77b621 is described below
commit 48e3a77b621a6bb00dba634d3a2819b6dff62dde
Author: florianvazelle <[email protected]>
AuthorDate: Tue Sep 15 13:07:52 2026 +0200
[FLINK-39997][python] Upgrade pemja to 0.6.2 (#28550)
---
flink-python/pom.xml | 2 +-
.../pyflink/fn_execution/datastream/embedded/state_impl.py | 8 ++++----
flink-python/pyproject.toml | 2 +-
flink-python/setup.py | 2 +-
flink-python/src/main/resources/META-INF/NOTICE | 2 +-
5 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/flink-python/pom.xml b/flink-python/pom.xml
index 43bc301bfcd..ca08c75951c 100644
--- a/flink-python/pom.xml
+++ b/flink-python/pom.xml
@@ -155,7 +155,7 @@ under the License.
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>pemja</artifactId>
- <version>0.5.7</version>
+ <version>0.6.2</version>
<optional>${flink.markBundledAsOptional}</optional>
</dependency>
diff --git
a/flink-python/pyflink/fn_execution/datastream/embedded/state_impl.py
b/flink-python/pyflink/fn_execution/datastream/embedded/state_impl.py
index 8eb28eaf380..8bd9b991850 100644
--- a/flink-python/pyflink/fn_execution/datastream/embedded/state_impl.py
+++ b/flink-python/pyflink/fn_execution/datastream/embedded/state_impl.py
@@ -223,8 +223,8 @@ class MapStateImpl(KeyedStateImpl, InternalMapState):
entries = self._state.entries()
if entries:
for entry in entries:
- yield (self._k_converter.to_internal(entry.getKey()),
- self._v_converter.to_internal(entry.getValue()))
+ yield (self._k_converter.to_internal(entry[0]),
+ self._v_converter.to_internal(entry[1]))
def keys(self) -> Iterable[K]:
keys = self._state.keys()
@@ -261,8 +261,8 @@ class ReadOnlyBroadcastStateImpl(StateImpl,
InternalReadOnlyBroadcastState):
def items(self) -> Iterable[Tuple[K, V]]:
entries = self._state.entries()
for entry in entries:
- yield (self._k_converter.to_internal(entry.getKey()),
- self._v_converter.to_internal(entry.getValue()))
+ yield (self._k_converter.to_internal(entry[0]),
+ self._v_converter.to_internal(entry[1]))
def keys(self) -> Iterable[K]:
for k in self._state.keys():
diff --git a/flink-python/pyproject.toml b/flink-python/pyproject.toml
index f8f9c867c79..d18e47acf10 100644
--- a/flink-python/pyproject.toml
+++ b/flink-python/pyproject.toml
@@ -46,7 +46,7 @@ dev = [
"grpcio>=1.33.1,<2",
# Apache Beam 2.69 is the last version supporting Python 3.9 and requires
grpcio<1.66.
"grpcio-tools==1.80.0; python_version >= '3.10'",
- "pemja>=0.5.7,<0.5.8; platform_system != 'Windows'",
+ "pemja>=0.6.2,<0.7; platform_system != 'Windows'",
"httplib2>=0.19.0",
"protobuf>=6.31.1,<7.0.0.dev0",
"pytest~=8.0",
diff --git a/flink-python/setup.py b/flink-python/setup.py
index d224f6c05f2..d643180f438 100644
--- a/flink-python/setup.py
+++ b/flink-python/setup.py
@@ -327,7 +327,7 @@ try:
'numpy>=1.22.4',
'pandas>=1.3.0,<2.3', # FLINK-38513: 2.3+ drops cp39
wheels
'pyarrow>=5.0.0,<26.0.0',
- 'pemja>=0.5.7,<0.5.8;platform_system != "Windows"',
+ 'pemja>=0.6.2,<0.7;platform_system != "Windows"',
'httplib2>=0.19.0',
'ruamel.yaml>=0.18.4',
# deprecated() landed in 4.5.0; 4.7.0 declares 3.12
support.
diff --git a/flink-python/src/main/resources/META-INF/NOTICE
b/flink-python/src/main/resources/META-INF/NOTICE
index c7b30e05a80..1185938a764 100644
--- a/flink-python/src/main/resources/META-INF/NOTICE
+++ b/flink-python/src/main/resources/META-INF/NOTICE
@@ -32,7 +32,7 @@ This project bundles the following dependencies under the
Apache Software Licens
- org.apache.beam:beam-sdks-java-transform-service-launcher:2.75.0
- org.apache.beam:beam-vendor-guava-32_1_2-jre:0.1
- org.apache.beam:beam-vendor-grpc-1_69_0:0.1
-- com.alibaba:pemja:0.5.7
+- com.alibaba:pemja:0.6.2
This project bundles the following dependencies under the BSD license.
See bundled license files for details
