You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by GitBox <gi...@apache.org> on 2026/10/09 10:07:41 UTC

[GH] (rocketmq/fix/cold-data-flow-control-npe): Workflow run "Build and Run Tests by Maven" failed!

The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git/fix/cold-data-flow-control-npe has failed.
Run started by GitHub user zjncs (triggered by zjncs).

Head commit for run:
d7821670091e1512a35ff62368f80374c5ccaa2b / zjncs <18...@163.com>
[ISSUE #B3] Read the consume type from the compensation table in the cold-data flow-control path

The cold-data flow-control branch of PullMessageProcessor read the consume
type with ConsumerManager.getConsumerGroupInfo(group), which only sees the
live consumer table. Pull requests that carry their subscription (proxy /
lite-pull traffic) never registered the group there, so once the group is
flagged for cold-data flow control and the pulled offset is cold, the
processor dereferenced null and failed the request with an NPE.

The group's basic info (consume type, message model) is already
compensated into consumerCompensationTable a few lines earlier for exactly
these pull styles, so read it with getConsumerGroupInfo(group, true) like
ConsumerLagCalculator does, and fall back to the passive flow-control
response if even the compensation table has no record.

Signed-off-by: zjncs <18...@163.com>

Report URL: https://github.com/apache/rocketmq/actions/runs/34338093826

With regards,
GitHub Actions via GitBox