Hi, 看起来是依赖缺失问题，建议参考官方教程文档跑通一个简单的示例
Table API: https://nightlies.apache.org/flink/flink-docs-master/docs/dev/python/table_api_tutorial/ DataStreamAPI: https://nightlies.apache.org/flink/flink-docs-master/docs/dev/python/datastream_tutorial/ Best, Weihua On Wed, Jun 15, 2022 at 8:35 PM Xingbo Huang <hxbks...@gmail.com> wrote: > Hi, > > 你可以执行 pip install -r flink-python/dev/dev-requirements.txt 安装开发环境所需要的依赖 > > Best, > Xingbo > > 张 兴博 <xingbozh...@outlook.com> 于2022年6月15日周三 10:20写道： > > > 您好： > > 我是一名学习使用pyflink的用户，我想在ubuntu20.04上开发pyflink，但是在运行代码的时候，报错为： > > > > Traceback (most recent call last): > > File "/root/tttt.py", line 6, in <module> > > s_env = StreamExecutionEnvironment.get_execution_environment() > > File > > > "/usr/local/lib/python3.8/dist-packages/pyflink/datastream/stream_execution_environment.py", > > line 805, in get_execution_environment > > return StreamExecutionEnvironment(j_stream_exection_environment) > > File > > > "/usr/local/lib/python3.8/dist-packages/pyflink/datastream/stream_execution_environment.py", > > line 62, in __init__ > > self._open() > > File > > > "/usr/local/lib/python3.8/dist-packages/pyflink/datastream/stream_execution_environment.py", > > line 973, in _open > > startup_loopback_server() > > File > > > "/usr/local/lib/python3.8/dist-packages/pyflink/datastream/stream_execution_environment.py", > > line 963, in startup_loopback_server > > from pyflink.fn_execution.beam.beam_worker_pool_service import \ > > File > > > "/usr/local/lib/python3.8/dist-packages/pyflink/fn_execution/beam/beam_worker_pool_service.py", > > line 31, in <module> > > from apache_beam.options.pipeline_options import DebugOptions > > File "/usr/local/lib/python3.8/dist-packages/apache_beam/__init__.py", > > line 96, in <module> > > from apache_beam import io > > File > > "/usr/local/lib/python3.8/dist-packages/apache_beam/io/__init__.py", line > > 23, in <module> > > from apache_beam.io.avroio import * > > File "/usr/local/lib/python3.8/dist-packages/apache_beam/io/avroio.py", > > line 63, in <module> > > from apache_beam.io import filebasedsink > > File > > "/usr/local/lib/python3.8/dist-packages/apache_beam/io/filebasedsink.py", > > line 36, in <module> > > from apache_beam.io import iobase > > File "/usr/local/lib/python3.8/dist-packages/apache_beam/io/iobase.py", > > line 57, in <module> > > from apache_beam.transforms import Impulse > > File > > > "/usr/local/lib/python3.8/dist-packages/apache_beam/transforms/__init__.py", > > line 25, in <module> > > from apache_beam.transforms.external import * > > File > > > "/usr/local/lib/python3.8/dist-packages/apache_beam/transforms/external.py", > > line 45, in <module> > > from apache_beam.runners import pipeline_context > > File > > > "/usr/local/lib/python3.8/dist-packages/apache_beam/runners/pipeline_context.py", > > line 51, in <module> > > from apache_beam.transforms import environments > > File > > > "/usr/local/lib/python3.8/dist-packages/apache_beam/transforms/environments.py", > > line 54, in <module> > > from apache_beam.runners.portability.sdk_container_builder import > > SdkContainerImageBuilder > > File > > > "/usr/local/lib/python3.8/dist-packages/apache_beam/runners/portability/sdk_container_builder.py", > > line 44, in <module> > > from apache_beam.internal.gcp.auth import get_service_credentials > > File > > > "/usr/local/lib/python3.8/dist-packages/apache_beam/internal/gcp/auth.py", > > line 28, in <module> > > from oauth2client.client import GoogleCredentials > > File "/usr/local/lib/python3.8/dist-packages/oauth2client/client.py", > > line 39, in <module> > > from oauth2client import transport > > File > "/usr/local/lib/python3.8/dist-packages/oauth2client/transport.py", > > line 17, in <module> > > import httplib2 > > ModuleNotFoundError: No module named 'httplib2' > > > > 通过查询发现在python新版中，httplib2已经不用了？采用的名字是http.client？ > > 我的python版本为3.8.10，jdk为openjdk 11.0.15（另一台为java 1.8） > > 我想知道这是什么原因造成的呢？怎么能解决这个问题呢？ > > > > 感谢您在百忙之中解答我的问题，万分感谢~！ > > > > 发送自 Windows 11 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>应用 > > > > >
