Hi Tauseef,
This error is because your Class
com.hds.alta.pipeline.model.TopologyDTO cannot be serialized by ES
xcontent util.
The following solutions may fix it.
1. convert your TopologyDTO class data to a Map, and avoid using some
custom Class that cannot be serialized by ES.
or 2. make your
Hi Tauseef,
We cannot directly write POJO types into Elasticsearch.
You can try serializing the TopologyDTO into a JSON string like Jackson before
writing it.
public static void main(String[] args) throws IOException {
try (RestHighLevelClient client = new RestHighLevelClient(
Hi Team,
We get the below error message when we try to add an elastick sink
Caused by:
org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException:
Could not forward element to next operator
at
