https://pulsar.apache.org/ logo
Join Slack
Powered by
This message was deleted.
# general
s
This message was deleted.
j
can you check what is it in zookeeper in 
/admin/policies/pulsar
key ?
s
I haven't explicitly configured anything around this key. Can you help with how I could check this?
j
use the zookeeper shell
👍 1
I'm thinking this key is created on metadata initialization, maybe you can share your metadata initialization command line too.
s
@Jerome B I am using below command on zookeeper node to initialise the cluster metadata
Copy code
./pulsar initialize-cluster-metadata  --cluster local  --metadata-store zk:10.10.18.175:2181,10.10.18.153:2181,10.10.16.38:2181  --configuration-metadata-store zk:10.10.18.175:2181,10.10.18.153:2181,10.10.16.38:2181  --web-service-url <http://internal-pulsar-proxy-lb-perf-env-1022114077.us-east-1.elb.amazonaws.com:8080>  --broker-service-url <pulsar://internal-pulsar-proxy-lb-perf-env-1022114077.us-east-1.elb.amazonaws.com:6650>
@Jerome B Output of zk shell, is this what you were looking for?
I am getting error even while performing update on pulsar tenant
Copy code
[root@ip-10-10-17-153 bin]# ./pulsar-admin tenants update pulsar --allowed-clusters local

 --- An unexpected error occurred in the server ---

Message: Failed to deserialize payload for key '/admin/policies/pulsar'

Stacktrace:

org.apache.pulsar.metadata.api.MetadataStoreException$ContentDeserializationException: Failed to deserialize payload for key '/admin/policies/pulsar'
	at org.apache.pulsar.metadata.cache.impl.MetadataCacheImpl.lambda$readValueFromStore$0(MetadataCacheImpl.java:115)
	at java.base/java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:1150)
	at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
	at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147)
	at org.apache.pulsar.metadata.impl.ZKMetadataStore.handleGetResult(ZKMetadataStore.java:275)
	at org.apache.pulsar.metadata.impl.ZKMetadataStore.lambda$batchOperation$5(ZKMetadataStore.java:219)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.base/java.lang.Thread.run(Thread.java:833)
Caused by: com.fasterxml.jackson.databind.exc.MismatchedInputException: No content to map due to end-of-input
 at [Source: (byte[])""; line: 1, column: 0]
	at com.fasterxml.jackson.databind.exc.MismatchedInputException.from(MismatchedInputException.java:59)
	at com.fasterxml.jackson.databind.DeserializationContext.reportInputMismatch(DeserializationContext.java:1746)
	at com.fasterxml.jackson.databind.ObjectReader._initForReading(ObjectReader.java:360)
	at com.fasterxml.jackson.databind.ObjectReader._bindAndClose(ObjectReader.java:2095)
	at com.fasterxml.jackson.databind.ObjectReader.readValue(ObjectReader.java:1583)
	at org.apache.pulsar.metadata.cache.impl.JSONMetadataSerdeSimpleType.deserialize(JSONMetadataSerdeSimpleType.java:46)
	at org.apache.pulsar.metadata.cache.impl.MetadataCacheImpl.lambda$readValueFromStore$0(MetadataCacheImpl.java:111)
	... 12 more
It worked fine when I manually set the policies for pulsar tenant using zookeeper shell
Copy code
set /admin/policies/pulsar {"allowedClusters":["local"],"adminRoles":[]}
Basically it was failing due to empty response from get /admin/policies/pulsar.. looks like a bug?
➕ 1
d
Yes, this appears to be a bug. I suggest you file a bug report on the Apache Pulsar project.
s
Sure ✌️
2 Views
Open in Slack
PreviousNext
Powered by