Added currency correction from findbugs.

jcustenborder · Mar 21, 2016 · 6e03970 · 6e03970
1 parent 505b053
commit 6e03970
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/confluent/connect/solr/sink/SolrInputDocumentConverter.java b/src/main/java/io/confluent/connect/solr/sink/SolrInputDocumentConverter.java
@@ -67,7 +67,7 @@ void convertField(final Struct row, Field field, SolrInputDocument solrInputDocu
     if(currencyFields.containsKey(field.name())){
       String currencyCode = currencyFields.get(field.name());
       String currency = String.format("%s,%s", value, currencyCode);
-      solrInputDocument.addField(solrField, value);
+      solrInputDocument.addField(solrField, currency);
     } else {
       switch(field.schema().type()){
         default: