Skip to content

Pipe: Fix delete inclusion aliases and metrics maps#18002

Merged
jt2594838 merged 1 commit into
apache:masterfrom
Caideyipi:fix-pipe-inclusion-options-metrics
Jun 23, 2026
Merged

Pipe: Fix delete inclusion aliases and metrics maps#18002
jt2594838 merged 1 commit into
apache:masterfrom
Caideyipi:fix-pipe-inclusion-options-metrics

Conversation

@Caideyipi

Copy link
Copy Markdown
Collaborator

Description

This PR fixes two small Pipe issues:

  • Corrects the delete and schema.delete inclusion aliases to use the legal option schema.timeseries.ordinary.drop instead of the nonexistent schema.timeseries.ordinary.delete.
  • Uses ConcurrentHashMap for DataNode pipe processor/sink metric task registries, matching the existing concurrent metric map usage and avoiding unsynchronized access during metric bind/unbind and task register/deregister.

Tests

  • mvn -Ddevelocity.off=true -pl iotdb-core/node-commons -Dtest=PipeInclusionOptionsTest test
  • mvn -Ddevelocity.off=true -pl iotdb-core/node-commons,iotdb-core/datanode spotless:apply
  • git diff --check

@jt2594838 jt2594838 merged commit b6c217a into apache:master Jun 23, 2026
40 checks passed
@jt2594838 jt2594838 deleted the fix-pipe-inclusion-options-metrics branch June 23, 2026 02:22
MileaRobertStefan pushed a commit to MileaRobertStefan/iotdb that referenced this pull request Jun 26, 2026
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.

2 participants