首页
\
问答
\
Apache Storm＆Vagrant。(Apache Storm & Vagrant. org.apache.storm.utils.NimbusLeaderNotFoundException)
Apache Storm＆Vagrant。(Apache Storm & Vagrant. org.apache.storm.utils.NimbusLeaderNotFoundException)
我是Apache Storm和Vagrant的新手，我想在使用Vagrant构建的虚拟群集上部署我的拓扑。 不过，我经常从Storm UI获取
org.apache.storm.utils.NimbusLeaderNotFoundException：org.apache.storm.utils.NimbusLeaderNotFoundException: Could not find leader nimbus from seed hosts ["nimbus"]. Did you specify a valid list of nimbus hosts for config nimbus.seeds? at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:90) at org.apache.storm.ui.core$all_topologies_summary.invoke(core.clj:434) at org.apache.storm.ui.core$fn__12605.invoke(core.clj:952) at org.apache.storm.shade.compojure.core$make_route$fn__4631.invoke(core.clj:100) at org.apache.storm.shade.compojure.core$if_route$fn__4619.invoke(core.clj:46) at org.apache.storm.shade.compojure.core$if_method$fn__4612.invoke(core.clj:31) at org.apache.storm.shade.compojure.core$routing$fn__4637.invoke(core.clj:113) at clojure.core$some.invoke(core.clj:2570) at org.apache.storm.shade.compojure.core$routing.doInvoke(core.clj:113) at clojure.lang.RestFn.applyTo(RestFn.java:139) at clojure.core$apply.invoke(core.clj:632) at org.apache.storm.shade.compojure.core$routes$fn__4641.invoke(core.clj:118) at org.apache.storm.shade.ring.middleware.json$wrap_json_params$fn__12065.invoke(json.clj:56) at org.apache.storm.shade.ring.middleware.multipart_params$wrap_multipart_params$fn__5766.invoke(multipart_params.clj:118) at org.apache.storm.shade.ring.middleware.reload$wrap_reload$fn__11217.invoke(reload.clj:22) at org.apache.storm.ui.helpers$requests_middleware$fn__6019.invoke(helpers.clj:50) at org.apache.storm.ui.core$catch_errors$fn__12786.invoke(core.clj:1225) at org.apache.storm.shade.ring.middleware.keyword_params$wrap_keyword_params$fn__5686.invoke(keyword_params.clj:35) at org.apache.storm.shade.ring.middleware.nested_params$wrap_nested_params$fn__5729.invoke(nested_params.clj:84) at org.apache.storm.shade.ring.middleware.params$wrap_params$fn__5658.invoke(params.clj:64) at org.apache.storm.shade.ring.middleware.multipart_params$wrap_multipart_params$fn__5766.invoke(multipart_params.clj:118) at org.apache.storm.shade.ring.middleware.flash$wrap_flash$fn__5981.invoke(flash.clj:35) at org.apache.storm.shade.ring.middleware.session$wrap_session$fn__5967.invoke(session.clj:98) at org.apache.storm.shade.ring.util.servlet$make_service_method$fn__5516.invoke(servlet.clj:127) at org.apache.storm.shade.ring.util.servlet$servlet$fn__5520.invoke(servlet.clj:136) at org.apache.storm.shade.ring.util.servlet.proxy$javax.servlet.http.HttpServlet$ff19274a.service(Unknown Source) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:654) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1320) at org.apache.storm.logging.filters.AccessLoggingFilter.handle(AccessLoggingFilter.java:47) at org.apache.storm.logging.filters.AccessLoggingFilter.doFilter(AccessLoggingFilter.java:39) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1291) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93) at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28) at org.apache.storm.ui.helpers$x_frame_options_filter_handler$fn__6112.invoke(helpers.clj:189) at org.apache.storm.ui.helpers.proxy$java.lang.Object$Filter$abec9a8f.doFilter(Unknown Source) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1291) at org.apache.storm.shade.org.eclipse.jetty.servlets.CrossOriginFilter.handle(CrossOriginFilter.java:247) at org.apache.storm.shade.org.eclipse.jetty.servlets.CrossOriginFilter.doFilter(CrossOriginFilter.java:210) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1291) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:443) at org.apache.storm.shade.org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1044) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:372) at org.apache.storm.shade.org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:978) at org.apache.storm.shade.org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:135) at org.apache.storm.shade.org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:116) at org.apache.storm.shade.org.eclipse.jetty.server.Server.handle(Server.java:369) at org.apache.storm.shade.org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:486) at org.apache.storm.shade.org.eclipse.jetty.server.AbstractHttpConnection.headerComplete(AbstractHttpConnection.java:933) at org.apache.storm.shade.org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.headerComplete(AbstractHttpConnection.java:995) at org.apache.storm.shade.org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:644) at org.apache.storm.shade.org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:235) at org.apache.storm.shade.org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:82) at org.apache.storm.shade.org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:668) at org.apache.storm.shade.org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:52) at org.apache.storm.shade.org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608) at org.apache.storm.shade.org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543) at java.lang.Thread.run(Thread.java:745)这是nimbus机器上
nimbus.log文件的尾部：2017-02-10 11:35:12.768 o.a.s.s.o.a.z.ClientCnxn [INFO] Opening socket connection to server zookeeper/192.168.50.3:2181. Will not attempt to authenticate using SASL (unknown error) 2017-02-10 11:35:12.769 o.a.s.s.o.a.z.ClientCnxn [WARN] Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744) at org.apache.storm.shade.org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361) at org.apache.storm.shade.org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081)这里是我的配置回购： https : //github.com/alxg2112/storm-vagrant-cluster 。
请指教！
I'm new to Apache Storm and Vagrant and I want to deploy my topology on virtualized cluster built using Vagrant. However I'm constantly getting
org.apache.storm.utils.NimbusLeaderNotFoundExceptionfrom Storm UI:org.apache.storm.utils.NimbusLeaderNotFoundException: Could not find leader nimbus from seed hosts ["nimbus"]. Did you specify a valid list of nimbus hosts for config nimbus.seeds? at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:90) at org.apache.storm.ui.core$all_topologies_summary.invoke(core.clj:434) at org.apache.storm.ui.core$fn__12605.invoke(core.clj:952) at org.apache.storm.shade.compojure.core$make_route$fn__4631.invoke(core.clj:100) at org.apache.storm.shade.compojure.core$if_route$fn__4619.invoke(core.clj:46) at org.apache.storm.shade.compojure.core$if_method$fn__4612.invoke(core.clj:31) at org.apache.storm.shade.compojure.core$routing$fn__4637.invoke(core.clj:113) at clojure.core$some.invoke(core.clj:2570) at org.apache.storm.shade.compojure.core$routing.doInvoke(core.clj:113) at clojure.lang.RestFn.applyTo(RestFn.java:139) at clojure.core$apply.invoke(core.clj:632) at org.apache.storm.shade.compojure.core$routes$fn__4641.invoke(core.clj:118) at org.apache.storm.shade.ring.middleware.json$wrap_json_params$fn__12065.invoke(json.clj:56) at org.apache.storm.shade.ring.middleware.multipart_params$wrap_multipart_params$fn__5766.invoke(multipart_params.clj:118) at org.apache.storm.shade.ring.middleware.reload$wrap_reload$fn__11217.invoke(reload.clj:22) at org.apache.storm.ui.helpers$requests_middleware$fn__6019.invoke(helpers.clj:50) at org.apache.storm.ui.core$catch_errors$fn__12786.invoke(core.clj:1225) at org.apache.storm.shade.ring.middleware.keyword_params$wrap_keyword_params$fn__5686.invoke(keyword_params.clj:35) at org.apache.storm.shade.ring.middleware.nested_params$wrap_nested_params$fn__5729.invoke(nested_params.clj:84) at org.apache.storm.shade.ring.middleware.params$wrap_params$fn__5658.invoke(params.clj:64) at org.apache.storm.shade.ring.middleware.multipart_params$wrap_multipart_params$fn__5766.invoke(multipart_params.clj:118) at org.apache.storm.shade.ring.middleware.flash$wrap_flash$fn__5981.invoke(flash.clj:35) at org.apache.storm.shade.ring.middleware.session$wrap_session$fn__5967.invoke(session.clj:98) at org.apache.storm.shade.ring.util.servlet$make_service_method$fn__5516.invoke(servlet.clj:127) at org.apache.storm.shade.ring.util.servlet$servlet$fn__5520.invoke(servlet.clj:136) at org.apache.storm.shade.ring.util.servlet.proxy$javax.servlet.http.HttpServlet$ff19274a.service(Unknown Source) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:654) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1320) at org.apache.storm.logging.filters.AccessLoggingFilter.handle(AccessLoggingFilter.java:47) at org.apache.storm.logging.filters.AccessLoggingFilter.doFilter(AccessLoggingFilter.java:39) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1291) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:606) at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93) at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28) at org.apache.storm.ui.helpers$x_frame_options_filter_handler$fn__6112.invoke(helpers.clj:189) at org.apache.storm.ui.helpers.proxy$java.lang.Object$Filter$abec9a8f.doFilter(Unknown Source) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1291) at org.apache.storm.shade.org.eclipse.jetty.servlets.CrossOriginFilter.handle(CrossOriginFilter.java:247) at org.apache.storm.shade.org.eclipse.jetty.servlets.CrossOriginFilter.doFilter(CrossOriginFilter.java:210) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1291) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:443) at org.apache.storm.shade.org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1044) at org.apache.storm.shade.org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:372) at org.apache.storm.shade.org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:978) at org.apache.storm.shade.org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:135) at org.apache.storm.shade.org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:116) at org.apache.storm.shade.org.eclipse.jetty.server.Server.handle(Server.java:369) at org.apache.storm.shade.org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:486) at org.apache.storm.shade.org.eclipse.jetty.server.AbstractHttpConnection.headerComplete(AbstractHttpConnection.java:933) at org.apache.storm.shade.org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.headerComplete(AbstractHttpConnection.java:995) at org.apache.storm.shade.org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:644) at org.apache.storm.shade.org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:235) at org.apache.storm.shade.org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:82) at org.apache.storm.shade.org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:668) at org.apache.storm.shade.org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:52) at org.apache.storm.shade.org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608) at org.apache.storm.shade.org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543) at java.lang.Thread.run(Thread.java:745)Here is the tail of
nimbus.logfile on nimbus machine:2017-02-10 11:35:12.768 o.a.s.s.o.a.z.ClientCnxn [INFO] Opening socket connection to server zookeeper/192.168.50.3:2181. Will not attempt to authenticate using SASL (unknown error) 2017-02-10 11:35:12.769 o.a.s.s.o.a.z.ClientCnxn [WARN] Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744) at org.apache.storm.shade.org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361) at org.apache.storm.shade.org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081)Here is repo with my configuration: https://github.com/alxg2112/storm-vagrant-cluster.
Please advice!
原文：https://stackoverflow.com/questions/42158678
更新时间：2021-07-22 17:07
最满意答案
你可以从文档中读到
https://silviomoreto.github.io/bootstrap-select/methods/#selectpickerval
这样做的正确方法是
$('.selectpicker').selectpicker('val', 1);对于多个值，您可以添加值数组
$('.selectpicker').selectpicker('val', [1 , 2]);As you can read from documentation
https://silviomoreto.github.io/bootstrap-select/methods/#selectpickerval
The right way to do this would be
$('.selectpicker').selectpicker('val', 1);For multiple values you can add array of values
$('.selectpicker').selectpicker('val', [1 , 2]);
相关问答
更多-
bootstrap selectpicker：需要选择下拉列表(bootstrap selectpicker: Make a select drop down required)[2022-09-11]
使用html5的必需 对于laravel集体： 将array('required' => 'required')插入到表格集合第3个参数中 use html5's required你可以从文档中读到 https://silviomoreto.github.io/bootstrap-select/methods/#selectpickerval 这样做的正确方法是 $('.selectpicker').selectpicker('val', 1); 对于多个值，您可以添加值数组 $('.selectpicker').selectpicker('val', [1 , 2]); As you can read from documentation https://silviomoret ...如何设置多个bootstrap selectpicker的值？(How to set the values for multiple bootstrap selectpicker?)[2022-10-11]
尝试这个： $('#firstPicker').selectpicker('val', 'One'); //$('#firstPicker').selectpicker('refresh') $('#secondPicker').selectpicker('val', 'Four'); //$('#secondPicker').selectpicker('refresh') Try this: $('#firstPicker').selectpicker('val', 'One'); //$('#fir ...为你的页面声明一个模型类 public class ClassViewModel { public ListSelectedSchools {get; set;} public List Schools {get; set;} } 在控制器操作中设置选定的学校。 设置您的视图模型 @model ClassViewModel 然后在您的视图中使用此代码显示下拉列表 @Html.ListBoxFor(m=> m.SelectedSchools , Mo ... 这应该是诀窍： $('select[name=applicationSelect]').val() 如果使用参数指定val() ，则实际上是在设置值。 如果没有参数，该方法将只返回当前值。 您可以在此处找到更多信息。 This should do the trick: $('select[name=applicationSelect]').val() If you specify val() with a parameter, you are actually setting the value ...Jquery selectpicker默认选择框中的选定值(Jquery selectpicker default selected value from selectbox)[2023-02-21]
我试图搜索设置默认值选项，但我在seletpickers github上找不到任何关于它的信息。 我通过这段代码解决了我的问题。 ：selected给我们这个值。 我希望它会对某人有所帮助，有时候我们需要小修复而不是大修补。 var pets_name = $('#pets_name:selected').val(); I tried to search setting default value option but I couldn't find anything about it on seletp ...完成ajax请求后，应该刷新选择器。 从文档： 要以编程方式更新JavaScript的选择，首先操作选择，然后使用刷新方法更新UI以匹配新状态。 在删除或添加选项时，或通过JavaScript禁用/启用选择时，这是必需的。 完成ajax请求后，您需要刷新选择，并将其放在$ timeout中以进行角度重新渲染dom。 这里是一个例子： function getCompetences() { GatewayService.get('/competences') .then((data) => { ...如果你要做的就是选择＃p03选项然后$('#p03').prop('selected', true); 应该工作（而不是$('#preffrom').val('p03'); ）。 这是一个工作示例： https ： //jsfiddle.net/kwm9rsee/ If all you are trying to do is selected the #p03 option then $('#p03').prop('selected', true); should work (instead of $('# ...选中JQuery Bootstrap selectpicker on（'change'）设置(JQuery Bootstrap selectpicker on('change') set selected)[2023-01-29]
我认为这对你来说是一个解决方案，我把你的attr更改为prop insed并且改变了if if-statment。 不幸的是，data-max-options =“1”不起作用必须至少为data-max-options =“2”。 所以希望它有所帮助，你可以在这里找到jsfiddle： https ：//jsfiddle.net/txy4teks/1/ $('#choixVarX').on('change', function () { switch ($(this).val()) { ...找到了。 我有第二个jquery引用，它重新加载jquery并清除bootstrap-select.js添加的函数。 Found it. I had a second jquery reference that was re-loading jquery and wiping out the functions added by bootstrap-select.js.相关文章
更多- Apache Storm 衍生项目之1 -- storm-yarn
- Apache Storm技术实战之1 -- WordCountTopology
- storm
- storm
- Apache Storm技术实战之2 -- BasicDRPCTopology
- 如何使用vagrant在虚拟机安装Hadoop集群
- Apache Storm 衍生项目之2 -- Trident-ML
- storm demo
- Storm入门准备
- (二) storm的基本使用
最新问答
更多- 获取MVC 4使用的DisplayMode后缀(Get the DisplayMode Suffix being used by MVC 4)
- 如何通过引用返回对象？(How is returning an object by reference possible?)
- 矩阵如何存储在内存中？(How are matrices stored in memory?)
- 每个请求的Java新会话？(Java New Session For Each Request?)
- css：浮动div中重叠的标题h1(css: overlapping headlines h1 in floated divs)
- 无论图像如何，Caffe预测同一类(Caffe predicts same class regardless of image)
- xcode语法颜色编码解释？(xcode syntax color coding explained?)
- 在Access 2010 Runtime中使用Office 2000校对工具(Use Office 2000 proofing tools in Access 2010 Runtime)
- 从单独的Web主机将图像传输到服务器上(Getting images onto server from separate web host)
- 从旧版本复制文件并保留它们（旧/新版本）(Copy a file from old revision and keep both of them (old / new revision))
- 西安哪有PLC可控制编程的培训
- 在Entity Framework中选择基类(Select base class in Entity Framework)
- 在Android中出现错误“数据集和渲染器应该不为null，并且应该具有相同数量的系列”(Error “Dataset and renderer should be not null and should have the same number of series” in Android)
- 电脑二级VF有什么用
- Datamapper Ruby如何添加Hook方法(Datamapper Ruby How to add Hook Method)
- 金华英语角.
- 手机软件如何制作
- 用于Android webview中图像保存的上下文菜单(Context Menu for Image Saving in an Android webview)
- 注意：未定义的偏移量：PHP(Notice: Undefined offset: PHP)
- 如何读R中的大数据集[复制](How to read large dataset in R [duplicate])
- Unity 5 Heighmap与地形宽度/地形长度的分辨率关系？(Unity 5 Heighmap Resolution relationship to terrain width / terrain length?)
- 如何通知PipedOutputStream线程写入最后一个字节的PipedInputStream线程？(How to notify PipedInputStream thread that PipedOutputStream thread has written last byte?)
- python的访问器方法有哪些
- DeviceNetworkInformation：哪个是哪个？(DeviceNetworkInformation: Which is which?)
- 在Ruby中对组合进行排序(Sorting a combination in Ruby)
- 网站开发的流程？
- 使用Zend Framework 2中的JOIN sql检索数据(Retrieve data using JOIN sql in Zend Framework 2)
- 条带格式类型格式模式编号无法正常工作(Stripes format type format pattern number not working properly)
- 透明度错误IE11(Transparency bug IE11)
- linux的基本操作命令。。。