Not try to sync metadata for local tables (#4625)

pull/4617/head
Onur Tirtir 2021-02-02 15:12:12 +03:00 committed by GitHub
parent c5d4e7081b
commit c8a48c6eee
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 13 additions and 6 deletions

View File

@ -243,6 +243,11 @@ ClusterHasKnownMetadataWorkers()
bool bool
ShouldSyncTableMetadata(Oid relationId) ShouldSyncTableMetadata(Oid relationId)
{ {
if (!OidIsValid(relationId) || !IsCitusTable(relationId))
{
return false;
}
CitusTableCacheEntry *tableEntry = GetCitusTableCacheEntry(relationId); CitusTableCacheEntry *tableEntry = GetCitusTableCacheEntry(relationId);
bool streamingReplicated = bool streamingReplicated =

View File

@ -492,7 +492,8 @@ SELECT * FROM mat_view ORDER BY a;
2 2
(2 rows) (2 rows)
CREATE TABLE local(a int); CREATE SEQUENCE c_seq;
CREATE TABLE local(a int, b bigserial, c int default nextval('c_seq'));
INSERT INTO local VALUES (3); INSERT INTO local VALUES (3);
create materialized view m_local as select * from local; create materialized view m_local as select * from local;
create view v_local as select * from local; create view v_local as select * from local;
@ -615,9 +616,9 @@ NOTICE: Renaming the new table to alter_table_set_access_method.dist
(1 row) (1 row)
SELECT * FROM m_local; SELECT * FROM m_local;
a a | b | c
--------------------------------------------------------------------- ---------------------------------------------------------------------
3 3 | 1 | 1
(1 row) (1 row)
SELECT * FROM m_ref; SELECT * FROM m_ref;
@ -635,9 +636,9 @@ SELECT * FROM m_dist;
(2 rows) (2 rows)
SELECT * FROM v_local; SELECT * FROM v_local;
a a | b | c
--------------------------------------------------------------------- ---------------------------------------------------------------------
3 3 | 1 | 1
(1 row) (1 row)
SELECT * FROM v_ref; SELECT * FROM v_ref;

View File

@ -156,7 +156,8 @@ CREATE MATERIALIZED VIEW mat_view AS SELECT * FROM mat_view_test;
SELECT alter_table_set_access_method('mat_view_test','columnar'); SELECT alter_table_set_access_method('mat_view_test','columnar');
SELECT * FROM mat_view ORDER BY a; SELECT * FROM mat_view ORDER BY a;
CREATE TABLE local(a int); CREATE SEQUENCE c_seq;
CREATE TABLE local(a int, b bigserial, c int default nextval('c_seq'));
INSERT INTO local VALUES (3); INSERT INTO local VALUES (3);
create materialized view m_local as select * from local; create materialized view m_local as select * from local;
create view v_local as select * from local; create view v_local as select * from local;