[ 
https://issues.apache.org/jira/browse/IMPALA-14656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18048902#comment-18048902
 ] 

Quanlong Huang commented on IMPALA-14656:
-----------------------------------------

The patch for IMPALA-12865 might be able to fix this: 
https://gerrit.cloudera.org/c/21665/
So assigning this to [~hemanth619] first.

> test_skipping_older_events is flaky
> -----------------------------------
>
>                 Key: IMPALA-14656
>                 URL: https://issues.apache.org/jira/browse/IMPALA-14656
>             Project: IMPALA
>          Issue Type: Bug
>            Reporter: Quanlong Huang
>            Assignee: Sai Hemanth Gantasala
>            Priority: Major
>
> Saw the test failed in jobs on unrelated patches:
> https://jenkins.impala.io/job/ubuntu-20.04-from-scratch/7571/
> https://jenkins.impala.io/job/ubuntu-20.04-from-scratch/7523/
> Stacktrace
> {code:python}
> custom_cluster/test_events_custom_configs.py:774: in 
> test_skipping_older_events
>     verify_skipping_older_events(test_old_table, True, False)
> custom_cluster/test_events_custom_configs.py:760: in 
> verify_skipping_older_events
>     verify_skipping_hive_stmt_events(complete_query, table_name)
> custom_cluster/test_events_custom_configs.py:740: in 
> verify_skipping_hive_stmt_events
>     assert tbl_events_skipped_after > tbl_events_skipped_before
> E   assert 15 > 15{code}
> Standard Error
> {noformat}
> -- 2026-01-02 19:50:13,170 INFO     MainThread: Starting cluster with 
> command: /home/ubuntu/Impala/bin/start-impala-cluster.py 
> '--state_store_args=--statestore_update_frequency_ms=50 
> --statestore_priority_update_frequency_ms=50 
> --statestore_heartbeat_frequency_ms=50' --cluster_size=3 --num_coordinators=3 
> --log_dir=/home/ubuntu/Impala/logs/custom_cluster_tests --log_level=1 
> '--catalogd_args=--hms_event_polling_interval_s=10 
> --enable_skipping_older_events=true 
> --enable_sync_to_latest_event_on_ddls=true ' 
> --impalad_args=--default_query_options=
> 19:50:13 MainThread: Found 0 impalad/0 statestored/0 catalogd process(es)
> 19:50:13 MainThread: Starting State Store logging to 
> /home/ubuntu/Impala/logs/custom_cluster_tests/statestored.INFO
> 19:50:14 MainThread: Starting Catalog Service logging to 
> /home/ubuntu/Impala/logs/custom_cluster_tests/catalogd.INFO
> 19:50:15 MainThread: Starting Impala Daemon logging to 
> /home/ubuntu/Impala/logs/custom_cluster_tests/impalad.INFO
> 19:50:15 MainThread: Starting Impala Daemon logging to 
> /home/ubuntu/Impala/logs/custom_cluster_tests/impalad_node1.INFO
> 19:50:15 MainThread: Starting Impala Daemon logging to 
> /home/ubuntu/Impala/logs/custom_cluster_tests/impalad_node2.INFO
> 19:50:17 MainThread: Found 3 impalad/1 statestored/1 catalogd process(es)
> 19:50:17 MainThread: Waiting for Impalad webserver port 25000
> 19:50:18 MainThread: Waiting for Impalad webserver port 25000
> 19:50:18 MainThread: Waiting for Impalad webserver port 25001
> 19:50:18 MainThread: Waiting for Impalad webserver port 25002
> 19:50:19 MainThread: Waiting for coordinator client services - hs2 port: 
> 21050 hs2-http port: 28000 beeswax port: 21000
> 19:50:20 MainThread: Waiting for coordinator client services - hs2 port: 
> 21051 hs2-http port: 28001 beeswax port: 21001
> 19:50:21 MainThread: Waiting for coordinator client services - hs2 port: 
> 21052 hs2-http port: 28002 beeswax port: 21002
> 19:50:21 MainThread: Getting num_known_live_backends from 
> ip-172-31-61-231:25000
> 19:50:21 MainThread: num_known_live_backends has reached value: 3
> 19:50:21 MainThread: Getting num_known_live_backends from 
> ip-172-31-61-231:25001
> 19:50:21 MainThread: num_known_live_backends has reached value: 3
> 19:50:21 MainThread: Getting num_known_live_backends from 
> ip-172-31-61-231:25002
> 19:50:21 MainThread: num_known_live_backends has reached value: 3
> 19:50:21 MainThread: Total wait: 3.91s
> 19:50:21 MainThread: Actual log file names:
> 19:50:21 MainThread: statestored.INFO -> 
> statestored.ip-172-31-61-231.ubuntu.log.INFO.20260102-195013.2049278
> 19:50:21 MainThread: catalogd.INFO -> 
> catalogd.ip-172-31-61-231.ubuntu.log.INFO.20260102-195014.2049338
> 19:50:21 MainThread: impalad.INFO -> 
> impalad.ip-172-31-61-231.ubuntu.log.INFO.20260102-195015.2049447
> 19:50:21 MainThread: impalad_node1.INFO -> 
> impalad.ip-172-31-61-231.ubuntu.log.INFO.20260102-195015.2049449
> 19:50:21 MainThread: impalad_node2.INFO -> 
> impalad.ip-172-31-61-231.ubuntu.log.INFO.20260102-195015.2049452
> 19:50:21 MainThread: Impala Cluster Running with 3 nodes (3 coordinators, 3 
> executors).
> -- 2026-01-02 19:50:21,514 DEBUG    MainThread: Found 3 impalad/1 
> statestored/1 catalogd process(es)
> -- 2026-01-02 19:50:21,515 INFO     MainThread: Getting metric: 
> statestore.live-backends from ip-172-31-61-231:25010
> -- 2026-01-02 19:50:21,518 INFO     MainThread: Metric 
> 'statestore.live-backends' has reached desired value: 4. total_wait: 0s
> -- 2026-01-02 19:50:21,518 DEBUG    MainThread: Getting 
> num_known_live_backends from ip-172-31-61-231:25000
> -- 2026-01-02 19:50:21,520 INFO     MainThread: num_known_live_backends has 
> reached value: 3
> -- 2026-01-02 19:50:21,520 DEBUG    MainThread: Getting 
> num_known_live_backends from ip-172-31-61-231:25001
> -- 2026-01-02 19:50:21,522 INFO     MainThread: num_known_live_backends has 
> reached value: 3
> -- 2026-01-02 19:50:21,522 DEBUG    MainThread: Getting 
> num_known_live_backends from ip-172-31-61-231:25002
> -- 2026-01-02 19:50:21,524 INFO     MainThread: num_known_live_backends has 
> reached value: 3
> -- 2026-01-02 19:50:21,524 INFO     MainThread: beeswax: 
> set 
> client_identifier=custom_cluster/test_events_custom_configs.py::TestEventProcessingCustomConfigs::()::test_skipping_older_events;
> -- 2026-01-02 19:50:21,524 INFO     MainThread: beeswax: connected to 
> ip-172-31-61-231:21000 with beeswax
> -- 2026-01-02 19:50:21,524 INFO     MainThread: hs2: 
> set 
> client_identifier=custom_cluster/test_events_custom_configs.py::TestEventProcessingCustomConfigs::()::test_skipping_older_events;
> -- 2026-01-02 19:50:21,524 INFO     MainThread: hs2: connected to 
> ip-172-31-61-231:21050 with impyla hs2
> -- 2026-01-02 19:50:21,525 INFO     MainThread: hs2-http: 
> set 
> client_identifier=custom_cluster/test_events_custom_configs.py::TestEventProcessingCustomConfigs::()::test_skipping_older_events;
> -- 2026-01-02 19:50:21,525 INFO     MainThread: hs2-http: connected to 
> ip-172-31-61-231:28000 with impyla hs2-http
> -- 2026-01-02 19:50:21,526 INFO     MainThread: hs2: 
> set 
> client_identifier=custom_cluster/test_events_custom_configs.py::TestEventProcessingCustomConfigs::()::test_skipping_older_events;
> -- 2026-01-02 19:50:21,526 INFO     MainThread: hs2: connected to 
> ip-172-31-61-231:21050 with impyla hs2
> -- 2026-01-02 19:50:21,526 INFO     MainThread: hs2: 
> set 
> client_identifier=custom_cluster/test_events_custom_configs.py::TestEventProcessingCustomConfigs::()::test_skipping_older_events;
> -- 2026-01-02 19:50:21,526 INFO     MainThread: hs2: set_configuration:
> set sync_ddl=False;
> -- 2026-01-02 19:50:21,527 INFO     MainThread: hs2: executing against Impala 
> at ip-172-31-61-231:21050. session: 6c40c69f2b098dba:cfb64a4ba65c0f81 
> main_cursor: True user: None
> DROP DATABASE IF EXISTS `test_skipping_older_events_7aa2217d` CASCADE;
> -- 2026-01-02 19:50:21,706 INFO     MainThread: 
> 35406f323550fa48:a777f38400000000: query started
> -- 2026-01-02 19:50:21,707 INFO     MainThread: 
> 35406f323550fa48:a777f38400000000: getting log for operation
> -- 2026-01-02 19:50:21,707 INFO     MainThread: 
> 35406f323550fa48:a777f38400000000: getting runtime profile operation
> -- 2026-01-02 19:50:21,708 INFO     MainThread: 
> 35406f323550fa48:a777f38400000000: closing query for operation
> -- 2026-01-02 19:50:21,713 INFO     MainThread: hs2: executing against Impala 
> at ip-172-31-61-231:21050. session: 6c40c69f2b098dba:cfb64a4ba65c0f81 
> main_cursor: True user: None
> CREATE DATABASE `test_skipping_older_events_7aa2217d`;
> -- 2026-01-02 19:50:21,824 INFO     MainThread: 
> 4c42b0352fbf04e5:7082acab00000000: query started
> -- 2026-01-02 19:50:21,824 INFO     MainThread: 
> 4c42b0352fbf04e5:7082acab00000000: getting log for operation
> -- 2026-01-02 19:50:21,824 INFO     MainThread: 
> 4c42b0352fbf04e5:7082acab00000000: getting runtime profile operation
> -- 2026-01-02 19:50:21,824 INFO     MainThread: 
> 4c42b0352fbf04e5:7082acab00000000: closing query for operation
> -- 2026-01-02 19:50:21,825 INFO     MainThread: Created database 
> "test_skipping_older_events_7aa2217d" for test ID 
> "custom_cluster/test_events_custom_configs.py::TestEventProcessingCustomConfigs::()::test_skipping_older_events"
> -- 2026-01-02 19:50:21,825 INFO     MainThread: hs2: closing 1 sync and 0 
> async hs2 connections to: ip-172-31-61-231:21050
> -- 2026-01-02 19:50:21,825 INFO     MainThread: -- executing in HiveServer2
> create  table test_skipping_older_events_7aa2217d.test_old_table (i int) 
> -- 2026-01-02 19:50:23,797 INFO     MainThread: Waiting until events 
> processor syncs to event id:40201
> -- 2026-01-02 19:50:26,520 DEBUG    MainThread: Metric last-synced-event-id 
> has reached the desired value: 40201
> -- 2026-01-02 19:50:26,539 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25000
> -- 2026-01-02 19:50:26,550 INFO     MainThread: Waiting for metric value 
> 'catalog.curr-version'>=2092. Current value: 2091. total_wait: 0s
> -- 2026-01-02 19:50:26,551 INFO     MainThread: Sleeping 1s before next retry.
> -- 2026-01-02 19:50:27,552 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25000
> -- 2026-01-02 19:50:27,555 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2092. total_wait: 1.0122625827789307s
> -- 2026-01-02 19:50:27,555 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25001
> -- 2026-01-02 19:50:27,566 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2092. total_wait: 0s
> -- 2026-01-02 19:50:27,566 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25002
> -- 2026-01-02 19:50:27,576 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2092. total_wait: 0s
> -- 2026-01-02 19:50:27,579 INFO     MainThread: -- executing in HiveServer2
> insert into `test_skipping_older_events_7aa2217d`.`test_old_table`  values 
> (10),(20),(30)
> -- 2026-01-02 19:50:36,787 INFO     MainThread: hs2: executing against Impala 
> at ip-172-31-61-231:21050. session: 984f12febbb25f7b:527240d4870e1bbc 
> main_cursor: True user: None
> refresh test_skipping_older_events_7aa2217d.test_old_table;
> -- 2026-01-02 19:50:37,088 INFO     MainThread: 
> 8b47a198f709b963:6bab0ef000000000: query started
> -- 2026-01-02 19:50:37,088 INFO     MainThread: 
> 8b47a198f709b963:6bab0ef000000000: getting log for operation
> -- 2026-01-02 19:50:37,088 INFO     MainThread: 
> 8b47a198f709b963:6bab0ef000000000: getting runtime profile operation
> -- 2026-01-02 19:50:37,089 INFO     MainThread: 
> 8b47a198f709b963:6bab0ef000000000: closing query for operation
> -- 2026-01-02 19:50:37,105 INFO     MainThread: Waiting until events 
> processor syncs to event id:40205
> -- 2026-01-02 19:50:46,512 DEBUG    MainThread: Metric last-synced-event-id 
> has reached the desired value: 40205
> -- 2026-01-02 19:50:46,525 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25000
> -- 2026-01-02 19:50:46,536 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2094. total_wait: 0s
> -- 2026-01-02 19:50:46,536 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25001
> -- 2026-01-02 19:50:46,547 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2094. total_wait: 0s
> -- 2026-01-02 19:50:46,547 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25002
> -- 2026-01-02 19:50:46,557 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2094. total_wait: 0s
> -- 2026-01-02 19:50:46,566 INFO     MainThread: -- executing in HiveServer2
> insert into `test_skipping_older_events_7aa2217d`.`test_old_table`  values 
> (10),(20),(30) ;insert into 
> `test_skipping_older_events_7aa2217d`.`test_old_table`  values (10),(20),(30) 
> ;insert into `test_skipping_older_events_7aa2217d`.`test_old_table`  values 
> (10),(20),(30) ;
> -- 2026-01-02 19:50:56,226 INFO     MainThread: hs2: executing against Impala 
> at ip-172-31-61-231:21050. session: 984f12febbb25f7b:527240d4870e1bbc 
> main_cursor: True user: None
> refresh test_skipping_older_events_7aa2217d.test_old_table;
> -- 2026-01-02 19:50:56,263 INFO     MainThread: 
> b248842da8b5c198:17f0587500000000: query started
> -- 2026-01-02 19:50:56,263 INFO     MainThread: 
> b248842da8b5c198:17f0587500000000: getting log for operation
> -- 2026-01-02 19:50:56,263 INFO     MainThread: 
> b248842da8b5c198:17f0587500000000: getting runtime profile operation
> -- 2026-01-02 19:50:56,263 INFO     MainThread: 
> b248842da8b5c198:17f0587500000000: closing query for operation
> -- 2026-01-02 19:50:56,281 INFO     MainThread: Waiting until events 
> processor syncs to event id:40217
> -- 2026-01-02 19:50:56,495 DEBUG    MainThread: Metric last-synced-event-id 
> has reached the desired value: 40217
> -- 2026-01-02 19:50:56,507 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25000
> -- 2026-01-02 19:50:56,517 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2095. total_wait: 0s
> -- 2026-01-02 19:50:56,517 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25001
> -- 2026-01-02 19:50:56,527 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2095. total_wait: 0s
> -- 2026-01-02 19:50:56,527 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25002
> -- 2026-01-02 19:50:56,538 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2095. total_wait: 0s
> -- 2026-01-02 19:50:56,545 INFO     MainThread: hs2: executing against Impala 
> at ip-172-31-61-231:21050. session: 984f12febbb25f7b:527240d4870e1bbc 
> main_cursor: True user: None
> create table `test_skipping_older_events_7aa2217d`.`new_table` (i int)  ;
> -- 2026-01-02 19:50:56,620 INFO     MainThread: 
> 164ba8d63f5792ba:8976f8b100000000: query started
> -- 2026-01-02 19:50:56,621 INFO     MainThread: 
> 164ba8d63f5792ba:8976f8b100000000: getting log for operation
> -- 2026-01-02 19:50:56,621 INFO     MainThread: 
> 164ba8d63f5792ba:8976f8b100000000: getting runtime profile operation
> -- 2026-01-02 19:50:56,621 INFO     MainThread: 
> 164ba8d63f5792ba:8976f8b100000000: closing query for operation
> -- 2026-01-02 19:50:56,624 INFO     MainThread: -- executing in HiveServer2
> insert overwrite table `test_skipping_older_events_7aa2217d`.`new_table` 
> select * from `test_skipping_older_events_7aa2217d`.`test_old_table`
> -- 2026-01-02 19:51:06,956 INFO     MainThread: hs2: executing against Impala 
> at ip-172-31-61-231:21050. session: 984f12febbb25f7b:527240d4870e1bbc 
> main_cursor: True user: None
> refresh test_skipping_older_events_7aa2217d.new_table;
> -- 2026-01-02 19:51:06,999 INFO     MainThread: 
> 5040dddfafc673c0:0d2b9b2300000000: query started
> -- 2026-01-02 19:51:07,000 INFO     MainThread: 
> 5040dddfafc673c0:0d2b9b2300000000: getting log for operation
> -- 2026-01-02 19:51:07,000 INFO     MainThread: 
> 5040dddfafc673c0:0d2b9b2300000000: getting runtime profile operation
> -- 2026-01-02 19:51:07,000 INFO     MainThread: 
> 5040dddfafc673c0:0d2b9b2300000000: closing query for operation
> -- 2026-01-02 19:51:07,017 INFO     MainThread: Waiting until events 
> processor syncs to event id:40222
> -- 2026-01-02 19:51:16,414 DEBUG    MainThread: Metric last-synced-event-id 
> has reached the desired value: 40222
> -- 2026-01-02 19:51:16,425 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25000
> -- 2026-01-02 19:51:16,436 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2098. total_wait: 0s
> -- 2026-01-02 19:51:16,436 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25001
> -- 2026-01-02 19:51:16,446 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2098. total_wait: 0s
> -- 2026-01-02 19:51:16,446 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25002
> -- 2026-01-02 19:51:16,457 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2098. total_wait: 0s
> -- 2026-01-02 19:51:16,463 INFO     MainThread: hs2: executing against Impala 
> at ip-172-31-61-231:21050. session: 984f12febbb25f7b:527240d4870e1bbc 
> main_cursor: True user: None
> drop table test_skipping_older_events_7aa2217d.test_old_table;
> -- 2026-01-02 19:51:16,715 INFO     MainThread: 
> 454166c27725dda3:3e695c0300000000: query started
> -- 2026-01-02 19:51:16,715 INFO     MainThread: 
> 454166c27725dda3:3e695c0300000000: getting log for operation
> -- 2026-01-02 19:51:16,716 INFO     MainThread: 
> 454166c27725dda3:3e695c0300000000: getting runtime profile operation
> -- 2026-01-02 19:51:16,716 INFO     MainThread: 
> 454166c27725dda3:3e695c0300000000: closing query for operation
> -- 2026-01-02 19:51:16,716 INFO     MainThread: hs2: executing against Impala 
> at ip-172-31-61-231:21050. session: 984f12febbb25f7b:527240d4870e1bbc 
> main_cursor: True user: None
> drop table test_skipping_older_events_7aa2217d.new_table;
> -- 2026-01-02 19:51:16,822 INFO     MainThread: 
> 504e9ace392b7070:b00d6db200000000: query started
> -- 2026-01-02 19:51:16,823 INFO     MainThread: 
> 504e9ace392b7070:b00d6db200000000: getting log for operation
> -- 2026-01-02 19:51:16,823 INFO     MainThread: 
> 504e9ace392b7070:b00d6db200000000: getting runtime profile operation
> -- 2026-01-02 19:51:16,823 INFO     MainThread: 
> 504e9ace392b7070:b00d6db200000000: closing query for operation
> -- 2026-01-02 19:51:16,824 INFO     MainThread: -- executing in HiveServer2
> create transactional table test_skipping_older_events_7aa2217d.test_old_table 
> (i int) 
> -- 2026-01-02 19:51:18,760 INFO     MainThread: Waiting until events 
> processor syncs to event id:40227
> -- 2026-01-02 19:51:26,497 DEBUG    MainThread: Metric last-synced-event-id 
> has reached the desired value: 40227
> -- 2026-01-02 19:51:26,507 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25000
> -- 2026-01-02 19:51:26,519 INFO     MainThread: Waiting for metric value 
> 'catalog.curr-version'>=2101. Current value: 2100. total_wait: 0s
> -- 2026-01-02 19:51:26,519 INFO     MainThread: Sleeping 1s before next retry.
> -- 2026-01-02 19:51:27,520 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25000
> -- 2026-01-02 19:51:27,524 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2101. total_wait: 1.0127770900726318s
> -- 2026-01-02 19:51:27,524 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25001
> -- 2026-01-02 19:51:27,534 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2101. total_wait: 0s
> -- 2026-01-02 19:51:27,534 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25002
> -- 2026-01-02 19:51:27,545 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2101. total_wait: 0s
> -- 2026-01-02 19:51:27,547 INFO     MainThread: -- executing in HiveServer2
> insert into `test_skipping_older_events_7aa2217d`.`test_old_table`  values 
> (10),(20),(30)
> -- 2026-01-02 19:51:37,042 INFO     MainThread: hs2: executing against Impala 
> at ip-172-31-61-231:21050. session: 984f12febbb25f7b:527240d4870e1bbc 
> main_cursor: True user: None
> refresh test_skipping_older_events_7aa2217d.test_old_table;
> -- 2026-01-02 19:51:37,108 INFO     MainThread: 
> bf4c076ad58509e1:8c5cd87b00000000: query started
> -- 2026-01-02 19:51:37,108 INFO     MainThread: 
> bf4c076ad58509e1:8c5cd87b00000000: getting log for operation
> -- 2026-01-02 19:51:37,108 INFO     MainThread: 
> bf4c076ad58509e1:8c5cd87b00000000: getting runtime profile operation
> -- 2026-01-02 19:51:37,108 INFO     MainThread: 
> bf4c076ad58509e1:8c5cd87b00000000: closing query for operation
> -- 2026-01-02 19:51:37,124 INFO     MainThread: Waiting until events 
> processor syncs to event id:40231
> -- 2026-01-02 19:51:46,509 DEBUG    MainThread: Metric last-synced-event-id 
> has reached the desired value: 40231
> -- 2026-01-02 19:51:46,519 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25000
> -- 2026-01-02 19:51:46,530 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2103. total_wait: 0s
> -- 2026-01-02 19:51:46,530 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25001
> -- 2026-01-02 19:51:46,540 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2103. total_wait: 0s
> -- 2026-01-02 19:51:46,540 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25002
> -- 2026-01-02 19:51:46,551 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2103. total_wait: 0s
> -- 2026-01-02 19:51:46,559 INFO     MainThread: -- executing in HiveServer2
> insert into `test_skipping_older_events_7aa2217d`.`test_old_table`  values 
> (10),(20),(30) ;insert into 
> `test_skipping_older_events_7aa2217d`.`test_old_table`  values (10),(20),(30) 
> ;insert into `test_skipping_older_events_7aa2217d`.`test_old_table`  values 
> (10),(20),(30) ;
> -- 2026-01-02 19:51:56,438 INFO     MainThread: hs2: executing against Impala 
> at ip-172-31-61-231:21050. session: 984f12febbb25f7b:527240d4870e1bbc 
> main_cursor: True user: None
> refresh test_skipping_older_events_7aa2217d.test_old_table;
> -- 2026-01-02 19:51:56,490 INFO     MainThread: 
> 934cd2798b5e2dbb:270625e200000000: query started
> -- 2026-01-02 19:51:56,490 INFO     MainThread: 
> 934cd2798b5e2dbb:270625e200000000: getting log for operation
> -- 2026-01-02 19:51:56,491 INFO     MainThread: 
> 934cd2798b5e2dbb:270625e200000000: getting runtime profile operation
> -- 2026-01-02 19:51:56,491 INFO     MainThread: 
> 934cd2798b5e2dbb:270625e200000000: closing query for operation
> -- 2026-01-02 19:51:56,507 INFO     MainThread: Waiting until events 
> processor syncs to event id:40243
> -- 2026-01-02 19:51:56,511 DEBUG    MainThread: Metric last-synced-event-id 
> has reached the desired value: 40243
> -- 2026-01-02 19:51:56,521 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25000
> -- 2026-01-02 19:51:56,530 INFO     MainThread: Waiting for metric value 
> 'catalog.curr-version'>=2107. Current value: 2103. total_wait: 0s
> -- 2026-01-02 19:51:56,530 INFO     MainThread: Sleeping 1s before next retry.
> -- 2026-01-02 19:51:57,532 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25000
> -- 2026-01-02 19:51:57,535 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2107. total_wait: 1.010437250137329s
> -- 2026-01-02 19:51:57,535 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25001
> -- 2026-01-02 19:51:57,546 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2107. total_wait: 0s
> -- 2026-01-02 19:51:57,546 INFO     MainThread: Getting metric: 
> catalog.curr-version from ip-172-31-61-231:25002
> -- 2026-01-02 19:51:57,557 INFO     MainThread: Metric 'catalog.curr-version' 
> has reached desired value: 2107. total_wait: 0s{noformat}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to