Skip to content

Conversation

@congbobo184
Copy link
Contributor

@congbobo184 congbobo184 commented Nov 9, 2021

Motivation

fix flaky test #12671

    `publishContext.completed(null, position.getLedgerId(), position.getEntryId())` before `transactionBuffer.syncMaxReadPositionForNormalPublish((PositionImpl) ledger.getLastConfirmedEntry())`

so return messageId for client, dont represent broker syncMaxReadPositionForNormalPublish complete

@github-actions
Copy link

github-actions bot commented Nov 9, 2021

@congbobo184:Thanks for your contribution. For this PR, do we need to update docs?
(The PR template contains info about doc, which helps others know more about the changes. Can you provide doc-related info in this and future PR descriptions? Thanks)

@congbobo184 congbobo184 requested a review from eolivelli November 9, 2021 02:30
@congbobo184 congbobo184 added the doc-not-needed Your PR changes do not impact docs label Nov 9, 2021
@github-actions
Copy link

github-actions bot commented Nov 9, 2021

@congbobo184:Thanks for providing doc info!

@congbobo184 congbobo184 added this to the 2.10.0 milestone Nov 9, 2021
@congbobo184 congbobo184 linked an issue Nov 9, 2021 that may be closed by this pull request
@codelipenghui
Copy link
Contributor

@congbobo184 could you please add more context about the flaky test and how it will be fixed by this PR?

@congbobo184 congbobo184 merged commit afa472e into apache:master Nov 18, 2021
zeo1995 pushed a commit to zeo1995/pulsar that referenced this pull request Nov 18, 2021
* up/master:
  Update deploy-bare-metal.md (apache#12432)
  [Broker] Fix producer getting incorrectly removed from topic's producers map (apache#12846)
  Add error log when new jetty client (apache#12840)
  JavaInstanceTest should be AssertEquals (apache#12836)
  [Transaction] Fix transaction flaky test testMaxReadPositionForNormalPublish (apache#12681)
  The problem of two exception handling (apache#12744)
  Fix TopicPoliciesCacheNotInitException issue. (apache#12773)
  Added local filesystem backend for package manager (apache#12708)
  [Java Client] Make userProvidedProducerName final (apache#12849)
  optimize indention in ServerCnx#handleProducer (apache#12854)
zeo1995 pushed a commit to zeo1995/pulsar that referenced this pull request Nov 18, 2021
* up/master:
  [Issue 12757][broker] add broker config isAllowAutoUpdateSchema (apache#12786)
  Update deploy-bare-metal.md (apache#12432)
  [Broker] Fix producer getting incorrectly removed from topic's producers map (apache#12846)
  Add error log when new jetty client (apache#12840)
  JavaInstanceTest should be AssertEquals (apache#12836)
  [Transaction] Fix transaction flaky test testMaxReadPositionForNormalPublish (apache#12681)
  The problem of two exception handling (apache#12744)
  Fix TopicPoliciesCacheNotInitException issue. (apache#12773)
  Added local filesystem backend for package manager (apache#12708)
dlg99 pushed a commit to dlg99/pulsar that referenced this pull request Nov 23, 2021
…Publish (apache#12681)

## Motivation
fix flaky test apache#12671


        `publishContext.completed(null, position.getLedgerId(), position.getEntryId())` before `transactionBuffer.syncMaxReadPositionForNormalPublish((PositionImpl) ledger.getLastConfirmedEntry())`

so return messageId for client, dont represent broker syncMaxReadPositionForNormalPublish complete
eolivelli pushed a commit to eolivelli/pulsar that referenced this pull request Nov 29, 2021
…Publish (apache#12681)

## Motivation
fix flaky test apache#12671


        `publishContext.completed(null, position.getLedgerId(), position.getEntryId())` before `transactionBuffer.syncMaxReadPositionForNormalPublish((PositionImpl) ledger.getLastConfirmedEntry())`

so return messageId for client, dont represent broker syncMaxReadPositionForNormalPublish complete
fxbing pushed a commit to fxbing/pulsar that referenced this pull request Dec 19, 2021
…Publish (apache#12681)

## Motivation
fix flaky test apache#12671


        `publishContext.completed(null, position.getLedgerId(), position.getEntryId())` before `transactionBuffer.syncMaxReadPositionForNormalPublish((PositionImpl) ledger.getLastConfirmedEntry())`

so return messageId for client, dont represent broker syncMaxReadPositionForNormalPublish complete
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

doc-not-needed Your PR changes do not impact docs

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Flaky-test: TransactionTest.testMaxReadPositionForNormalPublish

2 participants