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

[run-tests] feat:allow client skips the non-continued deleted ranges stats #4

Closed
wants to merge 74 commits into from

Commits on Oct 19, 2022

  1. Configuration menu
    Copy the full SHA
    26b47ff View commit details
    Browse the repository at this point in the history
  2. Configuration menu
    Copy the full SHA
    7e5cad7 View commit details
    Browse the repository at this point in the history
  3. Configuration menu
    Copy the full SHA
    912f344 View commit details
    Browse the repository at this point in the history
  4. [improve][broker]consumer backlog eviction policy should not reset re…

    …ad position for consumer (apache#18037)
    
    ### Motivation
    Fixes apache#18036
    
    ### Modifications
    - The backlog eviction policy should use `asyncMarkDelete` instead of `resetCursor` in order to move the mark delete position.
    HQebupt authored Oct 19, 2022
    Configuration menu
    Copy the full SHA
    7404e0d View commit details
    Browse the repository at this point in the history

Commits on Oct 20, 2022

  1. [fix][test] Fix flaky test org.apache.pulsar.broker.service.persisten…

    …t.PersistentSubscriptionMessageDispatchStreamingDispatcherThrottlingTest#setup (apache#18115)
    lordcheng10 authored Oct 20, 2022
    Configuration menu
    Copy the full SHA
    3eac221 View commit details
    Browse the repository at this point in the history
  2. Configuration menu
    Copy the full SHA
    1225a24 View commit details
    Browse the repository at this point in the history
  3. Configuration menu
    Copy the full SHA
    10eaac2 View commit details
    Browse the repository at this point in the history
  4. Configuration menu
    Copy the full SHA
    de3dbaa View commit details
    Browse the repository at this point in the history
  5. Configuration menu
    Copy the full SHA
    3783ad2 View commit details
    Browse the repository at this point in the history
  6. Configuration menu
    Copy the full SHA
    cec8c91 View commit details
    Browse the repository at this point in the history
  7. [improve][doc] Add code example for WebSocket API to use TLS with CLI…

    … tools (apache#15485)
    
    * add a new section for websocket API
    
    * Update site2/docs/security-tls-transport.md
    
    Co-authored-by: Yunze Xu <[email protected]>
    
    * Update site2/docs/security-tls-transport.md
    
    Co-authored-by: Yunze Xu <[email protected]>
    
    * Update site2/docs/security-tls-transport.md
    
    Co-authored-by: Yunze Xu <[email protected]>
    
    * updates
    
    * updates
    
    * updates
    
    * update code snippet as per review comments
    
    Co-authored-by: Yunze Xu <[email protected]>
    momo-jun and BewareMyPower authored Oct 20, 2022
    Configuration menu
    Copy the full SHA
    5b452d1 View commit details
    Browse the repository at this point in the history
  8. [feat] [broker] PIP-188 support blue-green cluster migration [part-1] (

    …apache#17962)
    
    * [feat][PIP-188] support blue-green cluster migration [part-1]
    
    Add blue-green cluster migration
    
    Fix dependency
    
    * cleanup
    rdhabalia authored Oct 20, 2022
    Configuration menu
    Copy the full SHA
    b0945d1 View commit details
    Browse the repository at this point in the history
  9. Configuration menu
    Copy the full SHA
    cbf5cf5 View commit details
    Browse the repository at this point in the history
  10. Configuration menu
    Copy the full SHA
    e5b3ffd View commit details
    Browse the repository at this point in the history
  11. [improve][io] JDBC sinks: implement JDBC Batch API (apache#18017)

    * [improve][io] JDBC sinks: implement JDBC Batch API
    
    * more tests and transactions support
    
    * remove .db files
    
    * doc
    
    * fix batch results and thread safey
    
    * add next flush test - fix doc - improve code readability
    nicoloboschi authored Oct 20, 2022
    Configuration menu
    Copy the full SHA
    7b52a92 View commit details
    Browse the repository at this point in the history
  12. [fix][doc] Point Python and C++ docs to new GitHub repos (apache#18140)

    * [fix][doc] Point Python and C++ docs to new GitHub repos
    
    * Fix cpp examples link
    
    * Add notice to redirect any users
    michaeljmarshall authored Oct 20, 2022
    Configuration menu
    Copy the full SHA
    a4d00eb View commit details
    Browse the repository at this point in the history
  13. [fix][broker] PulsarRegistrationClient - implement getAllBookies and …

    …follow BookieServiceInfo updates (apache#18133)
    
    * [fix] PulsarRegistrationClient - implement getAllBookies and follow BookieServiceInfo updates
    
    * remove debug
    eolivelli authored Oct 20, 2022
    Configuration menu
    Copy the full SHA
    0c326c0 View commit details
    Browse the repository at this point in the history

Commits on Oct 21, 2022

  1. [improve][client] Support MAX_ACK_GROUP_SIZE configurable (apache#18107)

    ### Motivation
    The current MAX_ACK_GROUP_SIZE is fixed at 1000, increase the configuration acknowledgementsGroupSize, support MAX_ACK_GROUP_SIZE configurable:
    https://github.com/apache/pulsar/blob/afcdbf0e2b5fb905e1f82f0220436f8f9ec0c742/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java#L63-L64
    
    
    ### Modifications
    1.Add configuration acknowledgementsGroupSize;
    lordcheng10 authored Oct 21, 2022
    Configuration menu
    Copy the full SHA
    092d3b3 View commit details
    Browse the repository at this point in the history
  2. Configuration menu
    Copy the full SHA
    639393d View commit details
    Browse the repository at this point in the history
  3. Configuration menu
    Copy the full SHA
    b4bba3a View commit details
    Browse the repository at this point in the history
  4. [feat][ci] check style for all source code (apache#18142)

    * [feat][ci] check style for all source code
    
    This closes apache#18131.
    
    * fix violations
    
    Signed-off-by: tison <[email protected]>
    
    * no snapshot update
    
    Signed-off-by: tison <[email protected]>
    
    * remove mysterious dependency
    
    Signed-off-by: tison <[email protected]>
    
    Signed-off-by: tison <[email protected]>
    tisonkun authored Oct 21, 2022
    Configuration menu
    Copy the full SHA
    ae7722b View commit details
    Browse the repository at this point in the history
  5. When accumulating acks, update the batch index in batchDeletedIndexes…

    … and check whether it is greater than the batch index of the previous ack (apache#18042)
    
    Co-authored-by: leolinchen <[email protected]>
    lordcheng10 and leolinchen authored Oct 21, 2022
    Configuration menu
    Copy the full SHA
    fa328a4 View commit details
    Browse the repository at this point in the history
  6. Configuration menu
    Copy the full SHA
    0854032 View commit details
    Browse the repository at this point in the history
  7. Configuration menu
    Copy the full SHA
    330654a View commit details
    Browse the repository at this point in the history

Commits on Oct 22, 2022

  1. Configuration menu
    Copy the full SHA
    845d992 View commit details
    Browse the repository at this point in the history

Commits on Oct 23, 2022

  1. Configuration menu
    Copy the full SHA
    c55be38 View commit details
    Browse the repository at this point in the history
  2. Configuration menu
    Copy the full SHA
    55d6c5f View commit details
    Browse the repository at this point in the history

Commits on Oct 24, 2022

  1. Configuration menu
    Copy the full SHA
    b6d519c View commit details
    Browse the repository at this point in the history
  2. Configuration menu
    Copy the full SHA
    bdbbb1e View commit details
    Browse the repository at this point in the history
  3. Configuration menu
    Copy the full SHA
    e8db584 View commit details
    Browse the repository at this point in the history
  4. Configuration menu
    Copy the full SHA
    39270f0 View commit details
    Browse the repository at this point in the history
  5. [feat][broker] Segmented transaction buffer snapshot segment and inde…

    …x system topic (apache#16931)
    
    Master Issue: apache#16913
    ### Motivation
    Implement system topic client for snapshot segment topic and index topic to send segment snapshots or indexes.
    The configuration `transactionBufferSegmentedSnapshotEnabled` is used in the Transaction Buffer to determine which `AbortedTxnProcessor` is adopted by this TB.
    ### Modification
    
    In the new implementation of the Transaction Buffer Snapshot System topic, because the system topic that needs to be processed has changed from the original one to three with different schemes, we have added generics to the TransactionBufferSnapshotBaseSystemTopicClient class and the SystemTopicTxnBufferSnapshotService<T> class.
    And Pulsar Service maintains a factory class TransactionBufferSnapshotServiceFactory used to obtain SystemTopicTxnBufferSnapshotService.
    This way, we can obtain the required System topic client through pulsarService to read and send snapshots.
    <img width="1336" alt="image" src="https://user-images.githubusercontent.com/55571188/197467173-9028e58a-79cc-4fe4-81e2-c299c568caee.png">
    liangyepianzhou authored Oct 24, 2022
    Configuration menu
    Copy the full SHA
    d211766 View commit details
    Browse the repository at this point in the history
  6. [fix][admin] Passing force parameter to deleteNamespaceBundle whe…

    …n delete namespaces (apache#18153)
    
    ### Motivation
    
    In the current implementation, don't pass the `force` parameter to `deleteNamespaceBundle` when deleting namespaces, we should pass the `force` parameter.
    
    ### Modifications
    
    Passing `force` parameter to `deleteNamespaceBundle` when delete namespaces.
    coderzc authored Oct 24, 2022
    Configuration menu
    Copy the full SHA
    d1b5c02 View commit details
    Browse the repository at this point in the history
  7. Configuration menu
    Copy the full SHA
    031e37c View commit details
    Browse the repository at this point in the history
  8. Configuration menu
    Copy the full SHA
    7fee34d View commit details
    Browse the repository at this point in the history
  9. Configuration menu
    Copy the full SHA
    e913a10 View commit details
    Browse the repository at this point in the history
  10. [fix][storage] Autorecovery default reppDnsResolverClass to ZkBookieR…

    …ackAffinityMapping (apache#15640)
    
    * [Autorecovery] Default reppDnsResolverClass to ZkBookieRackAffinityMapping
    
    * Improve documentation
    
    Fixes: apache#18012
    
    ### Motivation
    
    The current Bookkeeper configuration defaults to using `org.apache.bookkeeper.net.ScriptBasedMapping` for the `DNSToSwitchMapping` implementation. However, this default configuration does not align with the Broker's default configuration, which is `org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping`. As such, the default configuration for a Pulsar cluster does not lead to ideal rack awareness when ledgers need to be recovered. The result is that a user can configure a cluster for rack awareness and the brokers will honor that configuration, but the autorecovery process will not because it does not have the correct bookkeeper cluster topology view.
    
    I propose we configure bookkeeper to use the broker's `ZkBookieRackAffinityMapping` class. That way, autorecovery will honor the operator's configured rack awareness policies out of the box.
    
    ### Modifications
    
    * Add default value for `reppDnsResolverClass` to the `conf/bookkeeper.conf` configuration. This change effectively switches the default from `org.apache.bookkeeper.net.ScriptBasedMapping` to `org.apache.pulsar.zookeeper.ZkBookieRackAffinityMapping`.
    
    ### Verifying this change
    
    I manually verified that the `ZkBookieRackAffinityMapping` works by running some tests in a minikube cluster deployed with the DataStax helm chart. I set up 3 racks, 4 bookies, and a topic with a E=2, Qw=2, and Qa=2. I then verified that the autorecovery pod correctly discovered the racks and then identified when an ensemble was not following the rack placement policy after two bookies were removed. I documented my testing a bit more here: datastax/pulsar-helm-chart#214.
    
    ### Does this pull request potentially affect one of the following parts:
    
    It changes a default value. The tradeoff is that a user relying on the `ScriptBasedMapping` default might accidentally get switched to using the `ZkBookieRackAffinityMapping` implementation. Given that `ScriptBasedMapping` doesn't work out of the box, and that the broker's default to `ZkBookieRackAffinityMapping`, I think this is an acceptable tradeoff.
    
    - [x] `doc`
    michaeljmarshall authored Oct 24, 2022
    Configuration menu
    Copy the full SHA
    9812297 View commit details
    Browse the repository at this point in the history
  11. Configuration menu
    Copy the full SHA
    31dad38 View commit details
    Browse the repository at this point in the history
  12. [fix][doc] Reflect archived and halted repositories (apache#18067)

    * [fix][doc] Remove archived and halted repositories
    
    * Add back archived repositories
    
    For anyone who wants to revive them.
    
    Signed-off-by: tison <[email protected]>
    
    Signed-off-by: tison <[email protected]>
    tisonkun authored Oct 24, 2022
    Configuration menu
    Copy the full SHA
    573c8f6 View commit details
    Browse the repository at this point in the history

Commits on Oct 25, 2022

  1. Configuration menu
    Copy the full SHA
    91562d2 View commit details
    Browse the repository at this point in the history
  2. Configuration menu
    Copy the full SHA
    82237d3 View commit details
    Browse the repository at this point in the history
  3. Configuration menu
    Copy the full SHA
    4ffa741 View commit details
    Browse the repository at this point in the history
  4. Configuration menu
    Copy the full SHA
    ae0153c View commit details
    Browse the repository at this point in the history
  5. Configuration menu
    Copy the full SHA
    58765c1 View commit details
    Browse the repository at this point in the history
  6. Configuration menu
    Copy the full SHA
    26aec17 View commit details
    Browse the repository at this point in the history
  7. Configuration menu
    Copy the full SHA
    f63356c View commit details
    Browse the repository at this point in the history
  8. [fix][broker] do not serialize field bundleStats (apache#18150)

    * do not serialize field bundleStats
    
    * add unit test.
    
    * use org.testng.Assert.assertFalse
    
    * add apache license header
    
    * fix doc
    
    * fix doc and change the package level.
    
    Co-authored-by: fengwenzhi <[email protected]>
    thetumbled and fengwenzhi authored Oct 25, 2022
    Configuration menu
    Copy the full SHA
    6cc30c9 View commit details
    Browse the repository at this point in the history

Commits on Oct 26, 2022

  1. Configuration menu
    Copy the full SHA
    9f91d7b View commit details
    Browse the repository at this point in the history
  2. [doc] [client] [go] Add chunking to go-client doc (apache#17789)

    * add go-client chunking doc
    
    * Update site2/docs/client-libraries-go.md
    
    Co-authored-by: Zixuan Liu <[email protected]>
    
    * Update site2/docs/client-libraries-go.md
    
    Co-authored-by: Anonymitaet <[email protected]>
    
    * Update site2/docs/client-libraries-go.md
    
    Co-authored-by: Anonymitaet <[email protected]>
    
    * Update site2/docs/client-libraries-go.md
    
    Co-authored-by: Anonymitaet <[email protected]>
    
    Co-authored-by: Zixuan Liu <[email protected]>
    Co-authored-by: Anonymitaet <[email protected]>
    3 people authored Oct 26, 2022
    Configuration menu
    Copy the full SHA
    29461bd View commit details
    Browse the repository at this point in the history

Commits on Oct 27, 2022

  1. Configuration menu
    Copy the full SHA
    6657fe4 View commit details
    Browse the repository at this point in the history
  2. [improve][doc] Improve the authentication enablement workflow across …

    …multiple providers (apache#18035)
    
    * Update security-athenz.md
    
    * improve auth overview
    
    * address review comments
    
    * Improve OAuth2 authentication
    
    * improve Kerberos authentication
    
    * Update security-athenz.md
    momo-jun authored Oct 27, 2022
    Configuration menu
    Copy the full SHA
    a48bc8b View commit details
    Browse the repository at this point in the history
  3. [improve][doc] cherry-pick cpp client docs installation section (apac…

    …he#18188)
    
    * [improve][doc] cherry-pick cpp client docs installation section
    
    Signed-off-by: tison <[email protected]>
    
    * Apply suggestions from code review
    
    Co-authored-by: momo-jun <[email protected]>
    
    * Update client-libraries-cpp.md
    
    Signed-off-by: tison <[email protected]>
    Co-authored-by: momo-jun <[email protected]>
    tisonkun and momo-jun authored Oct 27, 2022
    Configuration menu
    Copy the full SHA
    59e00ba View commit details
    Browse the repository at this point in the history
  4. Configuration menu
    Copy the full SHA
    5c1f8af View commit details
    Browse the repository at this point in the history
  5. Configuration menu
    Copy the full SHA
    3d7f9e5 View commit details
    Browse the repository at this point in the history
  6. Configuration menu
    Copy the full SHA
    1c78e0a View commit details
    Browse the repository at this point in the history
  7. Configuration menu
    Copy the full SHA
    5b7c5c6 View commit details
    Browse the repository at this point in the history
  8. Configuration menu
    Copy the full SHA
    2c9e729 View commit details
    Browse the repository at this point in the history
  9. Configuration menu
    Copy the full SHA
    c7990b9 View commit details
    Browse the repository at this point in the history
  10. Configuration menu
    Copy the full SHA
    b061c6a View commit details
    Browse the repository at this point in the history
  11. Configuration menu
    Copy the full SHA
    5e3f8ba View commit details
    Browse the repository at this point in the history
  12. [fix] [pulsar-client] Fix pendingLookupRequestSemaphore leak when Ser… (

    apache#18219)
    
    ### Motivation
    https://github.com/apache/pulsar/blob/b061c6ac5833c21e483368febebd0d30679a35e1/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java#L748-L774
    The `pendingLookupRequestSemaphore` will leak when handleError. There are `LookUpRequestSemaphore` not released when removing it from `pendingRequests`
    
    related PR: apache#17856 
    
    ### Modifications
    We can't easily release the semaphore in `handleError`, because there are not only `LookUpRequest`. So release the semaphore when LookupException
    
    ### Verifying this change
    Add unit test case to cover this change
    
    ### Documentation
    
    <!-- DO NOT REMOVE THIS SECTION. CHECK THE PROPER BOX ONLY. -->
    
    - [ ] `doc-required` 
    (Your PR needs to update docs and you will update later)
    
    - [x] `doc-not-needed` 
    bug fixs, no need doc
    
    - [ ] `doc` 
    (Your PR contains doc changes)
    
    - [ ] `doc-complete`
    (Docs have been already added)
    shoothzj authored Oct 27, 2022
    Configuration menu
    Copy the full SHA
    fad3ccc View commit details
    Browse the repository at this point in the history
  13. Add HTTP Sink (apache#17581)

    cbornet authored Oct 27, 2022
    Configuration menu
    Copy the full SHA
    b193051 View commit details
    Browse the repository at this point in the history

Commits on Oct 28, 2022

  1. Configuration menu
    Copy the full SHA
    8f8637a View commit details
    Browse the repository at this point in the history
  2. Configuration menu
    Copy the full SHA
    d86a50c View commit details
    Browse the repository at this point in the history
  3. Configuration menu
    Copy the full SHA
    7a88cb7 View commit details
    Browse the repository at this point in the history
  4. Configuration menu
    Copy the full SHA
    069ac87 View commit details
    Browse the repository at this point in the history
  5. Configuration menu
    Copy the full SHA
    b7b9239 View commit details
    Browse the repository at this point in the history
  6. [fix][offload] Fix the problem that ManagedLedger does not release lo…

    …cks in some cases when offload (apache#18221)
    tjiuming authored Oct 28, 2022
    Configuration menu
    Copy the full SHA
    3f5acfe View commit details
    Browse the repository at this point in the history
  7. Configuration menu
    Copy the full SHA
    67a3de7 View commit details
    Browse the repository at this point in the history
  8. [fix] Combination of autocreate + forced delete of partitioned topic …

    …with active consumer leaves topic metadata inconsistent. (apache#18193)
    dlg99 authored Oct 28, 2022
    Configuration menu
    Copy the full SHA
    3fdbc9f View commit details
    Browse the repository at this point in the history
  9. Configuration menu
    Copy the full SHA
    46c0438 View commit details
    Browse the repository at this point in the history

Commits on Oct 31, 2022

  1. Configuration menu
    Copy the full SHA
    a31e804 View commit details
    Browse the repository at this point in the history

Commits on Nov 1, 2022

  1. chore: fix apiParam

    leizhiyuan committed Nov 1, 2022
    Configuration menu
    Copy the full SHA
    8a2e854 View commit details
    Browse the repository at this point in the history

Commits on Nov 2, 2022

  1. feat: reform getStats

    leizhiyuan committed Nov 2, 2022
    Configuration menu
    Copy the full SHA
    8460be2 View commit details
    Browse the repository at this point in the history