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/04/21 11:32:54 UTC

[GitHub] [pulsar] kirill-kosenko opened a new issue #10306: [Transactions]. Transaction is not aborted after timeout

kirill-kosenko opened a new issue #10306:
URL: https://github.com/apache/pulsar/issues/10306


   Hello
   I'm running into an issue with Pulsar Transactions, here are the details:
   I'm following the documentation:
   ```
   Transaction txn = pulsarClient
        .newTransaction()
        .withTransactionTimeout(5, TimeUnit.MINUTES)
        .build()
        .get();
   Message<String> message = sourceConsumer.receive();
   sourceConsumer.acknowledgeAsync(message.getMessageId(), txn);
   sinkProducer.newMessage(txn).value("sink data").sendAsync();
   
   txn.commit().get();
   ```
   Before commiting the transaction  `txn.commit().get()` I kill the app process.
   However after waiting for 5 mins(Transaction timeout) if I restart app and try to process the same message with commiting the transaction
   I get an exception:
   ```
   org.apache.pulsar.client.api.PulsarClientException$TransactionConflictException: org.apache.pulsar.transaction.common.exception.TransactionConflictException: [persistent://public/default/test-events-partition-0][test-subscription] Transaction:(1,1) try to ack message:1307:1 in pending ack status.
   ```
   Did I miss something?
   Hope it was clear
   


-- 
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [pulsar] congbobo184 commented on issue #10306: [Transactions]. Transaction is not aborted after timeout

Posted by GitBox <gi...@apache.org>.
congbobo184 commented on issue #10306:
URL: https://github.com/apache/pulsar/issues/10306#issuecomment-833150222


   https://github.com/apache/pulsar/pull/10366
   https://github.com/apache/pulsar/pull/10323
   have been fixed, the you can use master branch to check still have this problem.


-- 
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [pulsar] truongninh commented on issue #10306: [Transactions]. Transaction is not aborted after timeout

Posted by GitBox <gi...@apache.org>.
truongninh commented on issue #10306:
URL: https://github.com/apache/pulsar/issues/10306#issuecomment-832757046


   @gaoran10, @congbobo184,do you have any idea or plan how to fix this. This is a minor blocker for us while using Pulsar in our system.
   
   It seems to be only issue with messages with no TTL (default settings). Or when we restart PulsarClient with same subscription name.
   
   we would love to contribute to fix this but need a bit more guidance here.


-- 
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [pulsar] congbobo184 edited a comment on issue #10306: [Transactions]. Transaction is not aborted after timeout

Posted by GitBox <gi...@apache.org>.
congbobo184 edited a comment on issue #10306:
URL: https://github.com/apache/pulsar/issues/10306#issuecomment-833150222


   https://github.com/apache/pulsar/pull/10366
   https://github.com/apache/pulsar/pull/10323
   have been fixed, you can use master branch to check still have this problem.


-- 
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [pulsar] truongninh commented on issue #10306: [Transactions]. Transaction is not aborted after timeout

Posted by GitBox <gi...@apache.org>.
truongninh commented on issue #10306:
URL: https://github.com/apache/pulsar/issues/10306#issuecomment-833169570


   Lovely, thanks very much @congbobo184 for the quick response. 


-- 
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [pulsar] congbobo184 edited a comment on issue #10306: [Transactions]. Transaction is not aborted after timeout

Posted by GitBox <gi...@apache.org>.
congbobo184 edited a comment on issue #10306:
URL: https://github.com/apache/pulsar/issues/10306#issuecomment-833150222


   https://github.com/apache/pulsar/pull/10366
   https://github.com/apache/pulsar/pull/10323
   have been fixed, you can use master branch to check if there is still have this problem.


-- 
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



[GitHub] [pulsar] codelipenghui commented on issue #10306: [Transactions]. Transaction is not aborted after timeout

Posted by GitBox <gi...@apache.org>.
codelipenghui commented on issue #10306:
URL: https://github.com/apache/pulsar/issues/10306#issuecomment-1058891194


   The issue had no activity for 30 days, mark with Stale label.


-- 
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