Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
823 commits
Select commit Hold shift + click to select a range
7856268
[cleanup][broker] Override close method to avoid caching exception (#…
Technoboy- May 11, 2022
25f5cec
[branch-2.9][fix][broker] Fix jdk API compatibility issues. (#15779)
mattisonchao May 25, 2022
033a3b6
[optimize][txn] Optimize transaction lowWaterMark to clean useless da…
liangyepianzhou May 21, 2022
fb42686
[fix][sql] Fix the decimal type error convert in json schema (#15687)
shibd May 26, 2022
90c4653
[fix][broker] Fix creating producer failure when set backlog quota. (…
Technoboy- May 25, 2022
19bd78a
[branch-2.9] fix:remove the loadbalance/bundle-data node (#15730)
mattisonchao May 26, 2022
5cd5ded
[branch-2.9][broker][test] Fix flaky test `testDeleteNamespaceBeforeC…
mattisonchao May 26, 2022
d592b76
[branch-2.9] Fix cherry-pick issue with #15051 (#15800)
mattisonchao May 26, 2022
48d6086
[fix][branch-2.9] Fix wrong unit of NIC speed on linux (#15770)
gaozhangmin May 27, 2022
15fdf15
[branch-2.9] Add publishRateLimitedTimes to topic metrics. (#15739)
mattisonchao May 29, 2022
817e617
[fix][python]Fix generated Python protobuf code not compatible with l…
cbornet May 31, 2022
0cdf66a
Switch to rely on Netty for Hostname Verification (#15824)
michaeljmarshall Jun 1, 2022
50d9502
Configure DLog Bookie, Pulsar, and Admin clients via pass through con…
michaeljmarshall Jun 1, 2022
b274e44
Bump version to 2.9.3-SNAPSHOT
lhotari Jun 1, 2022
362c126
[PIP-146] ManagedCursorInfo compression (#14542)
nodece Apr 19, 2022
12ee3f5
[improve][tiered storage] Reduce cpu usage when offloading the ledger…
zymap Jun 6, 2022
935ce6e
[ML] When skipping updating mark delete position, execute callback wi…
lhotari Jun 8, 2022
ec09b60
[fix][pulsar] Bump pyyaml from 5.3.1 to 5.4.1 to solve CVE-2020-14343…
Jun 9, 2022
43234c6
Allow PULSAR_MEM & PULSAR_GC to be Overridden in pulsar_tool_env.sh (…
jabbaugh Jun 9, 2022
55e4a1d
[cleanup] [broker] Remove useless code to avoid confusion in OpReadEn…
horizonzy Apr 11, 2022
960b80f
[fix][broker] Fix MultiRolesTokenAuthorizationProvider `authorize` is…
Technoboy- May 9, 2022
b2de043
[feat] [tiered-storage] Add pure S3 provider for the offloader (#15710)
zymap May 25, 2022
c1e6606
fix bug in getNumberOfEntriesInStorage (#15627)
HQebupt May 28, 2022
89e005f
Fix NPE in MessageDeduplication. (#15820)
Technoboy- Jun 1, 2022
d6565a5
Fix avro conversion order of registration (#15863)
coderzc Jun 1, 2022
4a471d0
[Revert] [#15483] Remove sensitive msg from consumer/producer stats l…
Jun 5, 2022
dac1c6f
[fix][broker]Fast return if ack cumulative illegal (#15695)
AnonHxy Jun 6, 2022
faac519
[fix][txn]Fix transasction ack batch message (#15875)
liangyepianzhou Jun 7, 2022
43ab20b
[fix][auth] Generate correct well-known OpenID configuration URL (#15…
gaoran10 Jun 7, 2022
53615e0
[Fix][broker] Fix NPE when ledger id not found in `OpReadEntry` (#15837)
mattisonchao Jun 7, 2022
3411bf2
[fix][txn] fix NPE of TransactionMetaStoreHandler (#15840)
congbobo184 Jun 9, 2022
88c5681
Upgrade Netty Reactive Streams to 2.0.6 (#15990)
merlimat Jun 9, 2022
134337f
[branch-2.9] Disable testReuseFork for broker_group_2 (#16010)
codelipenghui Jun 11, 2022
d7cb6a1
[fix] [admin] [branch-2.9] fix reach max tenants error if the tenant …
poorbarcode Jun 12, 2022
213b72f
[cleanup][function] refine file io connector (#15250)
nlu90 Jun 12, 2022
e1b207e
Fix wrong prompt exception when get non-persistent topic list without…
Technoboy- Mar 12, 2022
6e7bd70
Fix grant all permissions but can't list topic. (#15501)
Technoboy- May 9, 2022
a767d37
[fix][admin] Fix typo in validation message (#16021)
visortelle Jun 13, 2022
2e78141
[Function] provide default error handler for function log appender (#…
nlu90 Jun 13, 2022
7349c23
[fix][client] Remove consumer when close consumer command is received…
mattisonchao Jun 13, 2022
f80225d
Fix wrong response type for swagger definitions (#16022)
visortelle Jun 14, 2022
3211f91
Clean up C++ client curl configuration (#16064)
michaeljmarshall Jun 14, 2022
4225887
Avoid AuthenticationDataSource mutation for subscription name (#16065)
merlimat Jun 15, 2022
e3b8e01
[branch-2.9] Fix compile issue by cherry-pick (#16086)
mattisonchao Jun 16, 2022
3e84452
Removing log4j-1.2-api from dependencies (#15991)
merlimat Jun 9, 2022
1fa9c2e
[branch-2.9][fix][security] Add timeout of sync methods and avoid cal…
mattisonchao Jun 17, 2022
dd9a5f1
Release 2.9.3
mattisonchao Jun 17, 2022
ce08aa3
Use OrderedExecutor instead of OrderedScheduler for consumer dispatch…
merlimat Jun 19, 2022
8031731
Transactions: fix race in TransactionMetaStoreHandler (#16147)
eolivelli Jun 21, 2022
741fd6c
[fix][txn] Ack the same batch message different batchIndex with trans…
congbobo184 Jun 15, 2022
ac68841
Ensure ack-timeout task gets re-scheduled when there are exception in…
merlimat Jul 2, 2022
641406e
fix select broker is none (#16316)
lordcheng10 Jul 1, 2022
6f12f5e
[improve][broker] Optimise msgOutCounter and bytesOutCounter (#16214)…
mattisonchao Jul 2, 2022
0d303c8
[Transaction] Set TC state is Ready after open MLTransactionMetadataS…
liangyepianzhou Jun 15, 2022
1ee4e29
[branch-2.9]add message ack rate (#16146)
tjiuming Jul 2, 2022
2bedbab
Revert "[improve][broker] Optimise msgOutCounter and bytesOutCounter …
mattisonchao Jul 2, 2022
68d30e9
[fix][client] Add classLoader field for `SchemaDefinition` (#15915)
coderzc Jun 23, 2022
e72a51d
[fix][tests] TieredStorageConfigurationTests - clear system propertie…
eolivelli Jun 24, 2022
713181e
[fix][broker] Fix create client with TLS config (#16014)
nodece Jun 15, 2022
4fb769e
[fix][client] Remove producer when close producer command is received…
nodece Jun 13, 2022
e3b376b
rename pulsar_producer_configuration_set_crypto_failure_action to pul…
xiong-frank Jun 13, 2022
65efa3c
[improve][broker] Avoid reconnection when a partitioned topic was cre…
BewareMyPower Jun 14, 2022
5dd735c
[fix][Java Client] Fix thread safety issue of `LastCumulativeAck` (#1…
BewareMyPower Jun 22, 2022
cf73589
[fix][broker] Fix NPE when get /admin/v2/namespaces/public/default/ma…
coderzc Jun 23, 2022
5234be3
[improve][broker] Use LinkedHashSet for config items of type Set to p…
fantapsody Jun 28, 2022
47c5b3d
[fix][txn] Fix NPE when ack message with transaction at cnx = null (…
liangyepianzhou Jun 21, 2022
556d3d1
Fix `messageQueue` release message issue. (#16155)
Technoboy- Jun 21, 2022
282a0f2
[fix][function] Ensure bytes is a well-formed UTF-8 byte sequence whe…
coderzc Jul 1, 2022
6b3ed29
[fix][broker] Fix NPE when drop backlog for time limit. (#16235)
Technoboy- Jun 28, 2022
15895c3
[fix][broker]Fix getInternalStats occasional lack of LeaderInfo again…
AnonHxy Jul 1, 2022
c3fd77d
[fix][broker]fix npe when invoke replaceBookie. (#16239)
Nicklee007 Jun 28, 2022
f02ee1a
[fix][txn] Fix TopicTransactionBuffer ledger apend marker throw Manag…
congbobo184 Jul 1, 2022
99e4a19
[fix][txn] Fix append txn message is lower than lowWaterMark decrease…
congbobo184 Jun 28, 2022
f81b242
[improve][common] Use `Collection` to instead of `List` parameter typ…
mattisonchao Apr 26, 2022
dc9968a
[branch-2.9] Fix cherry-pick issues. (#16346)
mattisonchao Jul 2, 2022
d56ae37
[Branch-2.9][Cherry-pick] fix bug: fail to expose managed ledger clie…
HQebupt Jul 2, 2022
c7d9908
[Branch 2.9] Fix compaction subscription acknowledge Marker msg issue…
mattisonchao Jul 2, 2022
bf513e2
[Branch-2.9] Fix passing incorrect authentication data (#16347)
mattisonchao Jul 2, 2022
1038a74
Fixed deadlock when checking topic ownership (#16310)
merlimat Jul 3, 2022
69830a6
[Branch-2.9][transaction] Cmd-Subscribe and Cmd-Producer will not suc…
mattisonchao Jul 3, 2022
51d6584
[fix][broker] Fix RawReader out of order (#16390)
hangc0276 Jul 6, 2022
0735f6b
[Branch-2.9][Cherry-pick] Fix get non-persistent topics issue in Name…
Technoboy- Jul 11, 2022
3cea10a
[fix][txn] Allow producer enable send timeout in transaction (#16519)
congbobo184 Jul 11, 2022
ab1d708
Support shrink for TripleLongPriorityQueue (#15936)
315157973 Jun 7, 2022
f305c99
[fix][broker] Fixed error when delayed messages trackers state grows …
merlimat Jul 12, 2022
54b5288
cherry-pick [fix][txn] fix pattern sub filter transaction system topi…
congbobo184 Jul 12, 2022
87f64d0
[fix][security] Upgrade to Jetty to 9.4.48.v20220622 to get rid of CV…
nicoloboschi Jul 12, 2022
91bebdd
Fix: Make DeadLetterPolicy deserializable (#16513)
coderzc Jul 13, 2022
720585e
[fix][C++ client] Fix the close of Client might stuck or return a wro…
BewareMyPower Jul 6, 2022
d5139b9
[fix][pulsar-broker] Fix RawReader hasMessageAvailable returns true w…
zymap Jul 14, 2022
98fc43c
[fix][broker] Fix setManagedLedgerOffloadedReadPriority not work. (#1…
Technoboy- Jul 8, 2022
9961a11
[fix][broker] fix No such ledger exception (#16420)
lordcheng10 Jul 8, 2022
ab38b1a
[fix][broker] Expose timestamp field for SchemaData&SchemaInfo (#16380)
coderzc Jul 12, 2022
7e17d7a
[improve][broker] Recycle OpReadEntry in some corner cases (#16399)
BewareMyPower Jul 7, 2022
e0141bc
[fix][broker] Skip reading more entries for a pending read with no mo…
BewareMyPower Jul 13, 2022
c121d00
[improve][client] Add message key if exists to deadLetter messages (…
gaozhangmin Jul 15, 2022
8ca3941
[fix][test][branch-2.10] Fix test TransactionEndToEndTest#testSendTxn…
nicoloboschi Jul 14, 2022
5bc399d
[broker] Add config to allow deliverAt time to be strictly honored (#…
michaeljmarshall Jun 16, 2022
ee1d80a
Avoid tracking the delays of all the message when we detect that they…
merlimat Jul 15, 2022
2d7a82f
[branch-2.9] Fix `MockStatic` method caused the exception (#16628)
mattisonchao Jul 16, 2022
0bca713
Fixed deadlock in key-shared dispatcher (#16660)
merlimat Jul 19, 2022
f02853b
[improve][security] Add load multiple certificates support in TrustMa…
nodece Jul 13, 2022
ad5d8a1
[fix][proxy] Do not preserve host when forwarding admin requests. (#1…
fantapsody Jul 21, 2022
7a9bd8f
[fix][broker] The configuration loadBalancerNamespaceMaximumBundles i…
lordcheng10 Jul 18, 2022
9d20658
Fix newLookup TooManyRequestsException message (#16594)
AnonHxy Jul 25, 2022
f30f348
[fix][broker] Fix consumer does not abide by the max unacks limitatio…
codelipenghui Jul 20, 2022
1202424
[fix][broker] Fix consumer does not abide by the max unacks limitatio…
codelipenghui Jul 22, 2022
01dbf18
[fix][broker] Retry to delete the namespace if new topics created dur…
codelipenghui Jul 20, 2022
ca643ca
Fix branch-2.9 compatible issue. (#16779)
mattisonchao Jul 25, 2022
a16f03e
[improve][connector] add reader config to `pulsar-io-debezium` and `p…
freeznet Jul 25, 2022
1570567
[fix][common] Add back FutureUtil#waitForAll and FutureUtil#waitForAn…
mattisonchao Jul 26, 2022
28dc04b
[Broker] Expose topic level storage write and read rate metrics (#16855)
michaeljmarshall Jul 28, 2022
085678a
Update/fix Swagger Annotation for param: authoritative (#16222)
michaeljmarshall Jul 12, 2022
9339fd4
[broker][monitoring][fix] fix `pulsar_subscription_msg_ack_rate` (#16…
tjiuming Aug 4, 2022
2e761b8
[fix][client-c++] Close `messages_` when PartitionedConsumer is close…
coderzc Aug 3, 2022
ccb6140
fix PatternTopicsChangedListener blocked when topic removed (#16842)
wangjialing218 Jul 29, 2022
29b23ac
[fix][broker] ManagedCursor: mark delete no callback when create meta…
poorbarcode Jul 29, 2022
c2b685b
Revert "[fix][client-c++] Close `messages_` when PartitionedConsumer …
mattisonchao Aug 5, 2022
752225a
cherry pick #16837 to branch 2.9 (#16971)
Nicklee007 Aug 8, 2022
41c7dca
[improve][broker] Optimise msgOutCounter and bytesOutCounter (#16771)
Aug 8, 2022
f8ce46e
Fix MaxQueueSize semaphore release leak in createOpSendMsg (#16958)
Nicklee007 Aug 9, 2022
05d35d8
[Branch 2.9][fix][broker] Upgrade log4j2 version to 2.18.0 (#16884) (…
liudezhi2098 Aug 9, 2022
2c6db60
[improve][authentication] Support for get token from HTTP params (#16…
nodece Aug 9, 2022
ba24b40
Exclude the Netty Reactive Stream from asynchttpclient (#16312)
zymap Jul 5, 2022
0cc42d9
[fix][authorization] Fix multiple roles authorization (#16645)
nodece Jul 25, 2022
6bdffab
add artifactSet to pom.xml for pulsar-functions-local-runner (#16565)
danpi Jul 25, 2022
4bc4659
fix lafla source config when consumerConfigProperties='' (#16731)
danpi Jul 26, 2022
6f33cde
[fix][broker] Fix stats-internal with option -m cause active ledger r…
yapxue Jul 27, 2022
fbfc6bd
[fix][client] Fix ReconsumeLater will hang up if retryLetterProducer …
leizhiyuan Jul 27, 2022
dbfbea4
[fix][client] Fix load trust certificate (#16789)
nodece Jul 29, 2022
7b2f39c
[fix][proxy] Fix client service url (#16834)
nodece Jul 29, 2022
4fba95a
[Java Client] Send CloseConsumer on timeout (#16616)
michaeljmarshall Jul 30, 2022
4f03d00
[fix][function] Fix python instance not process zip file correctly (#…
jiangpengcheng Aug 3, 2022
4c00702
[fix][client] Remove redundant check for chunked message TotalChunkMs…
Gleiphir2769 Aug 5, 2022
e434a53
[fix][broker]remove exception log when access status.html (#17025)
poorbarcode Aug 10, 2022
1c6dc30
Avoid contended synchronized block on topic load (#15883)
merlimat Jun 2, 2022
0d36b6b
[improve][broker]Remove unnecessary lock on the stats thread (#16983)
zymap Aug 9, 2022
06be308
[fix][tiered-storage] move the state check forward (#17020)
zymap Aug 11, 2022
f41f62d
[fix][ML] Fix offload read handle NPE (#17056)
horizonzy Aug 13, 2022
0a28b98
fix CI
hangc0276 Aug 16, 2022
feded47
[Fix][Client] Fixed cnx channel Inactive causing the request fail to …
liangyepianzhou Aug 18, 2022
90ef1f1
[Branch-2.9]Upgrade rocksdb version to 6.16.4 to keep sync with bookk…
hangc0276 Aug 24, 2022
5902caa
[fix][tiered-storage] Fix the wrong secret key name get from env (#15…
zymap May 27, 2022
b292591
[fix][broker] Avoid IllegalStateException while client_version is not…
codelipenghui Jul 28, 2022
84124e2
[fix][broker]Prevent StackOverFlowException in SHARED subscription (#…
mattisonchao Aug 12, 2022
ce36660
[fix][client] Release semaphore before discarding messages in batchMe…
RobertIndie Aug 11, 2022
32e0976
[fix][sql]Fix presto sql avro decode error when publish non-batched m…
AnonHxy Aug 18, 2022
b78c389
[fix][tool] Using int instead of long in python scriptsc (#17215)
zymap Aug 23, 2022
f3899d5
[improve][test] Fix flaky C++ ClientTest.testWrongListener (#16510)
BewareMyPower Jul 13, 2022
66fbdab
[improve][client-c++] Use an atomic `state_` instead of the lock to i…
coderzc Aug 13, 2022
5f00aa5
[fix][cpp] Fix multi-topics consumer close segmentation fault (#17239)
BewareMyPower Aug 25, 2022
123d790
[fix][client] Fix reach redeliverCount client can't send messages to …
congbobo184 Aug 27, 2022
7317c84
[fix][client] Fix reach redeliverCount client can't send batch messag…
congbobo184 Aug 28, 2022
7527005
[package management service] check service status before run commands…
freeznet Nov 19, 2021
6e8b041
[improve][functions][admin] Improve the package download process (#16…
zymap Aug 11, 2022
afbbf1e
Fix compile error
mattisonchao Aug 29, 2022
74b91b9
[branch-2.9] Support mock final class with `PowerMockito` (#17327)
mattisonchao Aug 29, 2022
6ff1b64
[fix][client] Fix the message present in incoming queue after go to D…
congbobo184 Aug 29, 2022
4a674c2
[fix][broker] fix broker unackmessages number reduce error (#17003)
congbobo184 Aug 13, 2022
7d42018
[fix][broker]ManagedLedger metrics fail cause of zero period (#17257)
poorbarcode Aug 30, 2022
3ea1249
[improve][CI] Cancel duplicate build jobs for maintenance branches
lhotari Aug 30, 2022
a9c90ef
[branch-2.9][fix][load-balancer] skip mis-configured resource usage(>…
heesung-sohn Sep 1, 2022
4fad353
Fix calculate avg message per entry (#17281)
coderzc Sep 1, 2022
9fd542e
Bump dependency check and spring version to avoid potential FP (#15408)
May 2, 2022
960c8a8
[fix][broker] Fix schema does not replicate successfully (#17049)
codelipenghui Aug 18, 2022
8d293a2
[fix][broker] Fix out of order data replication (#17154)
codelipenghui Aug 19, 2022
22eb42f
[fix][broker] Fix the replicator unnecessary get schema request for b…
codelipenghui Sep 8, 2022
8262f25
[improve][broker] Improve cursor.getNumberOfEntries if isUnackedRange…
codelipenghui Sep 7, 2022
f1be5c3
[ci] Remove post-commit trigger for old release branches (#17570)
nicoloboschi Sep 9, 2022
dea4a32
[fix][broker] Multiple consumer dispatcher stuck when `unackedMessage…
mattisonchao Sep 10, 2022
3e632fe
Move into future stage to catch the exception (#17556)
Technoboy- Sep 10, 2022
db8480b
[fix][broker] Topic policy reader can't recover when get any exceptio…
mattisonchao Sep 13, 2022
4d628a9
[branch-2.9] Rename test file name from `*Test2.java` to `*Test.java`…
equanz Sep 13, 2022
b5ef559
[refactor][client c++] Delete PartitionedConsumerImpl, use MultiTopic…
shibd Aug 31, 2022
62dca40
[fix][cpp] Fix potential segfault when resending messages (#17395)
BewareMyPower Sep 6, 2022
a6842aa
[fix][admin] Add SNI header when tlsHostnameVerification is not enabl…
fantapsody Sep 14, 2022
db6393a
[C++] Reset `havePendingPingRequest` flag for any data received from …
merlimat Sep 15, 2022
fb36673
Fix wrong consumers size: execute `callback` before executing `reader…
coderzc Sep 16, 2022
4dc6175
[branch-2.9][fix][broker]Persist cursor info error when cursor close …
poorbarcode Sep 17, 2022
ab78a7e
Update proxy lookup throw exception type (#17600)
tuteng Sep 14, 2022
d1d1273
[fix][metadata] Set revalidateAfterReconnection true for certain fail…
michaeljmarshall Sep 18, 2022
15da3ed
[fix][metadata] Cleanup state when lock revalidation gets `LockBusyEx…
mattisonchao Sep 20, 2022
ce2c157
[branch-2.9][cherry-pick] Fix producer/consume permission can’t get s…
Technoboy- Sep 20, 2022
bc69cfb
[fix][broker][functions-worker] Ensure prometheus metrics are grouped…
marksilcox Sep 20, 2022
aa4c677
[improve][loadbalance] added loadBalancerReportUpdateMinIntervalMilli…
heesung-sohn Sep 14, 2022
7045376
[improve][broker] Make MessageRedeliveryController work more efficien…
codelipenghui Sep 23, 2022
2942062
[doc][proxy] Document how to mitigate CVE-2022-24280 (#17825)
lhotari Sep 23, 2022
3564f42
Revert "[fix][broker][functions-worker] Ensure prometheus metrics are…
codelipenghui Sep 24, 2022
976a318
Group prometheus metrics (#17852)
tjiuming Sep 29, 2022
39ce324
[fix][proxy] Fix refresh client auth (#17831)
nodece Sep 29, 2022
b07d31b
[branch-2.9] Fix cherry-pick issue (#17894)
codelipenghui Sep 30, 2022
9de48f5
[fix][broker] Fix the broker shutdown issue after Zookeeper node cras…
codelipenghui Oct 2, 2022
1f8cef3
Make executor of AbstractMetadataStore protected
codelipenghui Oct 2, 2022
4abd4d2
Allow to configure and disable the size of lookahead for detecting fi…
merlimat Oct 1, 2022
717dd1d
[fix][broker] Fix system topic schema not compatible bug (#17986)
dragonls Oct 12, 2022
88d7cf2
[improve][authentication] Improve get the basic authentication config…
nodece Oct 16, 2022
44d4183
[fix][client][txn] Use PulsarClient HashWheelTimer to schedule produc…
lifepuzzlefun Oct 17, 2022
10f6f07
Bump jackson version from 2.13.2 to 2.13.3 (#16508)
Jul 11, 2022
5cb46cc
[fix][sec] Upgrade JacksonXML to 2.13.4 (#18020)
nicoloboschi Oct 17, 2022
b53bc51
[fix][sec] File tiered storage: upgrade jettison to get rid of CVE-20…
nicoloboschi Oct 17, 2022
84644ec
[fix][sec] Upgrade protobuf to 3.19.6 to get rid of CVE-2022-3171 (#1…
nicoloboschi Oct 18, 2022
68bfd13
[broker] Fixed delayed delivery after read operation error (#18098)
merlimat Oct 19, 2022
36a9d13
Revert "[fix][sec] File tiered storage: upgrade jettison to get rid o…
mattisonchao Oct 19, 2022
469d44d
[fix][sec] File tiered storage: upgrade jettison to get rid of CVE-20…
mattisonchao Oct 19, 2022
3f2ebad
[branch-2.9] Fixed key-shared delivery of messages with interleaved d…
mattisonchao Oct 19, 2022
dced66c
[branch-2.9] Fix license check issue (#18117)
Technoboy- Oct 19, 2022
92da0bb
[fix][cpp][branch-2.9] Fix zlib dowload path. (#18127)
shibd Oct 20, 2022
6245518
[fix][storage] Autorecovery default reppDnsResolverClass to ZkBookieR…
michaeljmarshall Oct 24, 2022
a280fd2
[fix][monitor] fix metrics string encoding (#18138)
tjiuming Oct 24, 2022
56125f9
Prevent StackOverFlowException in KEY_SHARED subscription (#14121)
eolivelli Feb 6, 2022
7923d54
Revert "Clean up C++ client curl configuration (#16064)"
BewareMyPower Nov 2, 2022
b25b09d
Revert "Revert "Clean up C++ client curl configuration (#16064)""
BewareMyPower Nov 2, 2022
94de85f
[fix][sec] Updating dependencies to get rid of CVEs brought in with k…
Nov 3, 2022
5ed247d
[fix][client] Fix NPE of MultiTopicsConsumerImpl due to race conditio…
codelipenghui Nov 2, 2022
604c872
[improve][schema] Change update schema auth from tenant to produce (#…
congbobo184 Oct 19, 2022
48a99e9
[Client] Support passing existing executor providers to the client (#…
lhotari Jan 19, 2022
d9211c9
[improve][java-client] Replace ScheduledExecutor to improve performan…
codelipenghui Jun 28, 2022
8fa9ab1
Optimize conusmer pause (#14566)
Jason918 Mar 23, 2022
1ac2587
[improve][java-client] Improve performance of multi-topic consumer wi…
codelipenghui Jul 5, 2022
1de2915
[fix][client] Fix failover/exclusive consumer with batch cumulate ack…
Technoboy- Nov 15, 2022
dc1ce08
Ensure cache is refreshed (and not just invalidated) after a store wr…
merlimat Nov 17, 2021
2bbeace
fix-12894 (#12896)
Jason918 Nov 30, 2021
c3bf452
[Broker] Fix NPE of internalExpireMessagesByTimestamp (#14243)
nodece Feb 14, 2022
977a81c
Fix metadata cache inconsistency on do refresh (#14283)
Demogorgon314 Feb 15, 2022
06954d1
[fix][broker] Make `deleteTopicPolicies` serialized is executed when …
mattisonchao Aug 22, 2022
0844f31
[improve][broker] Avoid go through all the consumers to get the messa…
codelipenghui Jun 28, 2022
26c4b95
[improve][broker] Reduce the consumers list sort by priority level (#…
codelipenghui Jun 28, 2022
34f14fc
[fix][tiered-storage] Don't cleanup data when offload met Metastore e…
zymap Sep 14, 2022
78e7dde
[improve][txn] Implementation of Delayed Transaction Messages (#17548)
congbobo184 Sep 15, 2022
6c0fc32
[fix][broker] In the trimDeletedEntries method, release the removed e…
lordcheng10 Nov 3, 2022
f934f37
[fix][cli] Fix CLI client produce don't able to use multiple -m send …
coderzc Oct 28, 2022
c0ff7de
[fix][broker] Fix `getPositionAfterN` infinite loop. (#17971)
Technoboy- Oct 13, 2022
937f2ab
[fix][function] Fix invalid metric type `gauge ` (#18129)
coderzc Oct 24, 2022
e197eaa
[fix][broker] Fix incorrect bundle split count metric (#17970)
Shawyeok Oct 11, 2022
38f0588
[fix][broker] Fix executeWithRetry result is null (#17694)
coderzc Oct 11, 2022
668f6d4
[fix][broker] Unregister topic policy listener if managed ledger clos…
codelipenghui Sep 15, 2022
b8125d9
[fix][common] Fix parsing partitionedKey with Base64 encode issue. (#…
Technoboy- Sep 16, 2022
7cf681e
[fix] [pulsar-client] Fix pendingLookupRequestSemaphore leak when cha…
Oct 14, 2022
8c179d4
[fix] [pulsar-client] Fix pendingLookupRequestSemaphore leak when Ser…
Oct 27, 2022
68f7cde
[fix][client] Support LocalDateTime Conversion (#18334)
coderzc Nov 9, 2022
6398330
[fix][schema]ledger handle leak when update schema (#17283)
poorbarcode Sep 20, 2022
26b4747
[fix][security] Bump PostgreSQL version to 42.4.1(#17066)
tjiuming Aug 13, 2022
ae42b48
[fix][broker]Consumer can't consume messages because there has two sa…
poorbarcode Sep 21, 2022
4dcac0f
[fix][broker] Fix the order of resource close in the InMemoryDelayedD…
coderzc Oct 13, 2022
11130e1
[fix][offload] Fix memory leak while Offloading ledgers (#18500)
eolivelli Nov 16, 2022
9cf76fd
[fix][broker] DnsResolverUtil.TTL should be greater than zero (#18565)
Technoboy- Nov 22, 2022
db54894
[fix][fn] fix function failed to start if no `typeClassName` provided…
freeznet Nov 11, 2022
9dd4149
ManagedLedger: move to FENCED state in case of BadVersionException (#…
eolivelli Sep 22, 2022
9138533
[improve][java-client] Only trigger the batch receive timeout when ha…
codelipenghui Jun 23, 2022
52fd58a
[cherry-pick][branch-2.9] cherry-pick #17736 problem
Nov 26, 2022
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
  •  
  •  
  •  
6 changes: 4 additions & 2 deletions .github/actions/tune-runner-vm/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -33,8 +33,10 @@ runs:
# Set vm.swappiness=1 to avoid swapping and allow high RAM usage
echo 1 | sudo tee /proc/sys/vm/swappiness
# Set swappiness to 1 for all cgroups and sub-groups
for swappiness_file in /sys/fs/cgroup/memory/*/memory.swappiness /sys/fs/cgroup/memory/*/*/memory.swappiness; do
echo 1 | sudo tee $swappiness_file > /dev/null
for swappiness_dir in /sys/fs/cgroup/memory/*/ /sys/fs/cgroup/memory/*/*/; do
if [ -d "swappiness_dir" ]; then
echo 1 | sudo tee $(swappiness_dir)memory.swappiness > /dev/null
fi
done

# use "madvise" Linux Transparent HugePages (THP) setting
Expand Down
8 changes: 5 additions & 3 deletions .github/workflows/ci-build-macos.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,12 @@ on:
pull_request:
branches:
- master
push:
branches:
- branch-*

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3

Expand Down Expand Up @@ -68,7 +70,7 @@ jobs:
uses: actions/setup-java@v2
if: ${{ steps.check_changes.outputs.docs_only != 'true' }}
with:
distribution: 'adopt'
distribution: 'temurin'
java-version: 11


Expand Down
6 changes: 1 addition & 5 deletions .github/workflows/ci-cpp-build-centos7.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,15 +22,11 @@ on:
pull_request:
branches:
- master
paths:
- '.github/workflows/**'
- 'pulsar-client-cpp/**'
push:
branches:
- branch-*
paths:
- '.github/workflows/**'
- 'pulsar-client-cpp/**'

jobs:

cpp-build-centos7:
Expand Down
19 changes: 9 additions & 10 deletions .github/workflows/ci-cpp-build-windows.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,16 +22,15 @@ on:
pull_request:
branches:
- master
paths:
- '.github/workflows/**'
- 'pulsar-client-cpp/**'
push:
branches:
- branch-*
paths:
- '.github/workflows/**'
- 'pulsar-client-cpp/**'

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
VCPKG_FEATURE_FLAGS: manifests

Expand All @@ -46,26 +45,26 @@ jobs:
matrix:
include:
- name: 'Windows x64'
os: windows-latest
os: windows-2022
triplet: x64-windows
vcpkg_dir: 'C:\vcpkg'
suffix: 'windows-win64'
generator: 'Visual Studio 16 2019'
generator: 'Visual Studio 17 2022'
arch: '-A x64'
- name: 'Windows x86'
os: windows-latest
os: windows-2022
triplet: x86-windows
vcpkg_dir: 'C:\vcpkg'
suffix: 'windows-win32'
generator: 'Visual Studio 16 2019'
generator: 'Visual Studio 17 2022'
arch: '-A Win32'

steps:
- name: checkout
uses: actions/checkout@v2

- name: Detect changed files
id: changes
id: changes
uses: apache/pulsar-test-infra/paths-filter@master
with:
filters: .github/changes-filter.yaml
Expand Down
8 changes: 5 additions & 3 deletions .github/workflows/ci-cpp.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,12 @@ on:
pull_request:
branches:
- master
push:
branches:
- branch-*

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3

Expand Down Expand Up @@ -68,7 +70,7 @@ jobs:
uses: actions/setup-java@v2
if: ${{ steps.check_changes.outputs.docs_only != 'true' }}
with:
distribution: 'adopt'
distribution: 'temurin'
java-version: 11

- name: clean disk
Expand Down
9 changes: 4 additions & 5 deletions .github/workflows/ci-go-functions-style.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,16 +22,15 @@ on:
pull_request:
branches:
- master
paths:
- '.github/workflows/**'
- 'pulsar-function-go/**'
push:
branches:
- branch-*
paths:
- '.github/workflows/**'
- 'pulsar-function-go/**'

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3

Expand Down
9 changes: 4 additions & 5 deletions .github/workflows/ci-go-functions-test.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,16 +22,15 @@ on:
pull_request:
branches:
- master
paths:
- '.github/workflows/**'
- 'pulsar-function-go/**'
push:
branches:
- branch-*
paths:
- '.github/workflows/**'
- 'pulsar-function-go/**'

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3

Expand Down
8 changes: 5 additions & 3 deletions .github/workflows/ci-integration-backwards-compatibility.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,12 @@ on:
pull_request:
branches:
- master
push:
branches:
- branch-*

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3

Expand Down Expand Up @@ -69,7 +71,7 @@ jobs:
uses: actions/setup-java@v2
if: ${{ steps.check_changes.outputs.docs_only != 'true' }}
with:
distribution: 'adopt'
distribution: 'temurin'
java-version: 11

- name: clean disk
Expand Down
8 changes: 5 additions & 3 deletions .github/workflows/ci-integration-cli.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,12 @@ on:
pull_request:
branches:
- master
push:
branches:
- branch-*

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3

Expand Down Expand Up @@ -69,7 +71,7 @@ jobs:
uses: actions/setup-java@v2
if: ${{ steps.check_changes.outputs.docs_only != 'true' }}
with:
distribution: 'adopt'
distribution: 'temurin'
java-version: 11

- name: clean disk
Expand Down
8 changes: 5 additions & 3 deletions .github/workflows/ci-integration-function.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,12 @@ on:
pull_request:
branches:
- master
push:
branches:
- branch-*

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3

Expand Down Expand Up @@ -69,7 +71,7 @@ jobs:
uses: actions/setup-java@v2
if: ${{ steps.check_changes.outputs.docs_only != 'true' }}
with:
distribution: 'adopt'
distribution: 'temurin'
java-version: 11

- name: clean disk
Expand Down
8 changes: 5 additions & 3 deletions .github/workflows/ci-integration-messaging.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,12 @@ on:
pull_request:
branches:
- master
push:
branches:
- branch-*

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3

Expand Down Expand Up @@ -69,7 +71,7 @@ jobs:
uses: actions/setup-java@v2
if: ${{ steps.check_changes.outputs.docs_only != 'true' }}
with:
distribution: 'adopt'
distribution: 'temurin'
java-version: 11

- name: clean disk
Expand Down
8 changes: 5 additions & 3 deletions .github/workflows/ci-integration-process.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,12 @@ on:
pull_request:
branches:
- master
push:
branches:
- branch-*

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3

Expand Down Expand Up @@ -68,7 +70,7 @@ jobs:
uses: actions/setup-java@v2
if: ${{ steps.check_changes.outputs.docs_only != 'true' }}
with:
distribution: 'adopt'
distribution: 'temurin'
java-version: 11

- name: clean disk
Expand Down
8 changes: 5 additions & 3 deletions .github/workflows/ci-integration-pulsar-io-ora.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,12 @@ on:
pull_request:
branches:
- master
push:
branches:
- branch-*

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3

Expand Down Expand Up @@ -69,7 +71,7 @@ jobs:
uses: actions/setup-java@v2
if: ${{ steps.check_changes.outputs.docs_only != 'true' }}
with:
distribution: 'adopt'
distribution: 'temurin'
java-version: 11

- name: clean disk
Expand Down
8 changes: 5 additions & 3 deletions .github/workflows/ci-integration-pulsar-io.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,12 @@ on:
pull_request:
branches:
- master
push:
branches:
- branch-*

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3

Expand Down Expand Up @@ -69,7 +71,7 @@ jobs:
uses: actions/setup-java@v2
if: ${{ steps.check_changes.outputs.docs_only != 'true' }}
with:
distribution: 'adopt'
distribution: 'temurin'
java-version: 11

- name: clean disk
Expand Down
8 changes: 5 additions & 3 deletions .github/workflows/ci-integration-schema.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,12 @@ on:
pull_request:
branches:
- master
push:
branches:
- branch-*

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
MAVEN_OPTS: -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3

Expand Down Expand Up @@ -68,7 +70,7 @@ jobs:
uses: actions/setup-java@v2
if: ${{ steps.check_changes.outputs.docs_only != 'true' }}
with:
distribution: 'adopt'
distribution: 'temurin'
java-version: 11

- name: clean disk
Expand Down
8 changes: 5 additions & 3 deletions .github/workflows/ci-integration-sql.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,10 +22,12 @@ on:
pull_request:
branches:
- master
push:
branches:
- branch-*

concurrency:
group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true

env:
MAVEN_OPTS: -Xmx768m -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.http.retryHandler.class=standard -Dmaven.wagon.http.retryHandler.count=3
MALLOC_ARENA_MAX: "1"
Expand Down Expand Up @@ -69,7 +71,7 @@ jobs:
uses: actions/setup-java@v2
if: ${{ steps.check_changes.outputs.docs_only != 'true' }}
with:
distribution: 'adopt'
distribution: 'temurin'
java-version: 11

- name: clean disk
Expand Down
Loading