wenbingshen opened a new issue #13654:
URL: https://github.com/apache/pulsar/issues/13654
**Describe the bug**
```
Caused by:
org.apache.pulsar.client.api.PulsarClientException$TimeoutException: 9 request
timedout after ms 120000
at
org.apache.pulsar.client.api.PulsarClientException.unwrap(PulsarClientException.java:961)
at
org.apache.pulsar.client.impl.ReaderBuilderImpl.create(ReaderBuilderImpl.java:78)
at
org.apache.spark.streaming.pulsar2hdfs.PulsarRangeRDD.computeInner(PulsarRangeRDD.scala:155)
at
org.apache.spark.streaming.pulsar2hdfs.PulsarRangeRDD.compute(PulsarRangeRDD.scala:93)
```
```
ERROR
org.apache.pulsar.broker.transaction.pendingack.impl.MLPendingAckStoreProvider
-
persistent://wb_ad_tenant/wb_ad_feature_namespace/wb_ad_sfst_feature_store_online_stream-partition-17,pulsar2hdfs_online
open MLPendingAckStore cursor failed.
org.apache.bookkeeper.mledger.ManagedLedgerException: ManagedLedger
wb_ad_tenant/wb_ad_feature_namespace/persistent/wb_ad_sfst_feature_store_online_stream-partition-17-pulsar2hdfs_online__transaction_pending_ack
has already been closed
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
