Cannot Save Data Frame to Elasticsearch during spark streaming

Hi All,
please help me , i am getting below error while saving dataframe to Elastic search while spark streaming:

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

Below is the Gist for the Error I am facing:

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.