We use es-hadoop in our storm topo, and get the index name from the data being streamed to Elasticsearch according to the doc.
Unfortunately, It always report an error, the variable does not exist.
My code is like
and the error is like:
I am sure I had send one json object to the 'EsBolt' and with a variable 'instance_id'.
Help me please.