Hi Ryan, Why don't you use the ElasticsearchIO for that ?
Anyway, can you share your pipeline where you have the ParDo calling your DoFn ? Thanks, Regards JB On 10/23/2017 07:50 PM, r...@ostrich-emulators.com wrote:
Hi List, I'm trying to write an updated ElasticSearch client using the newly-published RestHighLevelClient class (with ES 5.6.0). I'm only interested in writes at this time, so I'm using the ElasticsearchIO.write() function as a model. I have a transient member named client. Here's my setup function for my DoFn: @Setup public void setup() { HttpHost elastic = HttpHost.create( elasticurl ); RestClientBuilder bldr = RestClient.builder( elastic ); client = new RestHighLevelClient( bldr.build() ); } If I run the code as shown, I eventually get the debug message: "Pipeline has terminated. Shutting down." but the program never exits. If I comment out the client assignment above, the pipeline behaves normally (but obviously, I can't write anything to ES). Any advice for a dev just getting started with Apache Beam (2.0.0)? ry
-- Jean-Baptiste Onofré jbono...@apache.org http://blog.nanthrax.net Talend - http://www.talend.com