Hi guys, I have a small question. I want to create a "Worker" class which using ElasticClient to make query to elasticsearch. (I want to enrich my data with geo search result).
How can I do that? I try to create a worker instance with ES host/port parameter but spark throw an exceptino (my class not serializable). Any idea? Thanks b0c1