File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -1298,7 +1298,7 @@ operator<<(NdbOut& out, const NdbImportImpl::Job& job)
1298
1298
{
1299
1299
const Error& error = job.m_error ;
1300
1300
const char * typetext = error.gettypetext ();
1301
- out << " error[" << typetext << " -" << error.code << " ]" ;
1301
+ out << " error[" << typetext << " -" << error.code << " ]" ;
1302
1302
}
1303
1303
return out;
1304
1304
}
@@ -1313,7 +1313,7 @@ operator<<(NdbOut& out, const NdbImportImpl::Team& team)
1313
1313
{
1314
1314
const Error& error = team.m_error ;
1315
1315
const char * typetext = error.gettypetext ();
1316
- out << " error[" << typetext << " -" << error.code << " ]" ;
1316
+ out << " error[" << typetext << " -" << error.code << " ]" ;
1317
1317
}
1318
1318
return out;
1319
1319
}
@@ -1559,6 +1559,7 @@ NdbImportImpl::CsvInputWorker::CsvInputWorker(Team& team, uint n) :
1559
1559
m_buf(true )
1560
1560
{
1561
1561
m_inputstate = InputState::State_null;
1562
+ m_csvinput = 0 ;
1562
1563
m_firstread = false ;
1563
1564
m_eof = false ;
1564
1565
}
@@ -3506,6 +3507,11 @@ NdbImportImpl::DiagWorker::write_result()
3506
3507
uint64 rows = 0 ;
3507
3508
uint64 reject = 0 ;
3508
3509
uint64 temperrors = 0 ;
3510
+ if (team.m_state != TeamState::State_stopped)
3511
+ {
3512
+ // not worth crashing
3513
+ team.m_timer .stop ();
3514
+ }
3509
3515
uint64 runtime = team.m_timer .elapsed_msec ();
3510
3516
uint64 utime = team.m_stat_utime ->m_sum ;
3511
3517
const Error& error = team.m_error ;
You can’t perform that action at this time.
0 commit comments