File tree Expand file tree Collapse file tree 1 file changed +9
-6
lines changed Expand file tree Collapse file tree 1 file changed +9
-6
lines changed Original file line number Diff line number Diff line change @@ -2400,15 +2400,18 @@ MtmExecutorFinish(QueryDesc *queryDesc)
2400
2400
for (i = 0 ; i < estate -> es_num_result_relations ; i ++ ) {
2401
2401
Relation rel = estate -> es_result_relations [i ].ri_RelationDesc ;
2402
2402
if (RelationNeedsWAL (rel )) {
2403
+ if (MtmIgnoreTablesWithoutPk ) {
2404
+ if (!rel -> rd_indexvalid ) {
2405
+ RelationGetIndexList (rel );
2406
+ }
2407
+ if (rel -> rd_replidindex == InvalidOid ) {
2408
+ MtmMakeRelationLocal (RelationGetRelid (rel ));
2409
+ continue ;
2410
+ }
2411
+ }
2403
2412
MtmTx .containsDML = true;
2404
2413
break ;
2405
2414
}
2406
- if (MtmIgnoreTablesWithoutPk ) {
2407
- if (!rel -> rd_indexvalid ) {
2408
- RelationGetIndexList (rel );
2409
- }
2410
- MtmMakeRelationLocal (rel -> rd_replidindex );
2411
- }
2412
2415
}
2413
2416
}
2414
2417
}
You can’t perform that action at this time.
0 commit comments