在火花流式传输期间无法将数据帧保存到 Elasticsearch

Question

在 Spark Stream 处理和将数据帧保存到 Elastic Search 期间面临以下错误：

org.elasticsearch.hadoop.EsHadoopIllegalArgumentException: Cannot determine write shards for [custAct_index/custAct_index_type]; 
    likely its format is incorrect (maybe it contains illegal characters?)

Answer 1

弹性搜索索引应使用小写字母。 使用 [custact_index/custact_index_type] 而不是 [custAct_index/custAct_index_type]。