;gt; externally..
> > > 2021-11-18 20:48:44,458 INFO 
> > >
> org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] -
> > Shutting
> > > down rest endpoint.
> > > 2021-11-18 20:48:44
at
> org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)
> at
> org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)
> at
> org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualW
> > org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] -
> > http://cdh5node3:40216 lost leadership
> > 2021-11-18 20:48:44,474 INFO 
> > org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] -
> Shut
> > down co
gt; 发件人:
> "user-zh"
> <
> dian0511...@gmail.com>;
> 发送时间: 2021年11月19日(星期五) 上午9:38
> 收件人: "user-zh"
> 主题: Re: 哪里可以下载到downloads/setup-pyflink-virtual-env.sh脚本
>
>
>
> -pyexec 指定的是集群端所用的P
irectory
> /tmp/flink-web-dd82c3c0-f457-492d-8e64-5ae74fe9abbd/flink-web-ui
> 2021-11-18 20:48:44,474 INFO
> org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] -
> http://cdh5node3:40216 lost leadership
> 2021-11-18 20:48:44,474 INFO
> org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - Shut
> down complete.
>
patcher
> [] - Stopping dispatcher akka.tcp://flink@cdh5node3
> :34697/user/rpc/dispatcher_1.
> 2021-11-18 20:48:44,476 INFO
> org.apache.flink.runtime.dispatcher.StandaloneDispatcher
> [] - Stopping all currently running jobs of dispatcher
> akka.tcp://flink@cdh5node3:34697/user/rpc
"user-zh"
https://nightlies.apache.org/flink/flink-docs-release-1.12/downloads/setup-pyflink-virtual-env.sh
?? 2021-11-18 15:05:03??"Asahi Lee" <978466...@qq.com.INVALID> ??
>Hi!
>
flink??&n
Hi!??https://nightlies.apache.org/flink/flink-docs-release-1.12/downloads/setup-pyflink-virtual-env.sh
?? 2021-11-18 15:05:03??"Asahi Lee" <978466...@qq.com.INVALID> ??
>Hi!
>
>flink?? set
Hi!
flink?? setup-pyflink-virtual-env.sh
python??
https://nightlies.apache.org/flink/flink-docs-release-1.14/zh/docs/dev/python/faq/
