@@ -237,7 +237,7 @@ public void actual_run() {
237237 if (this .sdk != null )
238238 result = docops .bulkInsert (this .sdk .connection , docs , setOptions );
239239 ops += dg .ws .batchSize *dg .ws .creates /100 ;
240- if (trackFailures && result .size ()>0 )
240+ if (this . trackFailures && result .size ()>0 )
241241 this .result = false ;
242242 try {
243243 failedMutations .get ("create" ).addAll (result );
@@ -257,7 +257,7 @@ public void actual_run() {
257257 if (this .sdk != null )
258258 result = docops .bulkUpsert (this .sdk .connection , docs , upsertOptions );
259259 ops += dg .ws .batchSize *dg .ws .updates /100 ;
260- if (trackFailures && result .size ()>0 )
260+ if (this . trackFailures && result .size ()>0 )
261261 this .result = false ;
262262 try {
263263 failedMutations .get ("update" ).addAll (result );
@@ -274,7 +274,7 @@ public void actual_run() {
274274 if (this .sdk != null )
275275 result = docops .bulkInsert (this .sdk .connection , docs , expiryOptions );
276276 ops += dg .ws .batchSize *dg .ws .expiry /100 ;
277- if (trackFailures && result .size ()>0 )
277+ if (this . trackFailures && result .size ()>0 )
278278 this .result = false ;
279279 try {
280280 failedMutations .get ("expiry" ).addAll (result );
@@ -294,7 +294,7 @@ public void actual_run() {
294294 this .esClient .deleteDocs (this .collection .replace ("_" , "" ), docs );
295295 }
296296 ops += dg .ws .batchSize *dg .ws .deletes /100 ;
297- if (trackFailures && result .size ()>0 )
297+ if (this . trackFailures && result .size ()>0 )
298298 this .result = false ;
299299 try {
300300 failedMutations .get ("delete" ).addAll (result );
0 commit comments