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

[feat][admin] Introduce unload flag in ns-isolation-policy set call #1

Merged
merged 828 commits into from
Sep 4, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
828 commits
Select commit Hold shift + click to select a range
88feb87
[fix][ml] Remove duplicated field initialization of ML (#22676)
dao-jun May 9, 2024
8f015d8
[fix][broker] usedLocallySinceLastReport should always be reset (#22672)
nodece May 9, 2024
bd4c57d
[fix][broker] Fix geo-replication admin client url (#22584)
Demogorgon314 May 9, 2024
566330c
[fix][offload] Fix OOM in tiered storage, caused by unbounded offsets…
lhotari May 9, 2024
03a4995
[improve][offload] Replace usage of shaded class in OffsetsCache (#22…
lhotari May 9, 2024
0fd223d
[improve] [pip] PIP-349: Add additionalSystemCursorNames ignore list …
hangc0276 May 9, 2024
bed032e
[improve] [broker] Add additionalSystemCursorNames ignore list for TT…
hangc0276 May 9, 2024
253e650
[fix][broker] Fix ProducerBusy issue due to incorrect userCreatedProd…
hrzzzz May 9, 2024
ff4853e
[fix] [broker] Fix configurationMetadataSyncEventTopic is marked supp…
poorbarcode May 10, 2024
774a5d4
[fix][broker] Fix cursor should use latest ledger config (#22644)
nodece May 10, 2024
b7ec89a
[fix] [doc] fix the class name of transaction exception. (#22687)
thetumbled May 10, 2024
b56f238
[fix][client] Fix ReaderBuilder doest not give illegalArgument on con…
rdhabalia May 10, 2024
2cfd959
[fix][sec] Upgrade postgresql version to avoid CVE-2024-1597 (#22635)
nikhilerigila09 May 10, 2024
d77c5de
[improve] [log] Print source client addr when enabled haProxyProtocol…
poorbarcode May 10, 2024
e558cfe
[feat][broker] PIP-264: Add OpenTelemetry consumer metrics (#22693)
dragosvictor May 10, 2024
3b24b6e
[fix][misc] Correct the description of patternAutoDiscoveryPeriod (#2…
jitokim May 13, 2024
16556fa
[improve] [pip] PIP-348: Trigger offload on topic load stage (#22650)
hangc0276 May 13, 2024
936afec
[improve][broker]Ensure namespace deletion doesn't fail (#22627)
eolivelli May 13, 2024
9fd1b61
[fix][broker] fix replicated subscriptions for transactional messages…
thetumbled May 13, 2024
9668674
[improve][build] Improve docker-push (#22702)
nodece May 13, 2024
1a7ada8
[improve][build] Bump version to 3.4.0-SNAPSHOT (#22700)
coderzc May 14, 2024
9f1325a
[fix] [broker] fix typo and useless local variable. (#22704)
thetumbled May 14, 2024
7468928
[improve][pip] PIP-327: Support force topic loading for unrecoverable…
rdhabalia May 14, 2024
3d26079
[improve][pip] PIP-347: add role field in consumer's stat (#22564)
thetumbled May 14, 2024
361156e
[improve][pip] PIP-350: Allow to disable the managedLedgerOffloadDele…
zymap May 15, 2024
22a9023
[cleanup][broker] Remove warn logs when changing the state from Owned…
BewareMyPower May 15, 2024
7befb8d
[improve][build] Support custom image and label names (#22703)
nodece May 15, 2024
f07b3a0
[improve] [broker] [break change] Do not create partitioned DLQ/Retry…
poorbarcode May 15, 2024
f3e52b5
[improve][pip] PIP-347: Add role field in consumer's stat (#22562)
thetumbled May 16, 2024
101aee4
[fix][schema] Error checking schema compatibility on a schema-less to…
shibd May 16, 2024
73fd61d
[improve][offload] Allow to disable the managedLedgerOffloadDeletionL…
zymap May 16, 2024
4e132d3
[improve] [test] Add a test to guarantee the TNX topics will not be r…
poorbarcode May 16, 2024
fd5916c
[fix][broker] Make ExtensibleLoadManagerImpl.getOwnedServiceUnits asy…
heesung-sn May 17, 2024
23d5e12
[improve] [broker] Do not call cursor.isCursorDataFullyPersistable if…
poorbarcode May 17, 2024
528c4b0
[fix][build] Fix CVE-2024-2511 by upgrading to OpenSSL in docker imag…
merlimat May 17, 2024
edde408
[fix][build] Add curl command for pulsar image (#22732)
coderzc May 17, 2024
0c6f248
[fix][build] Fixed creation of `packages-storage` directory in docker…
merlimat May 17, 2024
e35c00e
[fix][offload] Break the fillbuffer loop when met EOF (#22722)
zymap May 17, 2024
400a286
[improve] [broker] Trigger offload on topic load (#22652)
hangc0276 May 17, 2024
158960a
[fix][test] Fix flaky AuthorizationTest.testGetListWithGetBundleOp (#…
lhotari May 17, 2024
2308f27
[fix][build] Fix pulsar-client-python installation on ARM arch (#22733)
nodece May 17, 2024
4593cc3
[improve][build] Remove invalid relativePath definitions in pom.xml f…
lhotari May 18, 2024
6372b9c
[fix] [broker] fix deadlock when disable topic level Geo-Replication …
poorbarcode May 19, 2024
9c60134
[improve][cli] Supports creating tokens with additional headers (#22690)
coderzc May 20, 2024
47fd1a3
[improve][test] Restart broker in SimpleProducerConsumerTest if ns de…
lhotari May 20, 2024
b5bc390
[fix][ml]: subscription props could be lost in case of missing ledger…
nicoloboschi May 20, 2024
878a412
[improve][client] Deprecate `MessageIdUtils.getOffset` and `MessageId…
RobertIndie May 21, 2024
ae9616b
[fix] [ml] Add entry fail due to race condition about add entry faile…
poorbarcode May 21, 2024
a66ff17
[improve][broker] Close protocol handlers before unloading namespace …
BewareMyPower May 21, 2024
949260f
[fix][broker] Immediately tombstone Deleted and Free state bundles (#…
heesung-sn May 21, 2024
ce99986
[improve] Allow to construct Oxia metadata-store directly from a clie…
merlimat May 22, 2024
adad1fb
[improve][broker] Clear thread local BrokerEntryMetadata instance bef…
lhotari May 22, 2024
13806d7
[fix] [conf] fix typo for TransferShedder. (#22757)
thetumbled May 22, 2024
dd35981
[fix] Upgrade Alpine packages at build time to fix CVE-2023-4236 (#22…
merlimat May 22, 2024
99bff72
[fix][test] Fix flaky test testShadowWrites (#22745)
RobertIndie May 23, 2024
951eb51
[fix][cli] Remove defaultValue of tenant/namespace for CmdFunctions (…
coderzc May 23, 2024
4e5c0bc
[fix] [client] PIP-344 Do not create partitioned metadata when callin…
poorbarcode May 23, 2024
2db2e76
[improve][PIP] PIP-353: Improve transaction message visibility for pe…
shibd May 24, 2024
9d9b8df
[fix][admin][part-1]Clearly define REST API on Open API (#22774)
shibd May 26, 2024
aa230bc
[fix][admin] Tenant AdminRoles can not contains whitespace in the beg…
falser101 May 27, 2024
3534cdd
[improve] [pip] PIP-354: apply topK mechanism to ModularLoadManagerIm…
thetumbled May 27, 2024
9b3876d
[fix][admin] Clearly define REST API on Open API for Namesaces@v2 (#2…
shibd May 27, 2024
ba20e02
[fix][admin] Clearly define REST API on Open API (#22783)
shibd May 27, 2024
c25d7b2
[fix][admin] Clearly define REST API on Open API for Topics (#22782)
shibd May 27, 2024
f5a00d8
[improve] [pip] PIP-354: apply topK mechanism to ModularLoadManagerIm…
thetumbled May 28, 2024
55ad4b2
[fix] [broker] fix topic partitions was expanded even if disabled top…
poorbarcode May 28, 2024
20e83b9
[improve][cli] PIP-353: Improve transaction message visibility for pe…
shibd May 28, 2024
b0e8fe9
[fix] [broker] replace loadSheddingPipeline with loadSheddingStrategy…
thetumbled May 28, 2024
82025b8
[improve][broker] avoid creating new objects when intercepting (#22790)
mattisonchao May 28, 2024
60b9f87
[improve][broker] Remove ClassLoaderSwitcher to avoid objects allocat…
dao-jun May 29, 2024
5a7efd8
[fix][broker] EntryFilters fix NoClassDefFoundError due to closed cla…
eolivelli May 29, 2024
43b20c3
[improve] [pip] PIP-356: Support Geo-Replication starts at earliest p…
poorbarcode May 30, 2024
2b1630e
Revert "[improve] [pip] PIP-356: Support Geo-Replication starts at ea…
poorbarcode May 30, 2024
34898e3
[fix][broker] fix can not cleanup heartbeat data if scaling down brok…
TakaHiR07 May 30, 2024
87a3339
[improve] [client] improve the class GetTopicsResult (#22766)
poorbarcode May 30, 2024
60ebab4
[cleanup] [broker] remove DeviationShedder. (#22800)
thetumbled May 30, 2024
7ad157c
[improve] Upgrade to Oxia client 0.3.0 (#22807)
zymap May 30, 2024
c39f9f8
[fix][ml] Fix race conditions in RangeCache (#22789)
lhotari May 31, 2024
e731674
[improve][ml] RangeCache refactoring: test race conditions and preven…
lhotari May 31, 2024
7b8f4a9
[fix][ci] Fix snappy-java native lib fails to load in x86 alpine (#22…
yaalsn Jun 3, 2024
6701936
[fix] [broker] Fix doc of ThresholdShedder and remove useless method.…
thetumbled Jun 3, 2024
2c3909c
[fix] [broker] maintain last active info in memory only. (#22794)
thetumbled Jun 3, 2024
274a3cb
[improve] [pip] PIP-356: Support Geo-Replication starts at earliest p…
poorbarcode Jun 3, 2024
a6cee2b
[feat][broker] PIP-264: Add schema registry metrics (#22624)
dragosvictor Jun 3, 2024
245c3e8
[fix][cli] Fix expiration of tokens created with "pulsar tokens creat…
entvex Jun 3, 2024
208d8a5
[improve][ml] RangeCache refactoring follow-up: use StampedLock inste…
lhotari Jun 3, 2024
05d98f7
[fix][sec] Upgrade Bouncycastle libraries to address CVEs (#22826)
lhotari Jun 3, 2024
2c2ecab
[improve][misc] Upgrade OTel library to 1.38.0 version (#22825)
lhotari Jun 3, 2024
91781d5
[fix] Bump io.airlift:aircompressor from 0.20 to 0.27 (#22819)
dependabot[bot] Jun 3, 2024
b091081
[fix] Removing out of the box option for Java serde in functions (#22…
merlimat Jun 4, 2024
ca8b465
[improve] Validate user paths in Functions utils (#22833)
merlimat Jun 4, 2024
2532fbd
[fix] JWT CLI util should force the token validation (#22831)
merlimat Jun 4, 2024
02fd1ee
[fix] [broker] disable loadBalancerDirectMemoryResourceWeight by defa…
thetumbled Jun 4, 2024
9454985
[fix] [conf] fix configuration name and typo. (#22822)
thetumbled Jun 4, 2024
7529357
[improve] Validate range of argument before long -> int conversion (#…
merlimat Jun 4, 2024
be5eb91
[improve] Upgrade Jetcd to 0.7.7 and VertX to 4.5.8 (#22835)
merlimat Jun 4, 2024
30069db
[improve] Use Google re2/j library for user provided regexes (#22829)
merlimat Jun 4, 2024
bb95b85
[fix] Bump google.golang.org/protobuf from 1.32.0 to 1.33.0 in /pulsa…
dependabot[bot] Jun 4, 2024
8276f21
[improve][broker] Reduce number of OpenTelemetry consumer attributes …
dragosvictor Jun 4, 2024
342d88d
[fix] [broker] disable loadBalancerMemoryResourceWeight by default (#…
thetumbled Jun 5, 2024
aece67e
[fix] Remove blocking calls from BookieRackAffinityMapping (#22846)
merlimat Jun 5, 2024
326e9fa
[fix] [broker] Fix Broker was failing to load stats-internal with bro…
rdhabalia Jun 5, 2024
7419287
[fix][meta] Check if metadata store is closed in RocksdbMetadataStore…
lhotari Jun 5, 2024
c23e677
[improve][build] Support git worktree working directory while buildin…
lhotari Jun 5, 2024
4341f0f
[feat][broker] PIP-264: Add broker web executor metrics (#22816)
dragosvictor Jun 5, 2024
d74010c
[improve] Refactored BK ClientFactory to return futures (#22853)
merlimat Jun 6, 2024
6236116
[improve] [client] PIP-344 support feature flag supportsGetPartitione…
poorbarcode Jun 6, 2024
fb03d15
[improve][ci] Add arm64 image build (#22755)
nodece Jun 6, 2024
fb80007
[improve] [pip] PIP-357: Correct the conf name in load balance module…
thetumbled Jun 6, 2024
9326a08
[fix][broker] Fix NPE after publishing a tombstone to the service uni…
BewareMyPower Jun 7, 2024
9692b67
[improve] [pip] PIP-357: Correct the conf name in load balance module…
thetumbled Jun 7, 2024
c81c0f6
[fix][cli] Fix the shell script parameter passthrough syntax (#22867)
lhotari Jun 7, 2024
6f1f7ba
[fix] [test] fix testGetMetrics in ExtensibleLoadManagerImplTest. (#2…
thetumbled Jun 7, 2024
c5cc25e
[fix][cli] Fix Pulsar standalone shutdown - bkCluster wasn't closed (…
lhotari Jun 7, 2024
d6dc4d3
[fix][misc] Disable JFR based telemetry collection since it's not use…
lhotari Jun 7, 2024
80d1cf9
[fix][cli] Fix healthcheck script pulsar-zookeeper-ruok.sh (#22873)
lhotari Jun 7, 2024
5af0595
[fix][broker] Support advertised listeners when gracefully transferri…
heesung-sn Jun 7, 2024
e31dbdd
[improve][build] Require Java 17 or Java 21 for building Pulsar (#22875)
lhotari Jun 7, 2024
5a8db36
[improve][broker] Reuse topic OpenTelemetry attributes (#22876)
dragosvictor Jun 7, 2024
e236f49
[fix][misc] Add proper nslookup (included in bind-tools) to docker im…
lhotari Jun 7, 2024
ef6fbf4
[improve][ci] Migrate from Gradle Enterprise to Develocity (#22880)
lhotari Jun 8, 2024
30f7835
[fix][build] Add re2/j dependency to pulsar-common and client shading…
lhotari Jun 9, 2024
540134c
[improve][pip] PIP-351: Additional options for Pulsar-Test client to …
shasank112001 Jun 10, 2024
f6eceed
[fix][cli] Fix Pulsar standalone "--wipe-data" (#22885)
lhotari Jun 10, 2024
f17d90e
[improve] Upgrade IPAddress to 5.5.0 (#22886)
merlimat Jun 10, 2024
c326d8e
[fix][misc] Topic name from persistence name should decode local name…
Shawyeok Jun 11, 2024
6b76544
[improve] [pip] PIP-355: Enhancing Broker-Level Metrics for Pulsar (#…
hangc0276 Jun 11, 2024
266243c
[improve][broker] Optimize PersistentTopic.getLastDispatchablePositio…
dao-jun Jun 11, 2024
1770cbc
[improve] [broker] Fail fast when it failed to create LoadSheddingStr…
thetumbled Jun 12, 2024
c724f02
[improve] [broker] PIP-355: Enhancing Broker-Level Metrics for Pulsar…
hangc0276 Jun 12, 2024
75d7e55
[improve][misc] Upgrade to Netty 4.1.111.Final and switch to use grpc…
lhotari Jun 12, 2024
a91a172
[fix][broker] The topic might reference a closed ledger (#22860)
shibd Jun 13, 2024
411f697
[improve][misc] Replace dependencies on PositionImpl with Position in…
lhotari Jun 13, 2024
c2702e9
[fix][broker] Asynchronously return brokerRegistry.lookupAsync when c…
heesung-sn Jun 13, 2024
f7d35e5
[improve][meta] Fix invalid use of drain API and race condition in cl…
lhotari Jun 14, 2024
7a21918
[fix][cli] Fix the pulsar-daemon parameter passthrough syntax (#22905)
coderzc Jun 14, 2024
6831231
[fix][broker] Fix topic status for oldestBacklogMessageAgeSeconds con…
shibd Jun 14, 2024
f122817
[fix] [broker] Fix typo in PersistentTopicsBase (#22904)
richiefanfan Jun 14, 2024
f83dbe9
[feat][broker] PIP-264: Add OpenTelemetry producer metrics (#22882)
dragosvictor Jun 15, 2024
1dcd07b
[fix][misc] Correct the comment of tlsAllowInsecureConnection in Clus…
jitokim Jun 16, 2024
1a6254a
[feat][broker] PIP-264: Enable OpenTelemetry reusable data memory mod…
dragosvictor Jun 16, 2024
fa74538
[fix] Revert "[fix][cli] Fix the shell script parameter passthrough s…
coderzc Jun 17, 2024
9f8adc5
[improve] [pip] PIP-358: let resource weight work for OverloadShedder…
thetumbled Jun 17, 2024
dfbf05a
[fix] [broker] fix unload bundle count metric. (#22895)
thetumbled Jun 17, 2024
7020ea2
[improve][misc] Bump RoaringBitmap version to 1.0.6 (#22920)
dao-jun Jun 17, 2024
f3d4d5a
[fix][fn] Enable optimized Netty direct byte buffer support for Pulsa…
lhotari Jun 17, 2024
9aed736
[fix] [broker] response not-found error if topic does not exist when …
poorbarcode Jun 17, 2024
2dc0d96
[fix][test] Fix TableViewBuilderImplTest NPE and infinite loop (#22924)
lhotari Jun 17, 2024
bc3dc77
[fix] [client] Fix resource leak in Pulsar Client since HttpLookupSer…
poorbarcode Jun 18, 2024
aa8f696
[fix][broker] Update init and shutdown time and other minor logic (Ex…
heesung-sn Jun 18, 2024
5ed07c1
[improve][cli] Use LoadManagerReport instead of Object (#22850)
crossoverJie Jun 18, 2024
6a1bbe6
[feat][broker] PIP-264: Add OpenTelemetry broker connection metrics (…
dragosvictor Jun 19, 2024
bacb162
[cleanup][client] Remove unneeded sync scope in TransactionImpl (#22932)
dao-jun Jun 19, 2024
feae589
[fix] [broker] Messages lost on the remote cluster when using topic l…
poorbarcode Jun 19, 2024
5dc0304
[improve] [pip] PIP-358: let resource weight work for OverloadShedder…
thetumbled Jun 19, 2024
e0f545a
[fix][cli] Refactor scripts to detect major Java version and pass cor…
lhotari Jun 19, 2024
5fc0eaf
[improve] [broker] PIP-356 Support Geo-Replication starts at earliest…
poorbarcode Jun 19, 2024
5b1f653
[improve][broker] Optimize `ConcurrentOpenLongPairRangeSet` by Roarin…
dao-jun Jun 20, 2024
ca64505
[fix] [broker] broker log a full thread dump when a deadlock is detec…
yyj8 Jun 20, 2024
36bae69
[feat][broker] PIP-321 Introduce allowed-cluster at the namespace lev…
liangyepianzhou Jun 20, 2024
ada47a3
[fix][fn] Support compression type and crypto config for all producer…
lhotari Jun 20, 2024
82b8d98
[fix][broker] Check the markDeletePosition and calculate the backlog …
nodece Jun 20, 2024
6692bc8
[cleanup][misc] Remove classifier from netty-transport-native-unix-co…
lhotari Jun 20, 2024
1517e63
[improve][misc] Set Alpine base image to 3.20 instead of 3.19.1 (#22941)
lhotari Jun 21, 2024
ddb03bb
[fix][misc] Rename netty native libraries in pulsar-client-admin-shad…
lhotari Jun 21, 2024
263c694
[improve] [broker] make system topic distribute evenly. (#22953)
thetumbled Jun 24, 2024
10eeacc
[fix][ci] Replace removed macos-11 with macos-latest in GitHub Action…
lhotari Jun 24, 2024
f728b2e
[improve][misc] Replace rename-netty-native-libs.sh script with renam…
lhotari Jun 24, 2024
c78585a
[improve][misc] Upgrade Bookkeeper to 4.17.1 (#22962)
lhotari Jun 24, 2024
aa03c0e
[fix][ci] Fix jacoco code coverage report aggregation (#22964)
lhotari Jun 24, 2024
69b2739
[fix][client] Fix orphan consumer when reconnection and closing are c…
poorbarcode Jun 25, 2024
6fe8100
[improve][fn] Make producer cache bounded and expiring in Functions/C…
lhotari Jun 25, 2024
1c44fbb
[fix][broker] Fix updatePartitionedTopic when replication at ns level…
lhotari Jun 25, 2024
7dba98b
[improve][build] Use amazoncorretto:21-alpine image instead of apk in…
nodece Jun 25, 2024
f323342
[feat][broker] PIP-264: Add OpenTelemetry broker replicator metrics (…
dragosvictor Jun 25, 2024
2da4ee8
[revert] "[improve][broker] Optimize `ConcurrentOpenLongPairRangeSet`…
lhotari Jun 25, 2024
20eb3c6
[fix][doc] Fix the doc for the message redelivery backoff (#22855)
RobertIndie Jun 26, 2024
2c6fcc7
[fix][broker] Partitioned shadow topic not work properly (#22797)
RobertIndie Jun 26, 2024
243ad5a
[feat][broker] PIP-264: Add OpenTelemetry metadata store stats (#22952)
dragosvictor Jun 26, 2024
fe726db
[feat][broker] PIP-264: Add managed ledger cache metrics (#22898)
dragosvictor Jun 26, 2024
53df683
[fix][broker] Ensure that PulsarService is ready for serving incoming…
lhotari Jun 26, 2024
4ac9bc4
[improve] [pip] PIP-364: Introduce a new load balance algorithm AvgSh…
thetumbled Jun 27, 2024
4e535cb
[feat][broker] PIP-264: Add transaction metrics (#22970)
dragosvictor Jun 27, 2024
7f4c0c5
[Fix][broker] Limit replication rate based on bytes (#22674)
nodece Jun 28, 2024
4c84788
[improve][broker] Improve exception for topic does not have schema to…
shibd Jul 1, 2024
da2a191
[fix][broker] Fix broker OOM when upload a large package. (#22989)
shibd Jul 2, 2024
dbbb6b6
[fix] Make operations on `individualDeletedMessages` in lock scope (#…
dao-jun Jul 3, 2024
e4390d3
[fix][test] Update OpenTelemetry receiver endpoint in integration tes…
dragosvictor Jul 3, 2024
f4d1d05
[feat][broker] PIP-264: Add OpenTelemetry managed ledger metrics (#22…
dragosvictor Jul 3, 2024
deb26f7
[fix][broker] Can't connecte to non-persist topic when enable broker …
shibd Jul 3, 2024
2086cc4
[improve][pip] PIP-337: SSL Factory Plugin to customize SSL Context a…
Apurva007 Jul 4, 2024
8b7754f
[fix][ci] Fix OWASP Dependency Check download by using NVD API key (#…
lhotari Jul 4, 2024
dd1b579
[feat][misc] PIP-264: Copy OpenTelemetry resource attributes to Prome…
dragosvictor Jul 5, 2024
8351c07
[feat][broker] PIP-264: Add OpenTelemetry managed cursor metrics (#23…
dragosvictor Jul 5, 2024
41ef3f6
[fix][broker] Fix MessageDeduplication replay timeout cause topic loa…
TakaHiR07 Jul 5, 2024
ed39c4d
[improve][broker] Use RoaringBitmap in tracking individual acks to re…
lhotari Jul 6, 2024
17e3f86
[fix][broker] PulsarStandalone started with error if --stream-storage…
zhouyifan279 Jul 8, 2024
32e29a3
[fix][misc] Remove RoaringBitmap dependency from pulsar-common (#23008)
lhotari Jul 8, 2024
7924f9c
[improve][build] Upgrade dependency-check-maven-plugin to 10.0.2 (#23…
lhotari Jul 8, 2024
9626e7e
[fix][client] Fix pattern consumer create crash if a part of partitio…
poorbarcode Jul 9, 2024
b473a7b
[improve][broker] log exception in MessageDeduplication#takeSnapshot …
TakaHiR07 Jul 9, 2024
1f34497
[fix][admin] Fix half deletion when attempt to topic with a incorrect…
poorbarcode Jul 10, 2024
7c0e827
[fix][broker]Fix lookupService.getTopicsUnderNamespace can not work w…
poorbarcode Jul 10, 2024
c160cc9
[improve] [pip] PIP-364: Introduce a new load balance algorithm AvgSh…
thetumbled Jul 11, 2024
88ebe78
[fix][broker] Fix stuck when enable topic level replication and build…
poorbarcode Jul 15, 2024
a8ce990
[fix][broker] Replication stuck when partitions count between two clu…
poorbarcode Jul 15, 2024
5c6602c
[improve][pip] PIP-359: Support custom message listener executor for …
AuroraTwinkle Jul 16, 2024
23163f9
[feat][ws]Add support for initialSubscriptionPosition in Websocket Co…
moinessim Jul 16, 2024
aa757ac
[improve][proxy] Add debug logs for proxy cnx management (#23037)
rdhabalia Jul 16, 2024
fe5dafd
[fix][test]Fix flaky test increase the delay time (#23046)
congbobo184 Jul 17, 2024
e51d3e2
[fix] Upgrade to Oxia 0.3.1 (#23048)
merlimat Jul 17, 2024
59136a0
[feat][misc] PIP-264: Add OpenTelemetry HTTP rate limiting filter met…
dragosvictor Jul 17, 2024
d7e8ea1
[fix][broker] Introduce the last sent position to fix message orderin…
equanz Jul 19, 2024
d08e2e0
[improve][io] The JDBC connector supports JSON substructure schema (#…
shibd Jul 21, 2024
c50f4af
[fix] [broker] fix compile error for PersistentStickyKeyDispatcherMul…
poorbarcode Jul 21, 2024
3e4f338
[improve] [broker] high CPU usage caused by list topics under namespa…
poorbarcode Jul 22, 2024
3ed37af
[improve][broker] don't do load shedding when metadata service not av…
congbobo184 Jul 22, 2024
6fa3bcf
[improve][broker] GetPartitionMetadata fail also can produce messages…
congbobo184 Jul 22, 2024
81aed6c
[improve] [broker] Improve CPU resources usege of TopicName Cache (#2…
poorbarcode Jul 22, 2024
fca9c5c
[improve][client] Add exception handle for client send error (#23038)
congbobo184 Jul 23, 2024
c9c5bb4
[feat][misc] PIP-264: Add OpenTelemetry messaging rate limit metrics …
dragosvictor Jul 23, 2024
1c53841
[fix][broker] Handle BucketDelayedDeliveryTracker recover failed (#22…
dao-jun Jul 24, 2024
38a5e91
[fix] Fix compile failing (#23070)
dao-jun Jul 24, 2024
55e468e
[fix][broker] Do not try to clean owned bundles from inactive source …
heesung-sn Jul 24, 2024
c7310e3
[improve] [broker] Add subscription prefix for internal reader (#23044)
hangc0276 Jul 25, 2024
47f204f
[improve][pip] PIP-366: Support to specify different config for Confi…
Demogorgon314 Jul 26, 2024
d4bbf10
[fix][client] Fix negative acknowledgement by messageId (#23060)
izumo27 Jul 29, 2024
e59cd05
[fix] [broker] Remove blocking calls from Subscription.getStats (#23088)
poorbarcode Jul 29, 2024
679a3d4
[improve] [broker] Check max producers/consumers limitation first bef…
poorbarcode Jul 29, 2024
76ed555
[improve][build] Upgrade docker-maven-plugin to 0.45.0 (#23091)
nodece Jul 29, 2024
a0bdf45
[improve][ci] Switch to use DEVELOCITY_ACCESS_KEY from GRADLE_ENTERPR…
lhotari Jul 29, 2024
40c8c23
[improve][broker] Reduce the CPU pressure from the transaction buffer…
BewareMyPower Jul 29, 2024
77b6378
[improve][broker] Optimize the performance of individual acknowledgme…
shibd Jul 29, 2024
49d3beb
[improve][broker] Support to specify auth-plugin, auth-parameters and…
Demogorgon314 Jul 29, 2024
b955c65
[fix] [broker] Internal reader of __change_events can not started aft…
poorbarcode Jul 29, 2024
47d35a0
[improve][build] Move docker-push profile to submodule (#23093)
nodece Jul 29, 2024
19fe2e4
[cleanup][broker] Remove PersistentSubscription.getStats (#23095)
nodece Jul 30, 2024
6bbaec1
[fix][client] TransactionCoordinatorClient support retry (#23081)
chenhongSZ Jul 30, 2024
5aa5e7d
[fix] [broker] fix replicated namespaces filter in filterAndUnloadMat…
iosdev747 Jul 31, 2024
c249530
[improve][broker]Reuse method getAvailableBrokersAsync (#23099)
crossoverJie Jul 31, 2024
4d6fce9
[WIP] Introduce `unload` flag in `ns-isolation-policy set` call
grssam Aug 2, 2024
8384b27
Changes based on PIP review
grssam Aug 12, 2024
976bc16
checkstyle fixes
grssam Aug 12, 2024
e467025
minor comment name fix
grssam Aug 12, 2024
55c5e75
Replace Pattern with String for sets
grssam Aug 16, 2024
7c8ab79
Test correct namespaces are unloaded based on the scope
grssam Aug 23, 2024
61e0200
remove whitespace
grssam Aug 23, 2024
a799493
typo fix in log line
grssam Aug 29, 2024
e1372da
Update pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/imp…
grssam Aug 30, 2024
746f072
Add test for primary broker changed case
grssam Aug 30, 2024
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
5 changes: 4 additions & 1 deletion .asf.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ github:
enabled_merge_buttons:
squash: true
merge: false
rebase: true
rebase: false
protected_branches:
master:
required_status_checks:
Expand All @@ -58,6 +58,9 @@ github:

required_signatures: false

# Requires all conversations on code to be resolved before a pull request can be merged.
required_conversation_resolution: true

# The following branch protections only ensure that force pushes are not allowed
branch-1.15: {}
branch-1.16: {}
Expand Down
13 changes: 12 additions & 1 deletion .github/ISSUE_TEMPLATE/bug-report.yml
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,8 @@ body:
For suggestions or help, please consider:
1. [User Mail List](mailto:[email protected]) ([subscribe](mailto:[email protected]));
2. [Github Discussion](https://github.com/apache/pulsar/discussions).

If you are reporting a security vulnerability, please instead follow the [security policy](https://pulsar.apache.org/en/security/).
- type: checkboxes
attributes:
label: Search before asking
Expand All @@ -37,11 +39,20 @@ body:
- label: >
I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar.
required: true
- type: checkboxes
attributes:
label: Read release policy
description: >
Please check the [supported Pulsar versions in the release policy](https://pulsar.apache.org/contribute/release-policy/#supported-versions).
options:
- label: >
I understand that unsupported versions don't get bug fixes. I will attempt to reproduce the issue on a supported version of Pulsar client and Pulsar broker.
required: true
- type: textarea
attributes:
label: Version
description: >
Please provide the OS and Pulsar version you are using. If you are using the master branch, please provide the commit id.
Please provide the OS, Java version and Pulsar versions (client + broker) you are using.
validations:
required: true
- type: textarea
Expand Down
2 changes: 1 addition & 1 deletion .github/ISSUE_TEMPLATE/flaky-test.yml
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@
name: Flaky test
title: "Flaky-test: test_class.test_method"
description: Report a flaky test failure
labels: [ "component/test", "flaky-tests" ]
labels: [ "area/test", "type/flaky-tests" ]
body:
- type: markdown
attributes:
Expand Down
10 changes: 2 additions & 8 deletions .github/actions/tune-runner-vm/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -53,8 +53,8 @@ runs:
# tune filesystem mount options, https://www.kernel.org/doc/Documentation/filesystems/ext4.txt
# commit=999999, effectively disables automatic syncing to disk (default is every 5 seconds)
# nobarrier/barrier=0, loosen data consistency on system crash (no negative impact to empheral CI nodes)
sudo mount -o remount,nodiscard,commit=999999,barrier=0 /
sudo mount -o remount,nodiscard,commit=999999,barrier=0 /mnt
sudo mount -o remount,nodiscard,commit=999999,barrier=0 / || true
sudo mount -o remount,nodiscard,commit=999999,barrier=0 /mnt || true
# disable discard/trim at device level since remount with nodiscard doesn't seem to be effective
# https://www.spinics.net/lists/linux-ide/msg52562.html
for i in /sys/block/sd*/queue/discard_max_bytes; do
Expand All @@ -77,12 +77,6 @@ runs:
# stop Azure Linux agent to save RAM
sudo systemctl stop walinuxagent.service || true

# enable docker experimental mode which is
# required for using "docker build --squash" / "-Ddocker.squash=true"
daemon_json="$(sudo cat /etc/docker/daemon.json | jq '.experimental = true')"
echo "$daemon_json" | sudo tee /etc/docker/daemon.json
# restart docker daemon
sudo systemctl restart docker
echo '::endgroup::'

# show memory
Expand Down
6 changes: 3 additions & 3 deletions .github/actions/upload-coverage/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ runs:
- name: "Upload to Codecov (attempt #1)"
id: codecov-upload-1
if: steps.repo-check.outputs.passed == 'true'
uses: codecov/codecov-action@v3
uses: codecov/codecov-action@v4
continue-on-error: true
with:
flags: ${{ inputs.flags }}
Expand All @@ -64,7 +64,7 @@ runs:
- name: "Upload to Codecov (attempt #2)"
id: codecov-upload-2
if: steps.codecov-upload-1.outcome == 'failure'
uses: codecov/codecov-action@v3
uses: codecov/codecov-action@v4
continue-on-error: true
with:
flags: ${{ inputs.flags }}
Expand All @@ -77,7 +77,7 @@ runs:
- name: "Upload to Codecov (attempt #3)"
id: codecov-upload-3
if: steps.codecov-upload-2.outcome == 'failure'
uses: codecov/codecov-action@v3
uses: codecov/codecov-action@v4
# fail on last attempt
continue-on-error: false
with:
Expand Down
2 changes: 2 additions & 0 deletions .github/changes-filter.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,8 @@ docs:
- 'deployment/**'
- 'wiki/**'
- 'pip/**'
java_non_tests:
- '**/src/main/java/**/*.java'
tests:
- added|modified: '**/src/test/java/**/*.java'
need_owasp:
Expand Down
3 changes: 2 additions & 1 deletion .github/labeler.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,4 +16,5 @@
# under the License.

PIP:
- 'pip/**'
- changed-files:
- any-glob-to-any-file: 'pip/**'
10 changes: 5 additions & 5 deletions .github/workflows/ci-go-functions.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ jobs:
docs_only: ${{ steps.check_changes.outputs.docs_only }}
steps:
- name: checkout
uses: actions/checkout@v3
uses: actions/checkout@v4

- name: Detect changed files
id: changes
Expand Down Expand Up @@ -75,25 +75,25 @@ jobs:
runs-on: ubuntu-22.04
strategy:
matrix:
go-version: [1.15, 1.16, 1.17]
go-version: ['1.21']

steps:
- name: Check out code into the Go module directory
uses: actions/checkout@v3
uses: actions/checkout@v4

- name: Tune Runner VM
uses: ./.github/actions/tune-runner-vm

- name: Set up Go
uses: actions/setup-go@v2
uses: actions/setup-go@v5
with:
go-version: ${{ matrix.go-version }}
id: go

- name: InstallTool
run: |
cd pulsar-function-go
wget -O - -q https://raw.githubusercontent.com/golangci/golangci-lint/master/install.sh| sh -s v1.18.0
wget -O - -q https://raw.githubusercontent.com/golangci/golangci-lint/master/install.sh| sh -s v1.55.2
./bin/golangci-lint --version

- name: Build
Expand Down
13 changes: 7 additions & 6 deletions .github/workflows/ci-maven-cache-update.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -43,13 +43,14 @@ on:

env:
MAVEN_OPTS: -Xss1500k -Xmx1024m -Daether.connector.http.reuseConnections=false -Daether.connector.requestTimeout=60000 -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3 -Dmaven.wagon.http.retryHandler.requestSentEnabled=true -Dmaven.wagon.http.serviceUnavailableRetryStrategy.class=standard -Dmaven.wagon.rto=60000
JDK_DISTRIBUTION: corretto

jobs:
update-maven-dependencies-cache:
name: Update Maven dependency cache for ${{ matrix.name }}
env:
JOB_NAME: Update Maven dependency cache for ${{ matrix.name }}
GRADLE_ENTERPRISE_ACCESS_KEY: ${{ secrets.GE_ACCESS_TOKEN }}
DEVELOCITY_ACCESS_KEY: ${{ secrets.GE_ACCESS_TOKEN }}
runs-on: ${{ matrix.runs-on }}
timeout-minutes: 45

Expand All @@ -63,7 +64,7 @@ jobs:
mvn_arguments: ''

- name: all modules - macos
runs-on: macos-11
runs-on: macos-latest
cache_name: 'm2-dependencies-all'

- name: core-modules
Expand All @@ -73,7 +74,7 @@ jobs:

steps:
- name: checkout
uses: actions/checkout@v3
uses: actions/checkout@v4

- name: Tune Runner VM
uses: ./.github/actions/tune-runner-vm
Expand All @@ -91,7 +92,7 @@ jobs:
- name: Cache local Maven repository
if: ${{ github.event_name == 'schedule' || steps.changes.outputs.poms == 'true' }}
id: cache
uses: actions/cache@v3
uses: actions/cache@v4
timeout-minutes: 5
with:
path: |
Expand All @@ -103,10 +104,10 @@ jobs:
# cache would be used as the starting point for a new cache entry

- name: Set up JDK 17
uses: actions/setup-java@v3
uses: actions/setup-java@v4
if: ${{ (github.event_name == 'schedule' || steps.changes.outputs.poms == 'true') && steps.cache.outputs.cache-hit != 'true' }}
with:
distribution: 'temurin'
distribution: ${{ env.JDK_DISTRIBUTION }}
java-version: 17

- name: Download dependencies
Expand Down
84 changes: 58 additions & 26 deletions .github/workflows/ci-owasp-dependency-check.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -24,76 +24,108 @@ on:
workflow_dispatch:

env:
MAVEN_OPTS: -Xss1500k -Xmx1024m -Daether.connector.http.reuseConnections=false -Daether.connector.requestTimeout=60000 -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3 -Dmaven.wagon.http.retryHandler.requestSentEnabled=true -Dmaven.wagon.http.serviceUnavailableRetryStrategy.class=standard -Dmaven.wagon.rto=60000
MAVEN_OPTS: -Xss1500k -Xmx1500m -Daether.connector.http.reuseConnections=false -Daether.connector.requestTimeout=60000 -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3 -Dmaven.wagon.http.retryHandler.requestSentEnabled=true -Dmaven.wagon.http.serviceUnavailableRetryStrategy.class=standard -Dmaven.wagon.rto=60000
JDK_DISTRIBUTION: corretto
NIST_NVD_API_KEY: ${{ secrets.NIST_NVD_API_KEY }}

jobs:
run-owasp-dependency-check:
if: ${{ github.repository == 'apache/pulsar' || github.event_name == 'workflow_dispatch' }}
name: Check ${{ matrix.branch }}
env:
JOB_NAME: Check ${{ matrix.branch }}
GRADLE_ENTERPRISE_ACCESS_KEY: ${{ secrets.GE_ACCESS_TOKEN }}
DEVELOCITY_ACCESS_KEY: ${{ secrets.GE_ACCESS_TOKEN }}
runs-on: ubuntu-22.04
timeout-minutes: 45
timeout-minutes: 75
strategy:
fail-fast: false
max-parallel: 1
matrix:
include:
- branch: master
- branch: branch-3.1
- branch: branch-3.3
- branch: branch-3.2
- branch: branch-3.0
- branch: branch-2.11
- branch: branch-2.10
jdk: 11
- branch: branch-2.9
jdk: 11
- branch: branch-2.8
jdk: 11

steps:
- name: checkout
uses: actions/checkout@v3
uses: actions/checkout@v4
with:
ref: ${{ matrix.branch }}

- name: Tune Runner VM
uses: ./.github/actions/tune-runner-vm

- name: Cache local Maven repository
uses: actions/cache@v3
- name: Restore Maven repository cache
uses: actions/cache/restore@v4
timeout-minutes: 5
with:
path: |
~/.m2/repository/*/*/*
!~/.m2/repository/org/apache/pulsar
key: ${{ runner.os }}-m2-dependencies-owasp-${{ hashFiles('**/pom.xml') }}
key: ${{ runner.os }}-m2-dependencies-all-${{ hashFiles('**/pom.xml') }}
restore-keys: |
${{ runner.os }}-m2-dependencies-all-${{ hashFiles('**/pom.xml') }}
${{ runner.os }}-m2-dependencies-core-modules-${{ hashFiles('**/pom.xml') }}
${{ runner.os }}-m2-dependencies-core-modules-

- name: Set up JDK ${{ matrix.jdk || '17' }}
uses: actions/setup-java@v3
uses: actions/setup-java@v4
with:
distribution: 'temurin'
distribution: ${{ env.JDK_DISTRIBUTION }}
java-version: ${{ matrix.jdk || '17' }}

- name: run install by skip tests
run: mvn -B -ntp clean install -DskipTests -Dspotbugs.skip=true -Dlicense.skip=true -Dcheckstyle.skip=true -Drat.skip=true -DskipDocker=true
run: mvn -B -ntp clean install -DskipTests -Dspotbugs.skip=true -Dlicense.skip=true -Dcheckstyle.skip=true -Drat.skip=true -DskipDocker=true -DnarPluginPhase=none -pl '!distribution/io,!distribution/offloaders'

- name: OWASP cache key weeknum
id: get-weeknum
run: |
echo "weeknum=$(date -u +"%Y-%U")" >> $GITHUB_OUTPUT
shell: bash

- name: Restore OWASP Dependency Check data
id: restore-owasp-dependency-check-data
uses: actions/cache/restore@v4
timeout-minutes: 5
with:
path: ~/.m2/repository/org/owasp/dependency-check-data
key: owasp-dependency-check-data-${{ steps.get-weeknum.outputs.weeknum }}
enableCrossOsArchive: true
restore-keys: |
owasp-dependency-check-data-

- name: Update OWASP Dependency Check data
id: update-owasp-dependency-check-data
if: ${{ matrix.branch == 'master' && (steps.restore-owasp-dependency-check-data.outputs.cache-hit != 'true' || steps.restore-owasp-dependency-check-data.outputs.cache-matched-key != steps.restore-owasp-dependency-check-data.outputs.cache-primary-key) }}
run: mvn -B -ntp -Powasp-dependency-check initialize -pl . dependency-check:update-only

- name: Save OWASP Dependency Check data
if: ${{ steps.update-owasp-dependency-check-data.outcome == 'success' }}
uses: actions/cache/save@v4
timeout-minutes: 5
with:
path: ~/.m2/repository/org/owasp/dependency-check-data
key: ${{ steps.restore-owasp-dependency-check-data.outputs.cache-primary-key }}
enableCrossOsArchive: true

- name: run OWASP Dependency Check for distribution/server (-DfailBuildOnAnyVulnerability=true)
run: mvn -B -ntp -Pmain,skip-all,skipDocker,owasp-dependency-check initialize verify -pl distribution/server -DfailBuildOnAnyVulnerability=true

- name: run OWASP Dependency Check for distribution/offloaders, distribution/io and pulsar-sql/presto-distribution
run: mvn -B -ntp -Pmain,skip-all,skipDocker,owasp-dependency-check initialize verify -pl distribution/offloaders,distribution/io,pulsar-sql/presto-distribution
- name: run OWASP Dependency Check for offloaders/tiered-storage and pulsar-io connectors (-DfailOnError=false)
if: ${{ !cancelled() }}
run: |
mvnprojects=$(mvn -B -ntp -Dscan=false initialize \
| grep -- "-< .* >-" \
| sed -E 's/.*-< (.*) >-.*/\1/' \
| grep -E 'pulsar-io-|tiered-storage-|offloader' \
| tr '\n' ',' | sed 's/,$/\n/' )
set -xe
mvn --fail-at-end -B -ntp -Pmain,skip-all,skipDocker,owasp-dependency-check initialize verify -DfailOnError=false -pl "${mvnprojects}"

- name: Upload OWASP Dependency Check reports
uses: actions/upload-artifact@v3
uses: actions/upload-artifact@v4
if: always()
with:
name: owasp-dependency-check-reports-${{ matrix.branch }}
path: |
distribution/server/target/dependency-check-report.html
distribution/offloaders/target/dependency-check-report.html
distribution/io/target/dependency-check-report.html
pulsar-sql/presto-distribution/target/dependency-check-report.html
**/target/dependency-check-report.html
4 changes: 1 addition & 3 deletions .github/workflows/ci-semantic-pull-request.yml
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ jobs:
name: Check pull request title
runs-on: ubuntu-latest
steps:
- uses: amannn/action-semantic-pull-request@v5.0.2
- uses: amannn/action-semantic-pull-request@v5.5.2
env:
GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
with:
Expand All @@ -53,7 +53,6 @@ jobs:
# io -> Pulsar Connectors
# offload -> tiered storage
# sec -> security
# sql -> Pulsar Trino Plugin
# txn -> transaction
# ws -> websocket
# ml -> managed ledger
Expand All @@ -79,7 +78,6 @@ jobs:
schema
sec
site
sql
storage
test
txn
Expand Down
17 changes: 0 additions & 17 deletions .github/workflows/ci-stale-issue-pr.yaml

This file was deleted.

Loading
Loading