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: "*"
