[GitHub] [pulsar] HistoryGift commented on issue #11147: flume io connector can not run normally

[GitBox <gi...@apache.org>]

HistoryGift commented on issue #11147:
URL: https://github.com/apache/pulsar/issues/11147#issuecomment-870571748


   I download and copy pulsar-flume-io.jar to lib,I get a new issue "JavaInstanceRunnable - Encountered exception in sink write: 
   java.lang.NullPointerException: null" 
   
   Exception description: 
   JavaInstanceRunnable - Encountered exception in sink write: 
   java.lang.NullPointerException: null
           at org.apache.pulsar.io.flume.source.AbstractSource$FlumeRecord.getKey(AbstractSource.java:121) ~[pulsar-io-flume-2.8.0.jar:?]
           at org.apache.pulsar.functions.instance.SinkRecord.getKey(SinkRecord.java:53) ~[org.apache.pulsar-pulsar-functions-instance-2.7.1.jar:2.7.1]
           at org.apache.pulsar.functions.sink.PulsarSink.write(PulsarSink.java:354) ~[org.apache.pulsar-pulsar-functions-instance-2.7.1.jar:2.7.1]
           at org.apache.pulsar.functions.instance.JavaInstanceRunnable.sendOutputMessage(JavaInstanceRunnable.java:372) ~[org.apache.pulsar-pulsar-functions-instance-2.7.1.jar:2.7.1]
           at org.apache.pulsar.functions.instance.JavaInstanceRunnable.lambda$processResult$0(JavaInstanceRunnable.java:354) ~[org.apache.pulsar-pulsar-functions-instance-2.7.1.jar:2.7.1]
           at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774) [?:1.8.0_291]
           at java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:792) [?:1.8.0_291]
           at java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2153) [?:1.8.0_291]
           at org.apache.pulsar.functions.instance.JavaInstanceRunnable.processResult(JavaInstanceRunnable.java:345) [org.apache.pulsar-
   pulsar-functions-instance-2.7.1.jar:2.7.1]
           at org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:269) [org.apache.pulsar-pulsar-fun
   ctions-instance-2.7.1.jar:2.7.1]
   
   
   I look the code in Record.java
       /**
        * Return a key if the key has one associated.
        */
       default Optional<String> getKey() {
           return Optional.empty();  //
       }
   
   


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