ambition119 opened a new issue #3232: Discuss whether remove JsonRow 
SerializationSchema and DeserializationSchema
URL: https://github.com/apache/pulsar/issues/3232
 
 
   #### Expected behavior
   
   while I commit PulsarAvroTableSink class found , we can use the native 
SerializationSchema and DeserializationSchema classes provided by Flink 
directly. directly use flink-json model classes, maintain consistency and 
synchronization with Flink.
   
   #### Actual behavior
   
   We rewrote JsonRow SerializationSchema and DeserializationSchema classes 
ourselves,I think that unnecessary.
   
   If everyone thinks so,  fix this.
   
   tks
   
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to