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/11/19 03:44:04 UTC
[flink] branch release-1.10 updated: [FLINK-20218][python] Import
urllib.parse before importing apache-beam (#14125)
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a commit to branch release-1.10
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.10 by this push:
new 2fbef47 [FLINK-20218][python] Import urllib.parse before importing apache-beam (#14125)
2fbef47 is described below
commit 2fbef47bed73d3847fd88a292802551fcef64050
Author: HuangXingBo <hx...@gmail.com>
AuthorDate: Thu Nov 19 11:39:06 2020 +0800
[FLINK-20218][python] Import urllib.parse before importing apache-beam (#14125)
---
flink-python/pyflink/fn_execution/boot.py | 1 +
flink-python/pyflink/fn_execution/sdk_worker_main.py | 3 +++
2 files changed, 4 insertions(+)
diff --git a/flink-python/pyflink/fn_execution/boot.py b/flink-python/pyflink/fn_execution/boot.py
index d374397..d8c741ca3 100644
--- a/flink-python/pyflink/fn_execution/boot.py
+++ b/flink-python/pyflink/fn_execution/boot.py
@@ -36,6 +36,7 @@ import grpc
import logging
import sys
+import urllib.parse # noqa # pylint: disable=unused-import
from apache_beam.portability.api.beam_provision_api_pb2_grpc import ProvisionServiceStub
from apache_beam.portability.api.beam_provision_api_pb2 import GetProvisionInfoRequest
from apache_beam.portability.api.beam_artifact_api_pb2_grpc import ArtifactRetrievalServiceStub
diff --git a/flink-python/pyflink/fn_execution/sdk_worker_main.py b/flink-python/pyflink/fn_execution/sdk_worker_main.py
index 82d091c..7ceaded 100644
--- a/flink-python/pyflink/fn_execution/sdk_worker_main.py
+++ b/flink-python/pyflink/fn_execution/sdk_worker_main.py
@@ -18,6 +18,9 @@
import sys
+# refer to https://issues.apache.org/jira/browse/FLINK-20218
+import urllib.parse # noqa # pylint: disable=unused-import
+
# force to register the operations to SDK Harness
import pyflink.fn_execution.operations # noqa # pylint: disable=unused-import