fix:Fix the failure of uploading node indicator probabilities.

[weiliang110100]

No description provided.

[augmentcode]

🤖 Augment PR Summary

Summary: Fixes observable-metrics upload failures by ensuring node/table/processor sample-handler registries are always initialized and safe to access concurrently.

Changes: Initializes handler maps as final ConcurrentHashMap instances, removes lazy new HashMap() initialization blocks, and simplifies onStop cleanup to close handlers directly.

Why: Prevents missing handler registration / null-map access when aspects fire before map initialization.

Technical Notes: ConcurrentHashMap rejects null keys/values, so any call sites using a potentially-null key must be guarded.

_{🤖 Was this summary useful? React with 👍 or 👎}

[augmentcode]

Review completed. 1 suggestions posted.

Comment augment review to trigger a new review at any time.

[augmentcode]

Switching these handler registries to ConcurrentHashMap means null keys/values will now throw NPE. In handleWriteRecordFunc, targetTableName can be null (HashBiMap.create(...).inverse().get(table) miss) and is passed to containsKey/get, which would now crash and differs from prior HashMap behavior.

Severity: medium

Other Locations

• iengine/modules/observable-module/src/main/java/io/tapdata/observable/metric/ObservableAspectTask.java:507

_{🤖 Was this useful? React with 👍 or 👎, or 🚀 if it prevented an incident/outage.}