This is an automated email from the ASF dual-hosted git repository. github-merge-queue[bot] pushed a commit to branch gh-readonly-queue/dev/pr-12453-87ed0afe0f783eda1b1f3ac6f0ac9fadedcb4f98 in repository https://gitbox.apache.org/repos/asf/seatunnel.git
commit 309b15effe99423f73b6007cbe61b97bb6af7b24 Author: Goutam Adwant <[email protected]> AuthorDate: Sat Oct 3 15:56:09 2026 +0000 [Test][Zeta] Await asynchronous logical checkpoint metrics (#12453) Signed-off-by: Goutam Adwant <[email protected]> --- .../EngineStateStoreLogicalMetricExportsTest.java | 119 ++++++++++++--------- 1 file changed, 68 insertions(+), 51 deletions(-) diff --git a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/telemetry/metrics/exports/EngineStateStoreLogicalMetricExportsTest.java b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/telemetry/metrics/exports/EngineStateStoreLogicalMetricExportsTest.java index 504dc0d1bd..925cf0aa4f 100644 --- a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/telemetry/metrics/exports/EngineStateStoreLogicalMetricExportsTest.java +++ b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/telemetry/metrics/exports/EngineStateStoreLogicalMetricExportsTest.java @@ -85,58 +85,75 @@ class EngineStateStoreLogicalMetricExportsTest { seedFinishedJobStores(); seedConnectorJarRefCounters(); - List<MetricFamilySamples> metrics = - new EngineStateStoreLogicalMetricExports(instance.node).collect(); + // Logical counters are updated asynchronously by Hazelcast entry listeners. + await().atMost(10, TimeUnit.SECONDS) + .untilAsserted( + () -> { + List<MetricFamilySamples> metrics = + new EngineStateStoreLogicalMetricExports(instance.node) + .collect(); - Assertions.assertEquals( - 3d, - findSampleValue( - metrics, "engine_state_store_running_job_metrics_task_contexts", null)); - Assertions.assertEquals( - 2d, - findSampleValue( - metrics, - "engine_state_store_running_job_metrics_active_partition_keys", - null)); - Assertions.assertEquals( - 1d, findSampleValue(metrics, "engine_state_store_checkpoint_monitor_jobs", null)); - Assertions.assertEquals( - 1d, - findSampleValue( - metrics, - "engine_state_store_checkpoint_monitor_in_progress_checkpoints", - null)); - Assertions.assertEquals( - 2d, - findSampleValue( - metrics, - "engine_state_store_checkpoint_monitor_retained_history_entries", - null)); - Assertions.assertEquals( - 1d, - findSampleValue( - metrics, - "engine_state_store_finished_job_records", - Constant.IMAP_FINISHED_JOB_STATE)); - Assertions.assertEquals( - 1d, - findSampleValue( - metrics, - "engine_state_store_finished_job_records", - Constant.IMAP_FINISHED_JOB_METRICS)); - Assertions.assertEquals( - 1d, - findSampleValue( - metrics, - "engine_state_store_finished_job_records", - Constant.IMAP_FINISHED_JOB_VERTEX_INFO)); - Assertions.assertEquals( - 1d, - findSampleValue(metrics, "engine_state_store_connector_jar_tracked_jars", null)); - Assertions.assertEquals( - 2d, - findSampleValue( - metrics, "engine_state_store_connector_jar_total_references", null)); + Assertions.assertEquals( + 3d, + findSampleValue( + metrics, + "engine_state_store_running_job_metrics_task_contexts", + null)); + Assertions.assertEquals( + 2d, + findSampleValue( + metrics, + "engine_state_store_running_job_metrics_active_partition_keys", + null)); + Assertions.assertEquals( + 1d, + findSampleValue( + metrics, + "engine_state_store_checkpoint_monitor_jobs", + null)); + Assertions.assertEquals( + 1d, + findSampleValue( + metrics, + "engine_state_store_checkpoint_monitor_in_progress_checkpoints", + null)); + Assertions.assertEquals( + 2d, + findSampleValue( + metrics, + "engine_state_store_checkpoint_monitor_retained_history_entries", + null)); + Assertions.assertEquals( + 1d, + findSampleValue( + metrics, + "engine_state_store_finished_job_records", + Constant.IMAP_FINISHED_JOB_STATE)); + Assertions.assertEquals( + 1d, + findSampleValue( + metrics, + "engine_state_store_finished_job_records", + Constant.IMAP_FINISHED_JOB_METRICS)); + Assertions.assertEquals( + 1d, + findSampleValue( + metrics, + "engine_state_store_finished_job_records", + Constant.IMAP_FINISHED_JOB_VERTEX_INFO)); + Assertions.assertEquals( + 1d, + findSampleValue( + metrics, + "engine_state_store_connector_jar_tracked_jars", + null)); + Assertions.assertEquals( + 2d, + findSampleValue( + metrics, + "engine_state_store_connector_jar_total_references", + null)); + }); } @Test
