in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/lookup/ElasticsearchRowDataLookupFunction.java [184:193]
private RowData parseSearchResult(String result) {
RowData row = null;
try {
row = deserializationSchema.deserialize(result.getBytes());
} catch (IOException e) {
LOG.error("Deserialize search hit failed: " + e.getMessage());
}
return row;
}