flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Zili Chen <wander4...@gmail.com>
Subject Re: Re: Re: Re: Re: flink1.9.0 LOCAL_WEBSERVER 问题
Date Fri, 23 Aug 2019 07:12:41 GMT
这个应该跟 1.9 使用了新版 WebUI 有关,我不太清楚。你可以到 JIRA 上提
issue 贴上 1.9 和之前版本的前后对比图让相关的
Flink 开发者帮忙看一下。

后面的问题,看源码发现的(x

Best,
tison.


hb <343122422@163.com> 于2019年8月23日周五 下午3:05写道:

> 请问 这个【配置项无效】 是在哪里看的, debug程序里看的么
>
>
>
>
>
>
>
>
> 在 2019-08-23 14:01:32,"Zili Chen" <wander4096@gmail.com> 写道:
> >我看看能不能怎么加依赖或者手动放网页文件来解决这个问题。
> >
> >另外,【配置项无效】是说,这个配置项在代码里没有用到,所以无论你怎么配,都不会对程序产生影响;而不是说,不管怎么配,都产生了
WebUI
> 无效的效果。
> >
> >Best,
> >tison.
> >
> >
> >Zili Chen <wander4096@gmail.com> 于2019年8月23日周五 下午2:59写道:
> >
> >> 喔,明白了,这个是因为你访问 /taskmanagers 是一个 REST 接口,Flink
的 WebUI
> 实际上是正常的,所以能正常的返回你。
> >>
> >> 你访问主页的时候,由于加载主页需要相应的 html 等文件,而
Flink 找不到,所以就告诉你 not found
> >>
> >> Best,
> >> tison.
> >>
> >>
> >> hb <343122422@163.com> 于2019年8月23日周五 下午2:51写道:
> >>
> >>> 个人理解,能通过这个端口访问restfull API 应该表示 这个设置生效了,但是首页却是404
> >>>
> >>>
> >>> 访问: http://localhost:8089/   404
> >>> 访问: http://localhost:8089/taskmanagers/
> >>> 正常:
> >>>
> >>>
> {"taskmanagers":[{"id":"ef7030d2-eb13-4c68-8d0c-20b3d59616c8","path":"akka://flink/user/taskmanager_0","dataPort":-1,"timeSinceLastHeartbeat":0,"slotsNumber":8,"freeSlots":0,"hardware":{"cpuCores":4,"physicalMemory":34359738368,"freeMemory":7635730432,"managedMemory":5338540032}}]}
> >>>
> >>>
> >>> 源码:
> >>> ```
> >>> package test
> >>>
> >>>
> >>> import org.apache.flink.configuration.{ConfigConstants, Configuration,
> >>> ResourceManagerOptions, RestOptions}
> >>> import org.apache.flink.streaming.api.functions.source.SourceFunction
> >>> import
> org.apache.flink.streaming.api.scala.{StreamExecutionEnvironment,
> >>> _}
> >>>
> >>>
> >>>
> >>>
> >>> object File1 extends App {
> >>>   class MySource extends SourceFunction[String] {
> >>>     override def run(sourceContext:
> >>> SourceFunction.SourceContext[String]): Unit = {
> >>>       for (i <- 1 to 1000) {
> >>>         sourceContext.collect(i.toString)
> >>>         Thread.sleep(10000)
> >>>       }
> >>>     }
> >>>     override def cancel(): Unit = {}
> >>>   }
> >>>
> >>>
> >>>
> >>>
> >>>   var config = new Configuration()
> >>>   config.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER, true)
> >>>
> >>>
> >>>   config.setInteger(RestOptions.PORT, 8089)
> >>>   val env = StreamExecutionEnvironment.createLocalEnvironment(8,
> config)
> >>>   env.addSource(new MySource).print()
> >>>
> >>>
> >>>   env.execute()
> >>> }
> >>> ```
> >>>
> >>>
> >>>
> >>>
> >>>
> >>>
> >>> 在 2019-08-23 13:41:36,"Zili Chen" <wander4096@gmail.com> 写道:
> >>> >源码里没有标为废弃应该是 FLINK 的一个 issue,你可以到
JIRA[1]上提,这个选项确实是没有用的。
> >>> >
> >>> >听起来你的程序是个测试程序,能提供相应的源码吗?如果你说后面能访问
/taskmanagers 的话可能并没有问题(x
> >>> >
> >>> >Best,
> >>> >tison.
> >>> >
> >>> >[1] https://issues.apache.org/jira/browse/
> >>> >
> >>> >
> >>> >hb <343122422@163.com> 于2019年8月23日周五 下午2:27写道:
> >>> >
> >>> >> 我在idea里 用maven 下载依赖,在idea里运行flink程序<br/><br/>源码里没有标志为废弃啊
> >>> >> <br/><br/>```<br/><br/>package
> >>> >> org.apache.flink.configuration<br/><br/>public final
class
> >>> ConfigConstants
> >>> >> {  ...<br/><br/>     /**<br/>         * @deprecated
Use {@link
> >>> >> ResourceManagerOptions#LOCAL_NUMBER_RESOURCE_MANAGER} instead.<br/>
> >>> >> */<br/>        @Deprecated<br/>        public static
final int
> >>> >> DEFAULT_LOCAL_NUMBER_RESOURCE_MANAGER = 1;<br/><br/><br/>
>  public
> >>> >> static final String LOCAL_START_WEBSERVER =
> >>> >> "local.start-webserver";<br/><br/>```
> >>> >> 在 2019-08-23 13:07:27,"Zili Chen" <wander4096@gmail.com>
写道:
> >>> >> >另外有个问题是,你是下载二进制 zip 还是从源码编译安装的?
> >>> >> >
> >>> >> >Best,
> >>> >> >tison.
> >>> >> >
> >>> >> >
> >>> >> >Zili Chen <wander4096@gmail.com> 于2019年8月23日周五
下午2:04写道:
> >>> >> >
> >>> >> >> 我切到了 1.9 的代码上看,这个 ConfigConstants.LOCAL_START_WEBSERVER
> >>> >> 应该是个废设置,设不设都没有任何效果。
> >>> >> >>
> >>> >> >> 所以问题应该跟这个选项没关系,比如你刷新
localhost:8089 能不能恢复?
> >>> >> >>
> >>> >> >> Best,
> >>> >> >> tison.
> >>> >> >>
> >>> >> >>
> >>> >> >> hb <343122422@163.com> 于2019年8月23日周五
下午1:47写道:
> >>> >> >>
> >>> >> >>> 1.9 版本之前,都是可以这么用的,正常的,1.9也是有这个API的啊
> >>> >> >>> 在 2019-08-23 12:28:14,"Zili Chen" <wander4096@gmail.com>
写道:
> >>> >> >>> >你是在哪看到这个配置的,我查了下代码甚至这个选项都没有使用点(x
> >>> >> >>> >
> >>> >> >>> >Best,
> >>> >> >>> >tison.
> >>> >> >>> >
> >>> >> >>> >
> >>> >> >>> >hb <343122422@163.com> 于2019年8月23日周五
下午1:22写道:
> >>> >> >>> >
> >>> >> >>> >> flink1.9.0 下 本地web 页面主页404,代码:
> >>> >> >>> >> ```
> >>> >> >>> >> var config = new Configuration()
> >>> >> >>> >> config.setBoolean(ConfigConstants.LOCAL_START_WEBSERVER,
> true)
> >>> >> >>> >>
> >>> >> >>> >> config.setInteger(RestOptions.PORT, 8089)
> >>> >> >>> >> val env =
> StreamExecutionEnvironment.createLocalEnvironment(8,
> >>> >> config)
> >>> >> >>> >> ```
> >>> >> >>> >> 打开 http://localhost:8089/ 显示
> >>> >> >>> >> {"errors":["Not found."]}
> >>> >> >>> >> 打开 http://localhost:8089/taskmanagers/
能正常显示
> >>> >> >>>
> >>> >> >>
> >>> >>
> >>>
> >>
>
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message