Skip to content

[To dev/1.3] Subscription: support consumer timeout and idle disconnect#17300

Open
VGalaxies wants to merge 1 commit intoapache:dev/1.3from
VGalaxies:codex/cherry-pick-17293-to-dev-1.3
Open

[To dev/1.3] Subscription: support consumer timeout and idle disconnect#17300
VGalaxies wants to merge 1 commit intoapache:dev/1.3from
VGalaxies:codex/cherry-pick-17293-to-dev-1.3

Conversation

@VGalaxies
Copy link
Contributor

cherry-pick #17293 to https://github.com/apache/iotdb/tree/dev/1.3

Summary

  • backport consumer-side connectionTimeoutInMs plumbing to the older dev/1.3 subscription client layout
  • add server-side idle disconnect based on subscription heartbeat inactivity and reuse closeConsumer(...) for timeout-triggered cleanup
  • add receiver timeout coverage for SubscriptionReceiverV1

Verification

  • mvn -T 8 spotless:apply -P with-integration-tests
  • attempted mvn -T 8 -pl iotdb-core/datanode -am -Dtest=org.apache.iotdb.db.subscription.receiver.SubscriptionReceiverV1Test -Dsurefire.failIfNoSpecifiedTests=false test, but the build stops in the existing DataNode FMPP codegen step with ArithmeticUnaryColumnTransformer.ftl missing mathematicalDataType before reaching the subscription test
  • per request, I did not continue running unit-test commands after that point

This PR was primarily authored with Codex using gpt-5.4 xhigh and then hand-reviewed by me. I AM responsible for every change made in this PR. I aimed to keep it aligned with our goals, though I may have missed minor issues. Please flag anything that feels off, I'll fix it quickly.

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.

1 participant