Abhishek Madav

NullPointerException during connection creation.

16

I am hitting an issue while submitting an example with yarn-cluster deploy mode. `16/07/21 11:08:55 INFO yarn.ApplicationMaster: Unregistering ApplicationMaster with FAILED (diag message: User class threw exception: org.apache.spark.SparkException: Job aborted...

[python-client] Support KeySharedPolicy in consumer configuration

2

Support for auto-hash and sticky-hash based policy (https://github.com/apache/pulsar/issues/4077) was added to cpp client (https://github.com/apache/pulsar/pull/7842) java (https://github.com/apache/pulsar/pull/5928) & go (https://github.com/apache/pulsar-client-go/pull/363) It would be great to have these changes ported to python...