fix v$ob_timestamp_service

This commit is contained in:
obdev
2023-06-16 03:23:56 +00:00
committed by ob-robot
parent caaf2d84ca
commit e9a0d16b1d
2 changed files with 6 additions and 4 deletions

View File

@ -210,7 +210,7 @@ int ObInnerTableSchema::v_ob_timestamp_service_schema(ObTableSchema &table_schem
table_schema.set_collation_type(ObCharset::get_default_collation(ObCharset::get_default_charset())); table_schema.set_collation_type(ObCharset::get_default_collation(ObCharset::get_default_charset()));
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT TENANT_ID, TS_TYPE, TS_VALUE, SVR_IP, SVR_PORT FROM oceanbase.__all_virtual_timestamp_service WHERE ROLE = 'LEADER' AND SERVICE_EPOCH = (SELECT MAX(SERVICE_EPOCH) FROM oceanbase.__all_virtual_timestamp_service) )__"))) { if (OB_FAIL(table_schema.set_view_definition(R"__( SELECT TENANT_ID, TS_TYPE, TS_VALUE, SVR_IP, SVR_PORT FROM oceanbase.__all_virtual_timestamp_service as a WHERE ROLE = 'LEADER' AND SERVICE_EPOCH = (SELECT MAX(SERVICE_EPOCH) FROM oceanbase.__all_virtual_timestamp_service where TENANT_ID = a.TENANT_ID) GROUP BY TENANT_ID )__"))) {
LOG_ERROR("fail to set view_definition", K(ret)); LOG_ERROR("fail to set view_definition", K(ret));
} }
} }

View File

@ -26857,11 +26857,13 @@ def_table_schema(
SVR_IP, SVR_IP,
SVR_PORT SVR_PORT
FROM FROM
oceanbase.__all_virtual_timestamp_service oceanbase.__all_virtual_timestamp_service as a
WHERE WHERE
ROLE = 'LEADER' AND SERVICE_EPOCH = ROLE = 'LEADER' AND SERVICE_EPOCH =
(SELECT MAX(SERVICE_EPOCH) FROM (SELECT MAX(SERVICE_EPOCH) FROM
oceanbase.__all_virtual_timestamp_service) oceanbase.__all_virtual_timestamp_service
where TENANT_ID = a.TENANT_ID)
GROUP BY TENANT_ID
""".replace("\n", " ") """.replace("\n", " ")
) )
@ -51080,7 +51082,7 @@ def_table_schema(
) )
def_table_schema( def_table_schema(
owner = 'zhenjiang.xzj', owner = 'lixinze.lxz',
table_name = 'V$OB_TIMESTAMP_SERVICE', table_name = 'V$OB_TIMESTAMP_SERVICE',
name_postfix = '_ORA', name_postfix = '_ORA',
database_id = 'OB_ORA_SYS_DATABASE_ID', database_id = 'OB_ORA_SYS_DATABASE_ID',