Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Intermittent test failure in ManagedLedgerBkTest.testConcurrentMarkDelete #16

Closed
merlimat opened this issue Sep 13, 2016 · 0 comments
Closed
Assignees
Milestone

Comments

@merlimat
Copy link
Contributor

Seen failing once on Travis build:

Tests run: 218, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 110.82 sec <<< FAILURE! - in TestSuite
testConcurrentMarkDelete(org.apache.bookkeeper.mledger.impl.ManagedLedgerBkTest)  Time elapsed: 42.069 sec  <<< FAILURE!
java.util.concurrent.ExecutionException: org.apache.bookkeeper.mledger.ManagedLedgerException$MetaStoreException: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss
    at org.apache.bookkeeper.mledger.impl.ManagedLedgerBkTest.testConcurrentMarkDelete(ManagedLedgerBkTest.java:273)
Caused by: org.apache.bookkeeper.mledger.ManagedLedgerException$MetaStoreException: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss
Caused by: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss
Results :
Failed tests: 
  ManagedLedgerBkTest.testConcurrentMarkDelete:273 » Execution org.apache.bookke...
@merlimat merlimat added this to the 1.15 milestone Sep 13, 2016
@merlimat merlimat self-assigned this Sep 13, 2016
merlimat added a commit to merlimat/pulsar that referenced this issue Sep 22, 2016
…mplete before shutting down

Fixes apache#16: Intermittent test failure in ManagedLedgerBkTest.testConcurrentMarkDelete
jai1 pushed a commit that referenced this issue Feb 14, 2018
sijie added a commit to sijie/pulsar that referenced this issue Mar 4, 2018
* Integrate spawner in cli

* add scripts to run pulsar functions

* add example

* Make pulsar-functions run
hrsakai pushed a commit to hrsakai/pulsar that referenced this issue Dec 10, 2020
Impl consumer logic for go client:
Impl consumer logic for go client

Non-partition:

  receive
  ack
 ack
 ackID
 ackCumulative
 ackCumulativeID
  Seek
  Close
  Unsubscribe
  listener
Partition:

  receive
  ack
 ack
 ackID
 ackCumulative
 ackCumulativeID
  Seek
  Close
  Unsubscribe
  listener
hangc0276 referenced this issue in hangc0276/pulsar May 26, 2021
Fix #16 
In KoP we would like to keep batch message. In Kafka message passed into Broker in format `Records`, each `Records` contains 1 or more `Record`. This is similar to the batched Message in Pulsar.
But because we have to turn Kafka `Records` into Pulsar BatchedMessage to make message could both be recognized by both Pulsar and Kafka client , we have to read each Record out from Records, and turn into Pulsar Message, This may involve some overhead of un-batch/re-batch. 

changes:
- move message produce/consume logic from KafkaRequestHandler.java into separate files.
- add support for batch produce/consume.
- add support for message headers.
- change offset format in MessageRecordUtils.java to support batch index.
- add test for added code.
dlg99 referenced this issue in dlg99/pulsar Feb 28, 2022
* Include correct bookkeeper jars in pulsar-client jar

* Include correct bookkeeper jars in pulsar-admin-client jar
dlg99 referenced this issue in dlg99/pulsar Mar 4, 2022
* Include correct bookkeeper jars in pulsar-client jar

* Include correct bookkeeper jars in pulsar-admin-client jar

(cherry picked from commit c8b1e6f)
dlg99 referenced this issue in dlg99/pulsar May 11, 2022
* Include correct bookkeeper jars in pulsar-client jar

* Include correct bookkeeper jars in pulsar-admin-client jar

(cherry picked from commit c8b1e6f)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

1 participant