[GRIFFIN-238] try to write metric into elasticsearch, but fail to call post api

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.4.0
• Fix Version/s: 0.5.0
• Component/s: accuracy-batch
• Assignee: Eugene
• Reporter: Eugene
• Created: 13/Mar/19 08:55
• Updated: 11/Apr/19 01:13
• Resolved: 20/Mar/19 06:43

Description

when a batch job was scheduled in spark cluster, the last step is saving metric into ES sink. but we hit exception like below

 

19/03/05 16:22:03 WARN sink.SinkTaskRunner$: task 1551769200000 fails [ using time 0 ms ] : org.apache.hadoop.fs.FsUrlConnection:http://127.0.0.1:9200/griffin/accuracy (of class org.apache.hadoop.fs.FsUrlConnection)
19/03/05 16:22:03 ERROR sink.SinkTaskRunner$: task fails: task 1551769200000 retry ends but fails
scala.MatchError: org.apache.hadoop.fs.FsUrlConnection:http://127.0.0.1:9200/griffin/accuracy (of class org.apache.hadoop.fs.FsUrlConnection)
    at scalaj.http.HttpRequest.scalaj$http$HttpRequest$$doConnection(Http.scala:343)
    at scalaj.http.HttpRequest.exec(Http.scala:335)
    at scalaj.http.HttpRequest.asString(Http.scala:455)
    at org.apache.griffin.measure.utils.HttpUtil$.httpRequest(HttpUtil.scala:49)
    at org.apache.griffin.measure.sink.ElasticSearchSink$$anonfun$org$apache$griffin$measure$sink$ElasticSearchSink$$func$1$1.apply$mcZ$sp(ElasticSearchSink.scala:67)