Yufan Sheng comments

Results 81 comments of


Yufan Sheng

[BUG] The requirements of pulsar-spark with token release

Closed for no response from the end user.

[BUG] Failed to create producer: Namespace is being unloaded, cannot add topic

@wususu Spark 2.6.3 support has been dropped. Can you confirm this on our latest release on Spark 3.2.x?

[BUG]java.lang.RuntimeException: Failed to create schema for topic

@swapnil-chougule Can you paste your exception trace here?

[BUG]java.lang.RuntimeException: Failed to create schema for topic

`SchemaUtils$.uploadPulsarSchema(SchemaUtils.scala:104)` indicate that you should have admin privilege on the topic. This should be the root cause for this exception. So I don't think this is a bug.

[FEATURE] Can I have one topic for each subscription name

The pulsar-spark is using Pulsar's reader API which hides the subscription name internally. No need to care about the subscription.

[BUG]write data into pulsar, Literal must have a corresponding value to string, but class String found

I have tried on my local machine. But I can't reproduce this issue. Can anyone provide a reproduce code? @kvedes @acherla @DutchDave @naishu

[BUG]write data into pulsar, Literal must have a corresponding value to string, but class String found

@kvedes Yep. I think you are right. I tested the code on master branch and everything seems OK. This confuse me a lot.

[BUG]write data into pulsar, Literal must have a corresponding value to string, but class String found

We plan to release it today. Sorry for waiting too long.

[BUG] Failed to create subscription because of HTTP 307 Redirect.

The 307 redirect issue should be fixed now. https://github.com/apache/pulsar/issues/15546

[BUG] Pulsar SQL can NOT read topic data correctly which were written by Spark-Pulsar

Close this issue for it's stale.