You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/05/25 15:34:14 UTC

[GitHub] [pulsar] vanmeete opened a new issue #10702: [Pulsar IO] In Sink connector, record.getSchema(); returns null when processing from partitioned topic.

vanmeete opened a new issue #10702:
URL: https://github.com/apache/pulsar/issues/10702


   **Describe the bug**
   The record.getSchema(); returns null in case the sink connector is consuming from a partitioned topic. The correct schema is returned for non-partitioned topics.
   
   **To Reproduce**
   Steps to reproduce the behavior:
   1. Produce some messages using AvroSchema.of(SomeClass.class) to a partitioned topic
   2. In the write method of the sink observe the record.getSchema()
   3. 
   
   **Expected behavior**
   record.getSchema() to return the schema used to produce the message
   
   **Desktop (please complete the following information):**
    - OS: [e.g. iOS]
   
   **Additional context**
   - Pulsar 2.7.1 
   - Docker Standalone 
   - pulsar-functions-local-runner-original
   


-- 
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar] eolivelli edited a comment on issue #10702: [Pulsar IO] In Sink connector, record.getSchema(); returns null when processing from partitioned topic.

Posted by GitBox <gi...@apache.org>.
eolivelli edited a comment on issue #10702:
URL: https://github.com/apache/pulsar/issues/10702#issuecomment-847977672


   can you try on current 2.8.0-SNAPSHOT version ?
   we did lot of changes about the Schema API and this problem should not be present§
   
   
   are you using `Sink<GenericRecord>` ?


-- 
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar] codelipenghui commented on issue #10702: [Pulsar IO] In Sink connector, record.getSchema(); returns null when processing from partitioned topic.

Posted by GitBox <gi...@apache.org>.
codelipenghui commented on issue #10702:
URL: https://github.com/apache/pulsar/issues/10702#issuecomment-1058890001


   The issue had no activity for 30 days, mark with Stale label.


-- 
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: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar] eolivelli commented on issue #10702: [Pulsar IO] In Sink connector, record.getSchema(); returns null when processing from partitioned topic.

Posted by GitBox <gi...@apache.org>.
eolivelli commented on issue #10702:
URL: https://github.com/apache/pulsar/issues/10702#issuecomment-847977672


   can you try on current 2.8.0-SNAPSHOT version ?
   we did lot of changes about the Schema API and this problem should not be present


-- 
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar] vanmeete commented on issue #10702: [Pulsar IO] In Sink connector, record.getSchema(); returns null when processing from partitioned topic.

Posted by GitBox <gi...@apache.org>.
vanmeete commented on issue #10702:
URL: https://github.com/apache/pulsar/issues/10702#issuecomment-848581888


   The issue does not occur in 2.8.0-SNAPSHOT


-- 
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar] vanmeete commented on issue #10702: [Pulsar IO] In Sink connector, record.getSchema(); returns null when processing from partitioned topic.

Posted by GitBox <gi...@apache.org>.
vanmeete commented on issue #10702:
URL: https://github.com/apache/pulsar/issues/10702#issuecomment-847987078


   Yes using Sink<GenericRecord>, I will try 2.8.0-SNAPSHOT tomorrow.


-- 
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar] vanmeete edited a comment on issue #10702: [Pulsar IO] In Sink connector, record.getSchema(); returns null when processing from partitioned topic.

Posted by GitBox <gi...@apache.org>.
vanmeete edited a comment on issue #10702:
URL: https://github.com/apache/pulsar/issues/10702#issuecomment-847987078


   Yes using `Sink<GenericRecord>`, I will try 2.8.0-SNAPSHOT tomorrow.


-- 
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org