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

Reply via email to