diff --git a/src/backend/distributed/commands/create_distributed_table.c b/src/backend/distributed/commands/create_distributed_table.c index 77e26df65..af1648859 100644 --- a/src/backend/distributed/commands/create_distributed_table.c +++ b/src/backend/distributed/commands/create_distributed_table.c @@ -652,6 +652,11 @@ AlterSequenceType(Oid seqOid, Oid typeOid) SetDefElemArg(alterSequenceStatement, "as", asTypeNode); ParseState *pstate = make_parsestate(NULL); AlterSequence(pstate, alterSequenceStatement); + + /* + * Make sure later reads in this transaction read the correct type. + */ + CommandCounterIncrement(); } }