flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/utils/ElasticsearchJestSink.java (1 line):
	- line 98: jestClient.execute(bulkIndexBuilder.build());   //FIXME: iterate through response and handle failures of single actions to obtain at least once semantics