Commit 5653a96f authored by root's avatar root
Browse files

Upgrade to 1.2.0 and remove degraded ProcessorLog

parent 48258ba4
......@@ -10,7 +10,7 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.7</maven.compiler.source>
<maven.compiler.target>1.7</maven.compiler.target>
<nifi.version>0.4.2-SNAPSHOT</nifi.version>
<nifi.version>1.2.0</nifi.version>
</properties>
<dependencies>
......
......@@ -18,7 +18,6 @@ import java.util.concurrent.atomic.AtomicReference;
import org.apache.commons.io.IOUtils;
import org.apache.nifi.components.PropertyDescriptor;
import org.apache.nifi.flowfile.FlowFile;
import org.apache.nifi.logging.ProcessorLog;
import org.apache.nifi.processor.AbstractProcessor;
import org.apache.nifi.processor.ProcessContext;
import org.apache.nifi.processor.ProcessSession;
......@@ -70,7 +69,7 @@ public class JsonProcessor extends AbstractProcessor {
@Override
public void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException {
final ProcessorLog log = this.getLogger();
final AtomicReference<String> value = new AtomicReference<>();
FlowFile flowfile = session.get();
......@@ -84,7 +83,7 @@ public class JsonProcessor extends AbstractProcessor {
value.set(result);
}catch(Exception ex){
ex.printStackTrace();
log.error("Failed to read json string.");
getLogger().error("Failed to read json string.");
}
}
});
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment