[Issue 3896] [pulsar-io] Fix NPE in ElasticSearchSink (apache#3899)

* Fix NPE in ElasticSearchSink. * Init by an empty string
blitznihar · Mar 26, 2019 · 52659ae · 52659ae
1 parent fd8aa4f
commit 52659ae
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java b/...io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java
@@ -100,7 +100,7 @@ public void write(Record<byte[]> record) {
     }
 
     public KeyValue<String, byte[]> extractKeyValue(Record<byte[]> record) {
-        String key = record.getKey().orElseGet(null);
+        String key = record.getKey().orElse("");
         return new KeyValue<>(key, record.getValue());
     }