Slackbot
06/15/2023, 12:50 PMJon P
06/15/2023, 4:10 PMpublic/tracking
namespace is created and sees the same errorsijieg
06/15/2023, 8:25 PMJon P
06/15/2023, 8:46 PMNot enough bookies to create ledger with ensembleSize=1, writeQuorumSize=1 and ackQuorumSize=1
Rather than 2 /2 / 2? My issue seems to be I'm unable to work out how to override ensembleSize
, writeQuorumSize
and ackQuorumSize
. I'm going round in circles a bit in the code (pulsar & bookkeeper) trying to work out how/where the values in QuorumConfigProvider
, which is used by SimpleLedgerAllocator
, are set since they clearly don't come from
- managedLedgerDefaultEnsembleSize=1
- managedLedgerDefaultWriteQuorum=1
- managedLedgerDefaultAckQuorum=1
I've got as far as DistributedLogConfiguration
but I'm now a bit lost as to whether that's BK server config or BK client.Jon P
06/16/2023, 10:32 AMDistributedLogConfiguration
are set using function_workers numFunctionPackageReplicas
, which defaults to 2. Broker ledger defaults are not considered. Setting this to 1 fixes the issue, function is created without errors.
https://github.com/apache/pulsar/blob/7636e8989f4d3fc24fce69a356d54e1c550945ed/pul[…]c/main/java/org/apache/pulsar/functions/worker/WorkerUtils.java