@@ -166,13 +166,13 @@ def fill_query_params(queries):
166166            'wal_lsn'  if  Pooler .server_version_greater ('10.0' ) else  'xlog_location' ,
167167            'waiting'  if  Pooler .server_version_less ('9.6.0' ) else  'case when wait_event_type is null then false ' 
168168                                                                  ' else true end  as waiting' ,
169-             'coalesce((pg_wal_lsn_diff(pg_current_wal_lsn(), sent_lsn))::int , 0) AS send_lag, ' 
170-             'coalesce((pg_wal_lsn_diff(sent_lsn, flush_lsn))::int , 0) AS receive_lag, ' 
171-             'coalesce((pg_wal_lsn_diff(sent_lsn, write_lsn))::int , 0) AS write_lag, ' 
172-             'coalesce((pg_wal_lsn_diff(write_lsn, flush_lsn))::int , 0) AS flush_lag, ' 
173-             'coalesce((pg_wal_lsn_diff(flush_lsn, replay_lsn))::int , 0) AS replay_lag,'  if  Pooler .server_version_greater ('10.0' ) else  '' ,
169+             'coalesce((pg_wal_lsn_diff(pg_current_wal_lsn(), sent_lsn))::bigint , 0) AS send_lag, ' 
170+             'coalesce((pg_wal_lsn_diff(sent_lsn, flush_lsn))::bigint , 0) AS receive_lag, ' 
171+             'coalesce((pg_wal_lsn_diff(sent_lsn, write_lsn))::bigint , 0) AS write_lag, ' 
172+             'coalesce((pg_wal_lsn_diff(write_lsn, flush_lsn))::bigint , 0) AS flush_lag, ' 
173+             'coalesce((pg_wal_lsn_diff(flush_lsn, replay_lsn))::bigint , 0) AS replay_lag,'  if  Pooler .server_version_greater ('10.0' ) else  '' ,
174174            'wal_lsn'  if  Pooler .server_version_greater ('10.0' ) else  'xlog_location' ,
175-             'send_lag INTEGER , receive_lag INTEGER , write_lag INTEGER , flush_lag INTEGER , replay_lag INTEGER ,'  if  Pooler .server_version_greater ('10.0' )
175+             'send_lag BIGINT , receive_lag BIGINT , write_lag BIGINT , flush_lag BIGINT , replay_lag BIGINT ,'  if  Pooler .server_version_greater ('10.0' )
176176            else  '' ,
177177            'lsn'  if  Pooler .server_version_greater ('10.0' ) else  'location' ,
178178            'walfile'  if  Pooler .server_version_greater ('10.0' ) else  'xlogfile' ,
0 commit comments