"service.host": "",
"service.port": ""

Please configure them. An app config will override server config.


Best Regards,
Qingwen Zhao | 赵晴雯




2017-05-16 16:31 GMT+08:00 丁逸秋 <[email protected]>:

> 1.My network not issue
> 2.My app configuration(Hadoop Metrics Monitor):
> {
> "dataSinkConfig.HADOOP_JMX_METRIC_STREAM.topic":
> "hadoop_jmx_metric_sandbox",
> "dataSinkConfig.SYSTEM_METRIC_STREAM.topic": "system_metric_sandbox",
> "dataSinkConfig.HADOOP_JMX_RESOURCE_STREAM.topic":
> "hadoop_jmx_resource_sandbox",
> "dataSinkConfig.brokerList":
> "datanode01:9092,datanode02:9092,datanode03:9092",
> "dataSourceConfig.zkConnection":
> "datanode01:2181,datanode02:2181,datanode03:2181",
> "dataSourceConfig.fetchSize": "1048576",
> "dataSourceConfig.transactionZKRoot": "/consumers",
> "dataSourceConfig.consumerGroupId": "eagleConsumer",
> "dataSourceConfig.brokerZkPath": "",
> "dataSourceConfig.txZkServers":
> "datanode01:2181,datanode02:2181,datanode03:2181",
> "dataSourceConfig.transactionStateUpdateMS": "2000",
> "service.host": "",
> "service.port": ""
> }
>
> kafka' data is I use cron timed call
> "hadoop_jmx_kafka.py"&"system_metric_collector.py" ,
> although storm  report exception,but 0 failed.
> 3. I query reply data:
> {
>     "meta": {
>         "firstTimestamp": 0,
>         "totalResults": 0,
>         "lastTimestamp": 0,
>         "elapsedms": 15
>     },
>     "success": true,
>     "obj": [],
>     "type": "org.apache.eagle.metadata.model.MetricSchemaEntity"
> }
>
> Please help me.
> Thank you so much.
>
> 2017-05-16 16:18 GMT+08:00 Zhao Qingwen <[email protected]>:
>
> > Hi
> >
> > How about network issue?
> >
> > 1. first check your app configuration, make sure it's all right
> > 2. test using the following query
> >     http://{eagle server host}:{eagle server
> > port}/rest/entities?query=MetricSchemaService[]{*}&pageSize=1
> >
> >
> > Best Regards,
> > Qingwen Zhao | 赵晴雯
> >
> >
> >
> >
> > 2017-05-16 14:56 GMT+08:00 丁逸秋 <[email protected]>:
> >
> > > 1.My eagle service is up.
> > > 2.My Hbase is based on Zookeeper deploy,and I look hbase table, some
> data
> > > is stored into the(for example:alert_detail, eagle_metric).
> > > 3.I see eagle's log, no signs of error.
> > >
> > > Please help me.
> > > Thank you so much.
> > >
> > > 2017-05-16 14:32 GMT+08:00 Zhao Qingwen <[email protected]>:
> > >
> > > > This log shows writing database failed.
> > > >
> > > > 1. make sure Eagle server is up
> > > > 2. If you use HBase as the deep storage, please zookeeper is
> connected
> > &
> > > > hbase access is ok.  You can check Eagle server log.
> > > >
> > > >
> > > > For the second question, please ignore it. HealthCheck is an
> interface
> > to
> > > > help an application monitor itself, for example, whether the
> processed
> > > data
> > > > is delayed. This warning log tells you these applications do not
> > > implement
> > > > the interface.
> > > >
> > > >
> > > >
> > > > Best Regards,
> > > > Qingwen Zhao | 赵晴雯
> > > >
> > > >
> > > >
> > > >
> > > > 2017-05-16 13:58 GMT+08:00 丁逸秋 <[email protected]>:
> > > >
> > > > > Hi
> > > > > I use your opinion to use HBase0.98.24-hadoop2  version.But the
> > > previous
> > > > > three issues are still not resolved.
> > > > > I see log ,Have the following questions, please help:
> > > > > 1.On Storm HADOOP_METRIC_MONITOR_${SITE}:
> > > > > MetricDataSink_2,MetricDataSink_6,MetricSchemaGenerator_3,
> > > > > MetricSchemaGenerator_7
> > > > > tip exception:
> > > > > com.sun.jersey.api.client.ClientHandlerException:
> > > > > java.net.ConnectException: Connection refused (Connection refused)
> at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler.
> > > > > handle(URLConnec
> > > > > I see log:
> > > > > 2017-05-16T13:08:03.915+0800 o.a.e.a.m.MetricStreamPersist [ERROR]
> > > > > java.net.ConnectException: Connection refused (Connection refused)
> > > > > com.sun.jersey.api.client.ClientHandlerException:
> > > > > java.net.ConnectException: Connection refused (Connection refused)
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler.
> > handle(
> > > > > URLConnectionClientHandler.java:155)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.filter.GZIPContentEncodingFilter.handle(
> > > > > GZIPContentEncodingFilter.java:123)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.Client.handle(Client.java:652)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.WebResource.handle(
> > WebResource.java:682)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.WebResource.access$200(
> > > WebResource.java:74)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.WebResource$Builder.post(
> > > > > WebResource.java:570)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.service.client.impl.EagleServiceBaseClient.
> > > > > postEntitiesWithService(EagleServiceBaseClient.java:219)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.service.client.impl.
> EagleServiceClientImpl.create(
> > > > > EagleServiceClientImpl.java:96)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.service.client.impl.
> EagleServiceClientImpl.create(
> > > > > EagleServiceClientImpl.java:115)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.app.messaging.MetricStreamPersist.
> > > > > execute(MetricStreamPersist.java:86)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > backtype.storm.daemon.executor$fn__3439$tuple_
> > action_fn__3441.invoke(
> > > > > executor.clj:640)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.daemon.executor$mk_task_receiver$fn__
> > > > > 3362.invoke(executor.clj:407)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.disruptor$clojure_handler$reify__1445.
> > > > > onEvent(disruptor.clj:58)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(
> > > > > DisruptorQueue.java:132)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(
> > > > > DisruptorQueue.java:106)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.disruptor$consume_batch_when_available.
> > > > > invoke(disruptor.clj:80)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.daemon.executor$fn__3439$fn__3451$fn_
> > > > > _3498.invoke(executor.clj:755)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at backtype.storm.util$async_loop$fn__460.invoke(util.clj:463)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
> > > > > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_121]
> > > > > Caused by: java.net.ConnectException: Connection refused
> (Connection
> > > > > refused)
> > > > > at java.net.PlainSocketImpl.socketConnect(Native Method)
> > > ~[na:1.8.0_121]
> > > > > at
> > > > > java.net.AbstractPlainSocketImpl.doConnect(
> > > AbstractPlainSocketImpl.java:
> > > > > 350)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > java.net.AbstractPlainSocketImpl.connectToAddress(
> > > > > AbstractPlainSocketImpl.java:206)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > java.net.AbstractPlainSocketImpl.connect(
> > AbstractPlainSocketImpl.java:
> > > > 188)
> > > > > ~[na:1.8.0_121]
> > > > > at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
> > > > > ~[na:1.8.0_121]
> > > > > at java.net.Socket.connect(Socket.java:589) ~[na:1.8.0_121]
> > > > > at sun.net.NetworkClient.doConnect(NetworkClient.java:175)
> > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.openServer(HttpClient.java:432)
> > > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.openServer(HttpClient.java:527)
> > > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.<init>(HttpClient.java:211)
> > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.New(HttpClient.java:308)
> > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.New(HttpClient.java:326)
> > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(
> > > > > HttpURLConnection.java:1202)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.plainConnect0(
> > > > > HttpURLConnection.java:1138)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.plainConnect(
> > > > > HttpURLConnection.java:1032)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.connect(
> > > > > HttpURLConnection.java:966)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(
> > > > > HttpURLConnection.java:1316)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.getOutputStream(
> > > > > HttpURLConnection.java:1291)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler$1$
> > > > > 1.getOutputStream(URLConnectionClientHandler.java:238)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.CommittingOutputStream.commitStream(
> > > > > CommittingOutputStream.java:117)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.CommittingOutputStream.write(
> > > > > CommittingOutputStream.java:83)
> > > > > ~[stormjar.jar:na]
> > > > > at java.util.zip.GZIPOutputStream.writeHeader(
> > > GZIPOutputStream.java:182)
> > > > > ~[na:1.8.0_121]
> > > > > at java.util.zip.GZIPOutputStream.<init>(GZIPOutputStream.java:94)
> > > > > ~[na:1.8.0_121]
> > > > > at java.util.zip.GZIPOutputStream.<init>(
> GZIPOutputStream.java:109)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > com.sun.jersey.api.client.filter.GZIPContentEncodingFilter$
> > > > Adapter.adapt(
> > > > > GZIPContentEncodingFilter.java:81)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.RequestWriter.writeRequestEntity(
> > > > > RequestWriter.java:298)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler._
> > > invoke(
> > > > > URLConnectionClientHandler.java:217)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler.
> > handle(
> > > > > URLConnectionClientHandler.java:153)
> > > > > ~[stormjar.jar:na]
> > > > > ... 19 common frames omitted
> > > > > 2017-05-16T13:08:03.924+0800 b.s.d.executor [ERROR]
> > > > > com.sun.jersey.api.client.ClientHandlerException:
> > > > > java.net.ConnectException: Connection refused (Connection refused)
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler.
> > handle(
> > > > > URLConnectionClientHandler.java:155)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.filter.GZIPContentEncodingFilter.handle(
> > > > > GZIPContentEncodingFilter.java:123)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.Client.handle(Client.java:652)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.WebResource.handle(
> > WebResource.java:682)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.WebResource.access$200(
> > > WebResource.java:74)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.WebResource$Builder.post(
> > > > > WebResource.java:570)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.service.client.impl.EagleServiceBaseClient.
> > > > > postEntitiesWithService(EagleServiceBaseClient.java:219)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.service.client.impl.
> EagleServiceClientImpl.create(
> > > > > EagleServiceClientImpl.java:96)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.service.client.impl.
> EagleServiceClientImpl.create(
> > > > > EagleServiceClientImpl.java:115)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.app.messaging.MetricStreamPersist.
> > > > > execute(MetricStreamPersist.java:86)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > backtype.storm.daemon.executor$fn__3439$tuple_
> > action_fn__3441.invoke(
> > > > > executor.clj:640)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.daemon.executor$mk_task_receiver$fn__
> > > > > 3362.invoke(executor.clj:407)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.disruptor$clojure_handler$reify__1445.
> > > > > onEvent(disruptor.clj:58)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(
> > > > > DisruptorQueue.java:132)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(
> > > > > DisruptorQueue.java:106)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.disruptor$consume_batch_when_available.
> > > > > invoke(disruptor.clj:80)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.daemon.executor$fn__3439$fn__3451$fn_
> > > > > _3498.invoke(executor.clj:755)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at backtype.storm.util$async_loop$fn__460.invoke(util.clj:463)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
> > > > > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_121]
> > > > > Caused by: java.net.ConnectException: Connection refused
> (Connection
> > > > > refused)
> > > > > at java.net.PlainSocketImpl.socketConnect(Native Method)
> > > ~[na:1.8.0_121]
> > > > > at
> > > > > java.net.AbstractPlainSocketImpl.doConnect(
> > > AbstractPlainSocketImpl.java:
> > > > > 350)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > java.net.AbstractPlainSocketImpl.connectToAddress(
> > > > > AbstractPlainSocketImpl.java:206)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > java.net.AbstractPlainSocketImpl.connect(
> > AbstractPlainSocketImpl.java:
> > > > 188)
> > > > > ~[na:1.8.0_121]
> > > > > at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
> > > > > ~[na:1.8.0_121]
> > > > > at java.net.Socket.connect(Socket.java:589) ~[na:1.8.0_121]
> > > > > at sun.net.NetworkClient.doConnect(NetworkClient.java:175)
> > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.openServer(HttpClient.java:432)
> > > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.openServer(HttpClient.java:527)
> > > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.<init>(HttpClient.java:211)
> > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.New(HttpClient.java:308)
> > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.New(HttpClient.java:326)
> > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(
> > > > > HttpURLConnection.java:1202)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.plainConnect0(
> > > > > HttpURLConnection.java:1138)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.plainConnect(
> > > > > HttpURLConnection.java:1032)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.connect(
> > > > > HttpURLConnection.java:966)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(
> > > > > HttpURLConnection.java:1316)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.getOutputStream(
> > > > > HttpURLConnection.java:1291)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler$1$
> > > > > 1.getOutputStream(URLConnectionClientHandler.java:238)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.CommittingOutputStream.commitStream(
> > > > > CommittingOutputStream.java:117)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.CommittingOutputStream.write(
> > > > > CommittingOutputStream.java:83)
> > > > > ~[stormjar.jar:na]
> > > > > at java.util.zip.GZIPOutputStream.writeHeader(
> > > GZIPOutputStream.java:182)
> > > > > ~[na:1.8.0_121]
> > > > > at java.util.zip.GZIPOutputStream.<init>(GZIPOutputStream.java:94)
> > > > > ~[na:1.8.0_121]
> > > > > at java.util.zip.GZIPOutputStream.<init>(
> GZIPOutputStream.java:109)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > com.sun.jersey.api.client.filter.GZIPContentEncodingFilter$
> > > > Adapter.adapt(
> > > > > GZIPContentEncodingFilter.java:81)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.RequestWriter.writeRequestEntity(
> > > > > RequestWriter.java:298)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler._
> > > invoke(
> > > > > URLConnectionClientHandler.java:217)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler.
> > handle(
> > > > > URLConnectionClientHandler.java:153)
> > > > > ~[stormjar.jar:na]
> > > > > ... 19 common frames omitted
> > > > > 2017-05-16T13:08:03.922+0800 o.a.e.a.m.MetricStreamPersist [ERROR]
> > > > > java.net.ConnectException: Connection refused (Connection refused)
> > > > > com.sun.jersey.api.client.ClientHandlerException:
> > > > > java.net.ConnectException: Connection refused (Connection refused)
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler.
> > handle(
> > > > > URLConnectionClientHandler.java:155)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.filter.GZIPContentEncodingFilter.handle(
> > > > > GZIPContentEncodingFilter.java:123)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.Client.handle(Client.java:652)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.WebResource.handle(
> > WebResource.java:682)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.WebResource.access$200(
> > > WebResource.java:74)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.WebResource$Builder.post(
> > > > > WebResource.java:570)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.service.client.impl.EagleServiceBaseClient.
> > > > > postEntitiesWithService(EagleServiceBaseClient.java:219)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.service.client.impl.
> EagleServiceClientImpl.create(
> > > > > EagleServiceClientImpl.java:96)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.service.client.impl.
> EagleServiceClientImpl.create(
> > > > > EagleServiceClientImpl.java:115)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.app.messaging.MetricStreamPersist.
> > > > > execute(MetricStreamPersist.java:86)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > backtype.storm.daemon.executor$fn__3439$tuple_
> > action_fn__3441.invoke(
> > > > > executor.clj:640)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.daemon.executor$mk_task_receiver$fn__
> > > > > 3362.invoke(executor.clj:407)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.disruptor$clojure_handler$reify__1445.
> > > > > onEvent(disruptor.clj:58)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(
> > > > > DisruptorQueue.java:132)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(
> > > > > DisruptorQueue.java:106)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.disruptor$consume_batch_when_available.
> > > > > invoke(disruptor.clj:80)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.daemon.executor$fn__3439$fn__3451$fn_
> > > > > _3498.invoke(executor.clj:755)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at backtype.storm.util$async_loop$fn__460.invoke(util.clj:463)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
> > > > > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_121]
> > > > > Caused by: java.net.ConnectException: Connection refused
> (Connection
> > > > > refused)
> > > > > at java.net.PlainSocketImpl.socketConnect(Native Method)
> > > ~[na:1.8.0_121]
> > > > > at
> > > > > java.net.AbstractPlainSocketImpl.doConnect(
> > > AbstractPlainSocketImpl.java:
> > > > > 350)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > java.net.AbstractPlainSocketImpl.connectToAddress(
> > > > > AbstractPlainSocketImpl.java:206)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > java.net.AbstractPlainSocketImpl.connect(
> > AbstractPlainSocketImpl.java:
> > > > 188)
> > > > > ~[na:1.8.0_121]
> > > > > at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
> > > > > ~[na:1.8.0_121]
> > > > > at java.net.Socket.connect(Socket.java:589) ~[na:1.8.0_121]
> > > > > at sun.net.NetworkClient.doConnect(NetworkClient.java:175)
> > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.openServer(HttpClient.java:432)
> > > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.openServer(HttpClient.java:527)
> > > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.<init>(HttpClient.java:211)
> > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.New(HttpClient.java:308)
> > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.New(HttpClient.java:326)
> > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(
> > > > > HttpURLConnection.java:1202)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.plainConnect0(
> > > > > HttpURLConnection.java:1138)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.plainConnect(
> > > > > HttpURLConnection.java:1032)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.connect(
> > > > > HttpURLConnection.java:966)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(
> > > > > HttpURLConnection.java:1316)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.getOutputStream(
> > > > > HttpURLConnection.java:1291)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler$1$
> > > > > 1.getOutputStream(URLConnectionClientHandler.java:238)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.CommittingOutputStream.commitStream(
> > > > > CommittingOutputStream.java:117)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.CommittingOutputStream.write(
> > > > > CommittingOutputStream.java:83)
> > > > > ~[stormjar.jar:na]
> > > > > at java.util.zip.GZIPOutputStream.writeHeader(
> > > GZIPOutputStream.java:182)
> > > > > ~[na:1.8.0_121]
> > > > > at java.util.zip.GZIPOutputStream.<init>(GZIPOutputStream.java:94)
> > > > > ~[na:1.8.0_121]
> > > > > at java.util.zip.GZIPOutputStream.<init>(
> GZIPOutputStream.java:109)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > com.sun.jersey.api.client.filter.GZIPContentEncodingFilter$
> > > > Adapter.adapt(
> > > > > GZIPContentEncodingFilter.java:81)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.RequestWriter.writeRequestEntity(
> > > > > RequestWriter.java:298)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler._
> > > invoke(
> > > > > URLConnectionClientHandler.java:217)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler.
> > handle(
> > > > > URLConnectionClientHandler.java:153)
> > > > > ~[stormjar.jar:na]
> > > > > ... 19 common frames omitted
> > > > > 2017-05-16T13:08:03.931+0800 b.s.d.executor [ERROR]
> > > > > com.sun.jersey.api.client.ClientHandlerException:
> > > > > java.net.ConnectException: Connection refused (Connection refused)
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler.
> > handle(
> > > > > URLConnectionClientHandler.java:155)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.filter.GZIPContentEncodingFilter.handle(
> > > > > GZIPContentEncodingFilter.java:123)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.Client.handle(Client.java:652)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.WebResource.handle(
> > WebResource.java:682)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.WebResource.access$200(
> > > WebResource.java:74)
> > > > > ~[stormjar.jar:na]
> > > > > at com.sun.jersey.api.client.WebResource$Builder.post(
> > > > > WebResource.java:570)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.service.client.impl.EagleServiceBaseClient.
> > > > > postEntitiesWithService(EagleServiceBaseClient.java:219)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.service.client.impl.
> EagleServiceClientImpl.create(
> > > > > EagleServiceClientImpl.java:96)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.service.client.impl.
> EagleServiceClientImpl.create(
> > > > > EagleServiceClientImpl.java:115)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > org.apache.eagle.app.messaging.MetricStreamPersist.
> > > > > execute(MetricStreamPersist.java:86)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > backtype.storm.daemon.executor$fn__3439$tuple_
> > action_fn__3441.invoke(
> > > > > executor.clj:640)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.daemon.executor$mk_task_receiver$fn__
> > > > > 3362.invoke(executor.clj:407)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.disruptor$clojure_handler$reify__1445.
> > > > > onEvent(disruptor.clj:58)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(
> > > > > DisruptorQueue.java:132)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(
> > > > > DisruptorQueue.java:106)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.disruptor$consume_batch_when_available.
> > > > > invoke(disruptor.clj:80)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at
> > > > > backtype.storm.daemon.executor$fn__3439$fn__3451$fn_
> > > > > _3498.invoke(executor.clj:755)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at backtype.storm.util$async_loop$fn__460.invoke(util.clj:463)
> > > > > [storm-core-0.9.7.jar:0.9.7]
> > > > > at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
> > > > > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_121]
> > > > > Caused by: java.net.ConnectException: Connection refused
> (Connection
> > > > > refused)
> > > > > at java.net.PlainSocketImpl.socketConnect(Native Method)
> > > ~[na:1.8.0_121]
> > > > > at
> > > > > java.net.AbstractPlainSocketImpl.doConnect(
> > > AbstractPlainSocketImpl.java:
> > > > > 350)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > java.net.AbstractPlainSocketImpl.connectToAddress(
> > > > > AbstractPlainSocketImpl.java:206)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > java.net.AbstractPlainSocketImpl.connect(
> > AbstractPlainSocketImpl.java:
> > > > 188)
> > > > > ~[na:1.8.0_121]
> > > > > at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
> > > > > ~[na:1.8.0_121]
> > > > > at java.net.Socket.connect(Socket.java:589) ~[na:1.8.0_121]
> > > > > at sun.net.NetworkClient.doConnect(NetworkClient.java:175)
> > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.openServer(HttpClient.java:432)
> > > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.openServer(HttpClient.java:527)
> > > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.<init>(HttpClient.java:211)
> > > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.New(HttpClient.java:308)
> > > ~[na:1.8.0_121]
> > > > > at sun.net.www.http.HttpClient.New(HttpClient.java:326)
> > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(
> > > > > HttpURLConnection.java:1202)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.plainConnect0(
> > > > > HttpURLConnection.java:1138)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.plainConnect(
> > > > > HttpURLConnection.java:1032)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.connect(
> > > > > HttpURLConnection.java:966)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.getOutputStream0(
> > > > > HttpURLConnection.java:1316)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > sun.net.www.protocol.http.HttpURLConnection.getOutputStream(
> > > > > HttpURLConnection.java:1291)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler$1$
> > > > > 1.getOutputStream(URLConnectionClientHandler.java:238)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.CommittingOutputStream.commitStream(
> > > > > CommittingOutputStream.java:117)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.CommittingOutputStream.write(
> > > > > CommittingOutputStream.java:83)
> > > > > ~[stormjar.jar:na]
> > > > > at java.util.zip.GZIPOutputStream.writeHeader(
> > > GZIPOutputStream.java:182)
> > > > > ~[na:1.8.0_121]
> > > > > at java.util.zip.GZIPOutputStream.<init>(GZIPOutputStream.java:94)
> > > > > ~[na:1.8.0_121]
> > > > > at java.util.zip.GZIPOutputStream.<init>(
> GZIPOutputStream.java:109)
> > > > > ~[na:1.8.0_121]
> > > > > at
> > > > > com.sun.jersey.api.client.filter.GZIPContentEncodingFilter$
> > > > Adapter.adapt(
> > > > > GZIPContentEncodingFilter.java:81)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.api.client.RequestWriter.writeRequestEntity(
> > > > > RequestWriter.java:298)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler._
> > > invoke(
> > > > > URLConnectionClientHandler.java:217)
> > > > > ~[stormjar.jar:na]
> > > > > at
> > > > > com.sun.jersey.client.urlconnection.URLConnectionClientHandler.
> > handle(
> > > > > URLConnectionClientHandler.java:153)
> > > > > ~[stormjar.jar:na]
> > > > > ... 19 common frames omitted
> > > > > ....
> > > > > 2.on eagle eagle-server.log:
> > > > > I see it occasionally:
> > > > > WARN  [2017-05-16 05:50:37,612]
> > > > > org.apache.eagle.app.service.impl.ApplicationHealthCheckServiceI
> mpl:
> > > > > Application SYSTEM_METRIC_WEB_APP_SANDBOX does not implement
> > > HealthCheck
> > > > > WARN  [2017-05-16 05:50:37,612]
> > > > > org.apache.eagle.app.service.impl.ApplicationHealthCheckServiceI
> mpl:
> > > > > Application HDFS_METRIC_WEB_APP_SANDBOX does not implement
> > HealthCheck
> > > > > WARN  [2017-05-16 05:50:37,612]
> > > > > org.apache.eagle.app.service.impl.ApplicationHealthCheckServiceI
> mpl:
> > > > > Application HADOOP_METRIC_MONITOR_SANDBOX does not implement
> > > HealthCheck
> > > > > WARN  [2017-05-16 05:50:37,612]
> > > > > org.apache.eagle.app.service.impl.ApplicationHealthCheckServiceI
> mpl:
> > > > > Application HDFS_AUDIT_LOG_MONITOR_APP_SANDBOX does not implement
> > > > > HealthCheck
> > > > > WARN  [2017-05-16 05:50:37,612]
> > > > > org.apache.eagle.app.service.impl.ApplicationHealthCheckServiceI
> mpl:
> > > > > Application ALERT_UNIT_TOPOLOGY_APP_SANDBOX does not implement
> > > > HealthCheck
> > > > > The above is the result of my log,please help me.
> > > > > Thank you so much.
> > > > >
> > > >
> > >
> >
>

Reply via email to