From 5bd4493ea21eead46d34ac64bbeb5860602bbe94 Mon Sep 17 00:00:00 2001
From: javanna <cavannaluca@gmail.com>
Date: Thu, 12 Nov 2015 15:38:36 +0100
Subject: [PATCH] use ConfigurationUtils to read string value from config

---
 .../src/main/java/org/elasticsearch/ingest/Pipeline.java       | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/plugins/ingest/src/main/java/org/elasticsearch/ingest/Pipeline.java b/plugins/ingest/src/main/java/org/elasticsearch/ingest/Pipeline.java
index a719c4ec727..2101158c215 100644
--- a/plugins/ingest/src/main/java/org/elasticsearch/ingest/Pipeline.java
+++ b/plugins/ingest/src/main/java/org/elasticsearch/ingest/Pipeline.java
@@ -20,6 +20,7 @@
 
 package org.elasticsearch.ingest;
 
+import org.elasticsearch.ingest.processor.ConfigurationUtils;
 import org.elasticsearch.ingest.processor.Processor;
 
 import java.io.IOException;
@@ -73,7 +74,7 @@ public final class Pipeline {
     public final static class Factory {
 
         public Pipeline create(String id, Map<String, Object> config, Map<String, Processor.Factory> processorRegistry) throws IOException {
-            String description = (String) config.get("description");
+            String description = ConfigurationUtils.readStringProperty(config, "description");
             List<Processor> processors = new ArrayList<>();
             @SuppressWarnings("unchecked")
             List<Map<String, Map<String, Object>>> processorConfigs = (List<Map<String, Map<String, Object>>>) config.get("processors");