keyed state重新指定并行度后,比如2->4或者4->2,请问下是不是会丢失部分老的状态?
keyed state重新指定并行度后,比如2->4或者4->2,请问下是不是会丢失部分老的状态?
回复:如何添加source保障程序状态不丢
试了下,可以直接加source,有办法加source后,删掉老的source么? 在 2021-11-17 14:56:37,"杨浩" 写道: 请问下,我们程序在运行后需要添加一个kafka source(和老的协议一致,后面加工逻辑一样),程序开启了checkpoint,如何保障之前程序的状态不丢啊
如何添加source保障程序状态不丢
请问下,我们程序在运行后需要添加一个kafka source(和老的协议一致,后面加工逻辑一样),程序开启了checkpoint,如何保障之前程序的状态不丢啊
回复:Re: 回复:回复:Re: 在开启checkpoint后如何设置offset的自动提交以方便监控
明白这个逻辑,这个就导致consumer lag值不能反映真实情况,而很难监控系统延迟一个场景:业务状态很大,5分钟保存一次,QPS在1~100之间波动,那么需要配置延迟大于5*60*100来监控系统,这会导致监控非常不准确 在 2021-10-27 17:34:13,"Qingsheng Ren" 写道: >你好! > >如果使用的是基于 FLIP-27 实现的 KafkaSource,可以配置 enable.auto.commit = true 和 >auto.commit.interval.ms = {commit_interval} 使 KafkaSource 按照指定的时间间隔自动提交 >offset。基于 SourceFunction 的 FlinkKafkaConsumer 在 checkpoint 开启时不支持自动提交,只能在 >checkpoint 时提交位点。 > >-- >Best Regards, > >Qingsheng Ren >Email: renqs...@gmail.com >On Oct 27, 2021, 4:59 PM +0800, 杨浩 , wrote: >> 请问有办法和现有监控兼容么?开启checkpoint时,让消费组的offset实时更新 >> 在 2021-10-25 21:58:28,"杨浩" 写道: >> > currentOffsets理论上OK,但是这边云上监控系统中的kafka未消费量使用的是committedOffsets >> > 在 2021-10-25 10:31:12,"Caizhi Weng" 写道: >> > > Hi! >> > > >> > > 这里的 offset 是 kafka source 的 offset 吗?其实没必要通过 checkpoint 读取 offset,可以通过 >> > > metrics 读取,见 [1]。 >> > > >> > > [1] >> > > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/metrics/#kafka-connectors >> > > >> > > 杨浩 于2021年10月25日周一 上午10:20写道: >> > > >> > > > 请问下,如果启用checkpoint,因为状态比较大,checkpoint间隔设置比较大,如何让offset提交的比较快,这样方便监控程序进度
回复:回复:Re: 在开启checkpoint后如何设置offset的自动提交以方便监控
请问有办法和现有监控兼容么?开启checkpoint时,让消费组的offset实时更新 在 2021-10-25 21:58:28,"杨浩" 写道: >currentOffsets理论上OK,但是这边云上监控系统中的kafka未消费量使用的是committedOffsets >在 2021-10-25 10:31:12,"Caizhi Weng" 写道: >>Hi! >> >>这里的 offset 是 kafka source 的 offset 吗?其实没必要通过 checkpoint 读取 offset,可以通过 >>metrics 读取,见 [1]。 >> >>[1] >>https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/metrics/#kafka-connectors >> >>杨浩 于2021年10月25日周一 上午10:20写道: >> >>> 请问下,如果启用checkpoint,因为状态比较大,checkpoint间隔设置比较大,如何让offset提交的比较快,这样方便监控程序进度
回复:Re: 在开启checkpoint后如何设置offset的自动提交以方便监控
currentOffsets理论上OK,但是这边云上监控系统中的kafka未消费量使用的是committedOffsets 在 2021-10-25 10:31:12,"Caizhi Weng" 写道: >Hi! > >这里的 offset 是 kafka source 的 offset 吗?其实没必要通过 checkpoint 读取 offset,可以通过 >metrics 读取,见 [1]。 > >[1] >https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/metrics/#kafka-connectors > >杨浩 于2021年10月25日周一 上午10:20写道: > >> 请问下,如果启用checkpoint,因为状态比较大,checkpoint间隔设置比较大,如何让offset提交的比较快,这样方便监控程序进度
在开启checkpoint后如何设置offset的自动提交以方便监控
请问下,如果启用checkpoint,因为状态比较大,checkpoint间隔设置比较大,如何让offset提交的比较快,这样方便监控程序进度
offset of TumblingEventTimeWindows
As in China (UTC+08:00),we should use Time.hours(-8) as offset when state day's data, // daily tumbling event-time windows offset by -8 hours. input.keyBy().window(TumblingEventTimeWindows.of(Time.days(1),Time.hours(-8))).() shall we also set Time.hours(-8) as offset for minute's state ? input.keyBy().window(TumblingEventTimeWindows.of(Time.seconds(5))).() input.keyBy().window(TumblingEventTimeWindows.of(Time.seconds(5),Time.hours(-8))) .()
回复:回复: 如何查看1.10的中文文档
多谢,看的这个哈 https://ci.apache.org/projects/flink/flink-docs-release-1.10/zh/ 在 2021-10-11 09:34:10,"wukon...@foxmail.com" 写道: hi 杨浩: 中文版地址 https://ci.apache.org/projects/flink/flink-docs-release-1.10/ 可以看到最左侧 下面有个 Pick Docs Version 可以通过这里选择所有版本的文档 wukon...@foxmail.com 发件人: 杨浩 发送时间: 2021-10-09 10:57 收件人: user-zh 主题: 如何查看1.10的中文文档 我们公司用的flink版本是release-1.10,请问如何查看该版本的中文文档, 英文文档:https://ci.apache.org/projects/flink/flink-docs-release-1.10/ 中文只能看最新的:https://flink.apache.org/zh/flink-architecture.html
回复:Re: 如何查看1.10的中文文档
Thanks 在 2021-10-09 11:15:02,"Xintong Song" 写道: >https://ci.apache.org/projects/flink/flink-docs-release-1.10/zh/ > >Thank you~ > >Xintong Song > > > >On Sat, Oct 9, 2021 at 10:57 AM 杨浩 wrote: > >> 我们公司用的flink版本是release-1.10,请问如何查看该版本的中文文档, >> >> >> 英文文档:https://ci.apache.org/projects/flink/flink-docs-release-1.10/ >> 中文只能看最新的:https://flink.apache.org/zh/flink-architecture.html >> >>
如何查看1.10的中文文档
我们公司用的flink版本是release-1.10,请问如何查看该版本的中文文档, 英文文档:https://ci.apache.org/projects/flink/flink-docs-release-1.10/ 中文只能看最新的:https://flink.apache.org/zh/flink-architecture.html
Re:Re: Re: flink on yarn 指定节点开启 yarn session 报错
hi,我确保,端口没占用的情况下更换rest.port: 8072,且更改了配置: #== # HistoryServer #== # The HistoryServer is started and stopped via bin/historyserver.sh (start|stop) # Directory to upload completed jobs to. Add this directory to the list of # monitored directories of the HistoryServer as well (see below). jobmanager.archive.fs.dir: hdfs://bigdata-test-8:18082/completed-jobs/ # The address under which the web-based HistoryServer listens. historyserver.web.address: bigdata-test-8 # The port under which the web-based HistoryServer listens. historyserver.web.port: 18082 # Comma separated list of directories to monitor for completed jobs. historyserver.archive.fs.dir: hdfs://bigdata-test-8:18082/completed-jobs/ # Interval in milliseconds for refreshing the monitored directories. historyserver.archive.fs.refresh-interval: 1 但在这种情况下启动yarn session 报错信息如下: = 2019-11-27 14:50:40,981 ERROR org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Could not start cluster entrypoint YarnSessionClusterEntrypoint. org.apache.flink.runtime.entrypoint.ClusterEntrypointException: Failed to initialize the cluster entrypoint YarnSessionClusterEntrypoint. at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:182) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:501) at org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint.main(YarnSessionClusterEntrypoint.java:93) Caused by: org.apache.flink.util.FlinkException: Could not create the DispatcherResourceManagerComponent. at org.apache.flink.runtime.entrypoint.component.AbstractDispatcherResourceManagerComponentFactory.create(AbstractDispatcherResourceManagerComponentFactory.java:257) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:210) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$0(ClusterEntrypoint.java:164) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:422) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1875) at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:163) ... 2 more Caused by: java.net.BindException: Could not start rest endpoint on any port in port range 8070-8090 at org.apache.flink.runtime.rest.RestServerEndpoint.start(RestServerEndpoint.java:219) at org.apache.flink.runtime.entrypoint.component.AbstractDispatcherResourceManagerComponentFactory.create(AbstractDispatcherResourceManagerComponentFactory.java:161) ... 9 more 在 2019-11-27 11:28:06,"tison" 写道: >确实是 historyserver.web.port 的默认值,但我记得 HistoryServer 默认是不启动的 > >总之可以确认下问题能否稳定复现,失败的瞬间端口有无被占用,以及换个端口能不能起来 > >如果还不行再找找其他原因 > >Best, >tison. > > >Yangze Guo 于2019年11月27日周三 上午11:23写道: > >> 8082我记得是historyserver.web.port的默认值,很可能是冲突了改成8081呢? >> >> Best, >> Yangze Guo >> >> On Wed, Nov 27, 2019 at 11:13 AM 杨浩程 wrote: >> > >> > >> >> > 好的,更改过的配置如下: >> > >> > >> #== >> > # Rest & web frontend >> > >> #== >> > >> > >> > # The port to which the REST client connects to. If rest.bind-port has >> > # not been specified, then the server will bind to this port as well. >> > # >> > rest.port: 8082 >> > >> > >> > # The address to which the REST client will connect to >> > # >> > rest.address: bigdata-test-8 >> > >> > >> > # Port range for the REST and web server to bind to. >> > # >> > #rest.bind-port: 8080-8090 >> > rest.bind-port: 8082 >> > >> > >> > # The address that the REST & web server binds to >> > # >> > rest.bind-address: bigdata-test-8 >> > >> > >> > # Flag to specify whether job submission is enabled from the web-based >> > # runtime monitor. Uncomment to disable. >> > >> > >> > #web.submit.enable: false >> > #web.upload.dir: /data/flink-1.9.0/u
Re:Re: flink on yarn 指定节点开启 yarn session 报错
好的,更改过的配置如下: #== # Rest & web frontend #== # The port to which the REST client connects to. If rest.bind-port has # not been specified, then the server will bind to this port as well. # rest.port: 8082 # The address to which the REST client will connect to # rest.address: bigdata-test-8 # Port range for the REST and web server to bind to. # #rest.bind-port: 8080-8090 rest.bind-port: 8082 # The address that the REST & web server binds to # rest.bind-address: bigdata-test-8 # Flag to specify whether job submission is enabled from the web-based # runtime monitor. Uncomment to disable. #web.submit.enable: false #web.upload.dir: /data/flink-1.9.0/upload_jars/ 在 2019-11-27 11:01:47,"Yangze Guo" 写道: >您好,目前ML不支持图片,能将配置贴上来么? >另外看报错信息像是8082端口被占用导致rest服务起不起来 > >Best, >Yangze Guo > > >On Wed, Nov 27, 2019 at 10:56 AM 杨浩程 wrote: > >> 各位大佬好! >>请教各位个问题:使用的flink 版本1.9.0。测试flink on yarn 指定节点 开启yarn session 会话。 >>希望yarnsession开启的集群 jobmanager开启在我指定的节点上。 >>更改的配置如下: >> 报错信息如下: >> >> === >> 2019-11-27 10:35:45,640 INFO >> org.apache.flink.shaded.curator.org.apache.curator.framework.imps.CuratorFrameworkImpl >> - backgroundOperati >> 2019-11-27 10:35:45,650 INFO >> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.ZooKeeper - >> Session: 0x36ea133e2b51435 closed >> 2019-11-27 10:35:45,650 INFO >> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.ClientCnxn - >> EventThread shut down for session: 0x3 >> 2019-11-27 10:35:45,651 INFO >> org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping >> Akka RPC service. >> 2019-11-27 10:35:45,659 INFO >> org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping >> Akka RPC service. >> 2019-11-27 10:35:45,666 INFO >> akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting >> down remote daemon. >> 2019-11-27 10:35:45,669 INFO >> akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote >> daemon shut down; proceeding with fl >> 2019-11-27 10:35:45,676 INFO >> akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting >> down remote daemon. >> 2019-11-27 10:35:45,677 INFO >> akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote >> daemon shut down; proceeding with fl >> 2019-11-27 10:35:45,696 INFO >> akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting >> shut down. >> 2019-11-27 10:35:45,696 INFO >> akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting >> shut down. >> 2019-11-27 10:35:45,709 INFO >> org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped >> Akka RPC service. >> 2019-11-27 10:35:45,713 INFO >> org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped >> Akka RPC service. >> 2019-11-27 10:35:45,714 ERROR >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Could not >> start cluster entrypoint YarnSess >> org.apache.flink.runtime.entrypoint.ClusterEntrypointException: Failed to >> initialize the cluster entrypoint YarnSessionClusterEntrypoint. >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:182) >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:501) >> at >> org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint.main(YarnSessionClusterEntrypoint.java:93) >> Caused by: org.apache.flink.util.FlinkException: Could not create the >> DispatcherResourceManagerComponent. >> at >> org.apache.flink.runtime.entrypoint.component.AbstractDispatcherResourceManagerComponentFactory.create(AbstractDispatcherResou >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:210) >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$0(ClusterEntrypoint.java:164) >> at java.security.AccessController.doPrivileged(Native Method) >> at javax.security.auth.Subject.doAs(Subject.java:422) >> at >> org.apache.hadoop.security.UserGroupInformat
Re:Re: flink on yarn 指定节点开启 yarn session 报错
tison 你好, 我netstat查看了想要指定的节点的端口情况,8082没有被占用。所以有点困惑这个报错。 在 2019-11-27 10:59:52,"tison" 写道: >8082 端口被占用了吧? > >Best, >tison. > > >杨浩程 于2019年11月27日周三 上午10:56写道: > >> 各位大佬好! >>请教各位个问题:使用的flink 版本1.9.0。测试flink on yarn 指定节点 开启yarn session 会话。 >>希望yarnsession开启的集群 jobmanager开启在我指定的节点上。 >>更改的配置如下: >> 报错信息如下: >> >> === >> 2019-11-27 10:35:45,640 INFO >> org.apache.flink.shaded.curator.org.apache.curator.framework.imps.CuratorFrameworkImpl >> - backgroundOperati >> 2019-11-27 10:35:45,650 INFO >> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.ZooKeeper - >> Session: 0x36ea133e2b51435 closed >> 2019-11-27 10:35:45,650 INFO >> org.apache.flink.shaded.zookeeper.org.apache.zookeeper.ClientCnxn - >> EventThread shut down for session: 0x3 >> 2019-11-27 10:35:45,651 INFO >> org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping >> Akka RPC service. >> 2019-11-27 10:35:45,659 INFO >> org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping >> Akka RPC service. >> 2019-11-27 10:35:45,666 INFO >> akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting >> down remote daemon. >> 2019-11-27 10:35:45,669 INFO >> akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote >> daemon shut down; proceeding with fl >> 2019-11-27 10:35:45,676 INFO >> akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting >> down remote daemon. >> 2019-11-27 10:35:45,677 INFO >> akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote >> daemon shut down; proceeding with fl >> 2019-11-27 10:35:45,696 INFO >> akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting >> shut down. >> 2019-11-27 10:35:45,696 INFO >> akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting >> shut down. >> 2019-11-27 10:35:45,709 INFO >> org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped >> Akka RPC service. >> 2019-11-27 10:35:45,713 INFO >> org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped >> Akka RPC service. >> 2019-11-27 10:35:45,714 ERROR >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Could not >> start cluster entrypoint YarnSess >> org.apache.flink.runtime.entrypoint.ClusterEntrypointException: Failed to >> initialize the cluster entrypoint YarnSessionClusterEntrypoint. >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:182) >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:501) >> at >> org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint.main(YarnSessionClusterEntrypoint.java:93) >> Caused by: org.apache.flink.util.FlinkException: Could not create the >> DispatcherResourceManagerComponent. >> at >> org.apache.flink.runtime.entrypoint.component.AbstractDispatcherResourceManagerComponentFactory.create(AbstractDispatcherResou >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:210) >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$0(ClusterEntrypoint.java:164) >> at java.security.AccessController.doPrivileged(Native Method) >> at javax.security.auth.Subject.doAs(Subject.java:422) >> at >> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1875) >> at >> org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) >> at >> org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:163) >> ... 2 more >> Caused by: java.net.BindException: Could not start rest endpoint on any >> port in port range 8082 >> at >> org.apache.flink.runtime.rest.RestServerEndpoint.start(RestServerEndpoint.java:219) >> at >> org.apache.flink.runtime.entrypoint.component.AbstractDispatcherResourceManagerComponentFactory.create(AbstractDispatcherResou >> ... 9 more >> >> End of LogType:jobmanager.log >> >> === >> 请问这种问题要怎么解决?多谢各位大佬! >> >> >> >>
flink on yarn 指定节点开启 yarn session 报错
各位大佬好! 请教各位个问题:使用的flink 版本1.9.0。测试flink on yarn 指定节点 开启yarn session 会话。 希望yarnsession开启的集群 jobmanager开启在我指定的节点上。 更改的配置如下: 报错信息如下: === 2019-11-27 10:35:45,640 INFO org.apache.flink.shaded.curator.org.apache.curator.framework.imps.CuratorFrameworkImpl - backgroundOperati 2019-11-27 10:35:45,650 INFO org.apache.flink.shaded.zookeeper.org.apache.zookeeper.ZooKeeper - Session: 0x36ea133e2b51435 closed 2019-11-27 10:35:45,650 INFO org.apache.flink.shaded.zookeeper.org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x3 2019-11-27 10:35:45,651 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service. 2019-11-27 10:35:45,659 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service. 2019-11-27 10:35:45,666 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 2019-11-27 10:35:45,669 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with fl 2019-11-27 10:35:45,676 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon. 2019-11-27 10:35:45,677 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with fl 2019-11-27 10:35:45,696 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting shut down. 2019-11-27 10:35:45,696 INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting shut down. 2019-11-27 10:35:45,709 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service. 2019-11-27 10:35:45,713 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service. 2019-11-27 10:35:45,714 ERROR org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Could not start cluster entrypoint YarnSess org.apache.flink.runtime.entrypoint.ClusterEntrypointException: Failed to initialize the cluster entrypoint YarnSessionClusterEntrypoint. at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:182) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:501) at org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint.main(YarnSessionClusterEntrypoint.java:93) Caused by: org.apache.flink.util.FlinkException: Could not create the DispatcherResourceManagerComponent. at org.apache.flink.runtime.entrypoint.component.AbstractDispatcherResourceManagerComponentFactory.create(AbstractDispatcherResou at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:210) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$0(ClusterEntrypoint.java:164) at java.security.AccessController.doPrivileged(Native Method) at javax.security.auth.Subject.doAs(Subject.java:422) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1875) at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:163) ... 2 more Caused by: java.net.BindException: Could not start rest endpoint on any port in port range 8082 at org.apache.flink.runtime.rest.RestServerEndpoint.start(RestServerEndpoint.java:219) at org.apache.flink.runtime.entrypoint.component.AbstractDispatcherResourceManagerComponentFactory.create(AbstractDispatcherResou ... 9 more End of LogType:jobmanager.log === 请问这种问题要怎么解决?多谢各位大佬!