You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/08/09 12:11:53 UTC
[GitHub] [pulsar] gaozhangmin opened a new issue #11604: Got exception java.lang.UnsupportedOperationException: MessageId is null。Using Reader
gaozhangmin opened a new issue #11604:
URL: https://github.com/apache/pulsar/issues/11604
Got exception when consumer using reader:
Got exception java.lang.UnsupportedOperationException: MessageId is null。
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] leizhiyuan commented on issue #11604: Got exception java.lang.UnsupportedOperationException: MessageId is null。Using Reader
Posted by GitBox <gi...@apache.org>.
leizhiyuan commented on issue #11604:
URL: https://github.com/apache/pulsar/issues/11604#issuecomment-895179218
![image](https://user-images.githubusercontent.com/2684384/128705475-9ea3ebf1-b5c2-470f-b6bc-41ebea06ae57.png)
They add a precheck for messageId
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] leizhiyuan commented on issue #11604: Got exception java.lang.UnsupportedOperationException: MessageId is null。Using Reader
Posted by GitBox <gi...@apache.org>.
leizhiyuan commented on issue #11604:
URL: https://github.com/apache/pulsar/issues/11604#issuecomment-895182485
![image](https://user-images.githubusercontent.com/2684384/128705973-f4ef264f-ff43-4b46-a2b4-672d3f1b2147.png)
maybe there is a concurrent bug。
```
if (lastCumulativeAck.messageId == null) {. // 1. is not null
return false;
}
if (messageId.compareTo(lastCumulativeAck.messageId) <= 0) { //1.another thread change the messageId to null
// Already included in a cumulative ack
return true;
} else {
return pendingIndividualAcks.contains(messageId);
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] gaozhangmin commented on issue #11604: Got exception java.lang.UnsupportedOperationException: MessageId is null。Using Reader
Posted by GitBox <gi...@apache.org>.
gaozhangmin commented on issue #11604:
URL: https://github.com/apache/pulsar/issues/11604#issuecomment-895180330
> which version do you use?
2.8.0
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] merlimat closed issue #11604: Got exception java.lang.UnsupportedOperationException: MessageId is null。Using Reader
Posted by GitBox <gi...@apache.org>.
merlimat closed issue #11604:
URL: https://github.com/apache/pulsar/issues/11604
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] leizhiyuan edited a comment on issue #11604: Got exception java.lang.UnsupportedOperationException: MessageId is null。Using Reader
Posted by GitBox <gi...@apache.org>.
leizhiyuan edited a comment on issue #11604:
URL: https://github.com/apache/pulsar/issues/11604#issuecomment-895182485
![image](https://user-images.githubusercontent.com/2684384/128705973-f4ef264f-ff43-4b46-a2b4-672d3f1b2147.png)
maybe there is a concurrent bug。
```
if (lastCumulativeAck.messageId == null) {. // 1. is not null
return false;
}
if (messageId.compareTo(lastCumulativeAck.messageId) <= 0) { //2.another thread change the messageId to null
// Already included in a cumulative ack
return true;
} else {
return pendingIndividualAcks.contains(messageId);
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] leizhiyuan commented on issue #11604: Got exception java.lang.UnsupportedOperationException: MessageId is null。Using Reader
Posted by GitBox <gi...@apache.org>.
leizhiyuan commented on issue #11604:
URL: https://github.com/apache/pulsar/issues/11604#issuecomment-895178912
which version do you use?
this pr seems fixed it
https://github.com/apache/pulsar/pull/10586
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org