GitHub user Nintorac created a discussion: Presto connector schema issue
Hey :) I am trying to query my datastream and I get the following ``` presto> select * from pulsar."public/default"."avro-schema-topic" limit 10; Query 20220823_084000_00014_2f95a failed: Failed to get pulsar topic schema information for topic persistent://public/default/avro-schema-topic: null ``` my schema is defined like this ``` class SubmissionID(Record): submission_id = String(required=True) subreddit = String(required=True) client = Client('pulsar://localhost:6650') producer = client.create_producer( 'avro-schema-topic', schema=AvroSchema(SubmissionID) ) ``` and when I get the schema from the schema endpoint it's fine ``` curl http://localhost:8080/admin/v2/schemas/public/default/avro-schema-topic/schema {"version":0,"type":"AVRO","timestamp":0,"data":"{\n \"name\": \"SubmissionID\",\n \"type\": \"record\",\n \"fields\": [\n {\n \"name\": \"submission_id\",\n \"type\": \"string\",\n \"default\": null\n },\n {\n \"name\": \"subreddit\",\n \"type\": \"string\",\n \"default\": null\n }\n ]\n}","properties":{}}root@pulsar:/pulsar# ``` GitHub link: https://github.com/apache/pulsar/discussions/17234 ---- This is an automatically sent email for dev@pulsar.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@pulsar.apache.org