Skip to content

IGNITE-29107 Add ClientConnector metric for current peak of running compute tasks - #13661

Merged
shishkovilja merged 13 commits into
apache:masterfrom
shishkovilja:ignite-29107
Oct 27, 2026
Merged

shishkovilja merged 13 commits into
apache:masterfrom
shishkovilja:ignite-29107

Conversation

@shishkovilja

Copy link
Copy Markdown
Contributor

No description provided.

@shishkovilja
shishkovilja force-pushed the ignite-29107 branch 2 times, most recently from f3de6ff to 565cbba Compare October 14, 2026 12:10
@ignitetcbot

Copy link
Copy Markdown
Contributor

TCBot Test Analysis

Possible Blockers (0)

No blockers found.

New Tests (3)

  • Basic 1: 3 tests
    • IgniteBasicTestSuite: ClientListenerMetricsTest.testComputeTasksMetricsAfterClientDisconnect - PASSED
    • IgniteBasicTestSuite: ClientListenerMetricsTest.testComputeTasksMetricsComputeDisabled - PASSED
    • IgniteBasicTestSuite: ClientListenerMetricsTest.testComputeTasksMetrics - PASSED

@shishkovilja
shishkovilja force-pushed the ignite-29107 branch 2 times, most recently from 0f3f676 to 164399c Compare October 19, 2026 10:26
@shishkovilja shishkovilja changed the title IGNITE-29107 Add ClientConnector metrics for current and max active compute tasks IGNITE-29107 Add ClientConnector metric for current peak of running comute tasks Oct 19, 2026
@shishkovilja shishkovilja changed the title IGNITE-29107 Add ClientConnector metric for current peak of running comute tasks IGNITE-29107 Add ClientConnector metric for current peak of running compute tasks Oct 19, 2026
@ignitetcbot

Copy link
Copy Markdown
Contributor

TCBot Test Analysis

Possible Blockers (0)

No blockers found.

New Tests (5)

  • Basic 1: 5 tests
    • IgniteBasicTestSuite: ClientListenerMetricsTest.testComputeTasksMetricOnLongRunningTasks - PASSED
    • IgniteBasicTestSuite: ClientListenerMetricsTest.testComputeTasksMetricOnRejectedTask - PASSED
    • IgniteBasicTestSuite: ClientListenerMetricsTest.testComputeTasksMetricsAfterClientDisconnect - PASSED
    • IgniteBasicTestSuite: ClientListenerMetricsTest.testComputeTasksMetricsComputeDisabled - PASSED
    • IgniteBasicTestSuite: ClientListenerMetricsTest.testComputeTasksMetrics - PASSED

Comment thread docs/_docs/monitoring-metrics/new-metrics.adoc Outdated
Comment thread docs/_docs/monitoring-metrics/new-metrics-system.adoc Outdated
Comment thread docs/_docs/monitoring-metrics/system-views.adoc Outdated
long peak = super.value();

// The current value can not exceed the limit, so there is no need to calculate it.
return peak >= limit ? peak : Math.max(peak, cur.getAsLong());

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

cur can be more than max only when metric is not updated more than time interval, in this case value is 0 and only in this case we need to calculate cur. limit filed is not required

@shishkovilja shishkovilja Oct 23, 2026 •

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Limit

Limit is required currently because we should not re-calculate metric from sessions values:

  1. Limit <=0 - in this case compute taks are disabled for thin client. In fact, 0 is the current value.
  2. Value >= limit - in this case no new tasks will be executed. In fact, value == limit.

Current and zero

cur can be more than max only when metric is not updated more than time interval

No, it can be such situation:

  1. Session 1 starts Task1, Task2
  2. Interval was exceeded
  3. Task1, Task2 are still running, but metric is zero.
  4. Session 2 starts Task3
  5. Metric value will be updated to 1, not 0, so value() will not be re-calculated and we get incorrect value - 1 insead of 3.

However, I'll try to reduce re-calculations.

@ignitetcbot

Copy link
Copy Markdown
Contributor

TCBot Test Analysis

Possible Blockers (0)

No blockers found.

New Tests (88)

  • Basic 1: 5 tests
    • IgniteBasicTestSuite: ClientListenerMetricsTest.testComputeTasksMetricOnLongRunningTasks - PASSED
    • IgniteBasicTestSuite: ClientListenerMetricsTest.testComputeTasksMetricOnRejectedTask - PASSED
    • IgniteBasicTestSuite: ClientListenerMetricsTest.testComputeTasksMetricsAfterClientDisconnect - PASSED
    • IgniteBasicTestSuite: ClientListenerMetricsTest.testComputeTasksMetricsComputeDisabled - PASSED
    • IgniteBasicTestSuite: ClientListenerMetricsTest.testComputeTasksMetrics - PASSED
  • Cache 1: 83 tests
    • IgniteBinaryCacheTestSuite: jdbc.CacheJdbcPojoStoreBinaryMarshallerWithSqlEscapeSelfTest - PASSED
    • IgniteBinaryCacheTestSuite: jdbc.CacheJdbcPojoStoreBinaryMarshallerStoreKeepBinaryWithSqlEscapeSelfTest - PASSED
    • IgniteBinaryCacheTestSuite: jdbc.CacheJdbcPojoStoreBinaryMarshallerSelfTest - PASSED
    • IgniteBinaryCacheTestSuite: jdbc.CacheJdbcPojoStoreBinaryMarshallerStoreKeepBinarySelfTest - PASSED
    • IgniteBinaryCacheTestSuite: jdbc.CacheJdbcPojoWriteBehindConnectionLeakTest - PASSED
    • IgniteBinaryCacheTestSuite: store.GridCacheBalancingStoreSelfTest - PASSED
    • IgniteBinaryCacheTestSuite: jdbc.CacheJdbcPojoStoreMultitreadedSelfTest - PASSED
    • IgniteBinaryCacheTestSuite: jdbc.CacheJdbcPojoWriteBehindStoreWithCoalescingTest - PASSED
    • IgniteBinaryCacheTestSuite: cache.DataStorageConfigurationValidationTest - PASSED
    • IgniteBinaryCacheTestSuite: cache.CacheWithDifferentDataRegionConfigurationTest - PASSED
    • ... and 73 more new tests

@shishkovilja
shishkovilja merged commit 9b2ab51 into apache:master Oct 27, 2026
5 checks passed
@shishkovilja
shishkovilja deleted the ignite-29107 branch October 27, 2026 05:35
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants