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
