@@ -102,7 +102,7 @@ static NDB_TICKS startTime;
102
102
#define DEB_LCP_DEL (arglist ) do { } while (0 )
103
103
#endif
104
104
105
- // #define DEBUG_LCP_STAT 1
105
+ #define DEBUG_LCP_STAT 1
106
106
#ifdef DEBUG_LCP_STAT
107
107
#define DEB_LCP_STAT (arglist ) do { g_eventLogger->info arglist ; } while (0 )
108
108
#else
@@ -7284,11 +7284,26 @@ Backup::fragmentCompleted(Signal* signal,
7284
7284
* the LCP scan in an orderly manner with no rows read. So we
7285
7285
* should not crash in this case.
7286
7286
*/
7287
- ndbrequire (errCode != 0 ||
7288
- ptr.p ->m_row_count == filePtr.p ->m_lcp_inserts ||
7289
- ((ptr.p ->m_num_parts_in_this_lcp != BackupFormat::NDB_MAX_LCP_PARTS) &&
7290
- (ptr.p ->m_row_count >=
7291
- (filePtr.p ->m_lcp_inserts + filePtr.p ->m_lcp_writes ))));
7287
+ if (!(errCode != 0 ||
7288
+ ptr.p ->m_row_count == filePtr.p ->m_lcp_inserts ||
7289
+ ((ptr.p ->m_num_parts_in_this_lcp !=
7290
+ BackupFormat::NDB_MAX_LCP_PARTS) &&
7291
+ (ptr.p ->m_row_count >=
7292
+ (filePtr.p ->m_lcp_inserts + filePtr.p ->m_lcp_writes )))))
7293
+ {
7294
+ g_eventLogger->info (" errCode = %u, row_count = %llu, inserts: %llu"
7295
+ " , writes: %llu, parts: %u" ,
7296
+ errCode,
7297
+ ptr.p ->m_row_count ,
7298
+ filePtr.p ->m_lcp_inserts ,
7299
+ filePtr.p ->m_lcp_writes ,
7300
+ ptr.p ->m_num_parts_in_this_lcp );
7301
+ ndbrequire (errCode != 0 ||
7302
+ ptr.p ->m_row_count == filePtr.p ->m_lcp_inserts ||
7303
+ ((ptr.p ->m_num_parts_in_this_lcp != BackupFormat::NDB_MAX_LCP_PARTS) &&
7304
+ (ptr.p ->m_row_count >=
7305
+ (filePtr.p ->m_lcp_inserts + filePtr.p ->m_lcp_writes ))));
7306
+ }
7292
7307
7293
7308
ptr.p ->slaveState .setState (STOPPING);
7294
7309
0 commit comments