You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2020/06/03 14:56:25 UTC
[flink] branch master updated (75df7ed -> 66d1300)
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 75df7ed [FLINK-13782][table-api] Fix checking comparision of nested distinct/structured/raw types
add 80b002b [FLINK-17959][checkstyle] Exclude all beam classes
add b31b180 [FLINK-17959][python] Port Beam GrpcStateService class to flink-python module
add 66d1300 [FLINK-17959][python] Fix the 'call already cancelled' exception when executing Python UDF
No new revisions were added by this update.
Summary of changes:
.../fnexecution/state/GrpcStateService.java | 170 +++++++++++++++++++++
tools/maven/suppressions.xml | 2 +-
2 files changed, 171 insertions(+), 1 deletion(-)
create mode 100644 flink-python/src/main/java/org/apache/beam/runners/fnexecution/state/GrpcStateService.java