Commit cdb90493 authored by Mohamed, Fawzi Roberto (fawzi)'s avatar Mohamed, Fawzi Roberto (fawzi)
Browse files

increase time to process batch add for elastic search

parent 0d4dd157
...@@ -129,7 +129,7 @@ object ElasticSearchData extends StrictLogging { ...@@ -129,7 +129,7 @@ object ElasticSearchData extends StrictLogging {
previousBatch: Option[Future[BulkResponse]] previousBatch: Option[Future[BulkResponse]]
): Option[Future[BulkResponse]] = { ): Option[Future[BulkResponse]] = {
if (previousBatch.nonEmpty) { if (previousBatch.nonEmpty) {
val response = Await.result(previousBatch.get, 10.seconds) val response = Await.result(previousBatch.get, 100.seconds)
if (response.hasFailures) { if (response.hasFailures) {
response.failures.foreach(x => logger.warn(" failed insertion: " + x)) response.failures.foreach(x => logger.warn(" failed insertion: " + x))
} }
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment