Do you know how to solve scala.MatchError

[Eugene Liu <li...@apache.org>]

Hi,

recently I have hit a problem when griffin task tries to write result into elasticsearch.

http://127.0.0.1:9200/griffin/accuracy (of class org.apache.hadoop.fs.FsUrlConnection)
19/03/05 15:54:20 ERROR sink.SinkTaskRunner$: task fails: task 1551768000000 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)

but I manually call ES rest api, it works well
/apache/griffin$ curl -i -H "Content-Type: application/json" -X POST http://127.0.0.1:9200/griffin/accuracy -d '{"griffin": true}'
HTTP/1.1 201 Created
Location: /griffin/accuracy/0oPnTGkBwDXqtjrq46Hg
content-type: application/json; charset=UTF-8
content-length: 178

{"_index":"griffin","_type":"accuracy","_id":"0oPnTGkBwDXqtjrq46Hg","_version":1,"result":"created","_shards":{"total":3,"successful":1,"failed":0},"_seq_no":0,"_primary_term":9}

I see there is similar bug in spark inventory, but I'm not sure.
https://issues.apache.org/jira/browse/SPARK-25694?page=com.atlassian.jira.plugin.system.issuetabpanels%3Aall-tabpanel


do you guys have any idea to address?

ES.YML

network.host: 127.0.0.1
http.cors.enabled: true
http.cors.allow-origin: "*"