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/08/09 23:59:43 UTC

[GitHub] [pulsar] jerrypeng opened a new pull request #11610: Fix sink byte buffer

jerrypeng opened a new pull request #11610:
URL: https://github.com/apache/pulsar/pull/11610


   ### Motivation
   
   If a Pulsar Function/Source/Sink is of type ByteBuffer, an cast exception will occur:
   
   ```
   6:44:00.226 INFO  [external-repl-prop/io/PulsarSink-test-0] o.a.p.f.i.JavaInstanceRunnable@357 - Encountered exception in sink write: 
   java.lang.ClassCastException: class [B cannot be cast to class java.nio.ByteBuffer ([B and java.nio.ByteBuffer are in module java.base of loader 'bootstrap')
   	at org.apache.pulsar.functions.worker.PulsarFunctionLocalRunTest$StatsNullSink.write(PulsarFunctionLocalRunTest.java:1027) ~[test-classes/:?]
   	at org.apache.pulsar.functions.instance.JavaInstanceRunnable.sendOutputMessage(JavaInstanceRunnable.java:355) [classes/:?]
   	at org.apache.pulsar.functions.instance.JavaInstanceRunnable.handleResult(JavaInstanceRunnable.java:338) [classes/:?]
   	at org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:283) [classes/:?]
   	at java.lang.Thread.run(Thread.java:834) [?:?]
   ```
   
   The is because if the function is of type ByteBuffer, the schema to used in the consumer is BYTES, which is not correct
   
   ### Modifications
   Use the correct ByteBuffer schema when the type of the function/source/sink is ByteBuffer
   
   ### Verifying this change
   
   Added a test
   
   ### Documentation
   
   No changes necessary
    
   #### For committer
   
   For this PR, do we need to update docs?
   
   No
   


-- 
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] jerrypeng closed pull request #11610: Fix sink byte buffer

Posted by GitBox <gi...@apache.org>.
jerrypeng closed pull request #11610:
URL: https://github.com/apache/pulsar/pull/11610


   


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