Commit a5ce66f4 authored by joreland@mysql.com's avatar joreland@mysql.com

ndb - Fix memory leak in HugoLoad

parent 8ff94e12
...@@ -865,7 +865,7 @@ HugoTransactions::loadTable(Ndb* pNdb, ...@@ -865,7 +865,7 @@ HugoTransactions::loadTable(Ndb* pNdb,
g_info << "|- Inserting records..." << endl; g_info << "|- Inserting records..." << endl;
for (int c=0 ; c<records ; ){ for (int c=0 ; c<records ; ){
bool closeTrans; bool closeTrans = true;
if (retryAttempt >= retryMax){ if (retryAttempt >= retryMax){
g_info << "Record " << c << " could not be inserted, has retried " g_info << "Record " << c << " could not be inserted, has retried "
<< retryAttempt << " times " << endl; << retryAttempt << " times " << endl;
...@@ -983,6 +983,9 @@ HugoTransactions::loadTable(Ndb* pNdb, ...@@ -983,6 +983,9 @@ HugoTransactions::loadTable(Ndb* pNdb,
c = c+batch; c = c+batch;
retryAttempt = 0; retryAttempt = 0;
} }
if(pTrans)
pNdb->closeTransaction(pTrans);
return NDBT_OK; return NDBT_OK;
} }
......
Markdown is supported
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