[ES Input]Caused by: org.elasticsearch.hadoop.EsHadoopIllegalArgumentException: Cannot invoke method public org.joda.time.DateTime org.joda.time.format.DateTimeFormatter.parseDateTime(java.lang.String)

[garyelephant]

ES Input 报错：

Caused by: org.elasticsearch.hadoop.EsHadoopIllegalArgumentException: Cannot invoke method public org.joda.time.DateTime org.joda.time.format.DateTimeFormatter.parseDateTime(java.lang.String)

发现是index中date类型的mapping设置如下：

"stat_time": {
    "type": "date",
     "format": "yyyy-MM-dd HH:mm:ss"
},

问题原因是ES-Hadoop date格式数据解析仅支持ISO8601 格式的，举例：yyyy-MM-dd'T'HH:mm:ss.SSSZZ，这个格式会解析报错yyyy-MM-dd HH:mm:ss.

解决方案是：

input {
  es {
    ...
    es.mapping.date.rich = false
    ...
  }
}