2018-03-30 07:04:02,776 INFO [main] org.apache.nifi.NiFi Launching NiFi... 2018-03-30 07:04:03,035 INFO [main] o.a.nifi.properties.NiFiPropertiesLoader Determined default nifi.properties path to be '/opt/nifi/nifi-1.5.0/./conf/nifi.properties' 2018-03-30 07:04:03,061 INFO [main] o.a.nifi.properties.NiFiPropertiesLoader Loaded 144 properties from /opt/nifi/nifi-1.5.0/./conf/nifi.properties 2018-03-30 07:04:03,068 INFO [main] org.apache.nifi.NiFi Loaded 144 properties 2018-03-30 07:04:03,076 INFO [main] org.apache.nifi.BootstrapListener Started Bootstrap Listener, Listening for incoming requests on port 33645 2018-03-30 07:04:03,091 INFO [main] org.apache.nifi.BootstrapListener Successfully initiated communication with Bootstrap 2018-03-30 07:04:03,102 INFO [main] org.apache.nifi.nar.NarUnpacker Expanding 88 NAR files with all processors... 2018-03-30 07:04:15,268 INFO [main] org.apache.nifi.nar.NarUnpacker NAR loading process took 12165947639 nanoseconds (12 seconds). 2018-03-30 07:04:15,569 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-jetty-bundle-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-jetty-bundle-1.5.0.nar-unpacked] 2018-03-30 07:04:15,579 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,579 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-slack-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-slack-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,580 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-gcp-services-api-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-gcp-services-api-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,581 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-avro-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-avro-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,582 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-hl7-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-hl7-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,583 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-snmp-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-snmp-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,584 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-kafka-0-8-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-kafka-0-8-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,585 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-update-attribute-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-update-attribute-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,587 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-ldap-iaa-providers-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-ldap-iaa-providers-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,589 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-ccda-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-ccda-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,590 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-language-translation-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-language-translation-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,592 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-datadog-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-datadog-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,592 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-spring-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-spring-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,593 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-kerberos-iaa-providers-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-kerberos-iaa-providers-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,594 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-enrich-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-enrich-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,596 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-tcp-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-tcp-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,596 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-couchbase-services-api-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-couchbase-services-api-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,597 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-ambari-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-ambari-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,598 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-poi-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-poi-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,599 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-provenance-repository-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-provenance-repository-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,600 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-cybersecurity-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-cybersecurity-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,601 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-standard-services-api-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-standard-services-api-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,601 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-html-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-html-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,607 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-media-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-media-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,607 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-riemann-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-riemann-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,611 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-hbase_1_1_2-client-service-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-hbase_1_1_2-client-service-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,615 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,616 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-mongodb-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-mongodb-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,617 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-social-media-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-social-media-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,618 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-redis-service-api-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-redis-service-api-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,619 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-solr-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-solr-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,620 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-lumberjack-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-lumberjack-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,621 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-hbase-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-hbase-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,621 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-hive-services-api-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-hive-services-api-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,623 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-hwx-schema-registry-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-hwx-schema-registry-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,624 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-couchbase-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-couchbase-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,624 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-rethinkdb-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-rethinkdb-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,629 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-gcp-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-gcp-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,630 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-kafka-0-9-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-kafka-0-9-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,631 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-groovyx-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-groovyx-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,634 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-elasticsearch-5-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-elasticsearch-5-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,634 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-http-context-map-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-http-context-map-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,635 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-splunk-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-splunk-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,635 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-dbcp-service-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-dbcp-service-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,637 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-confluent-platform-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-confluent-platform-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,637 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-websocket-services-api-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-websocket-services-api-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,638 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-mqtt-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-mqtt-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,638 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-metrics-reporter-service-api-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-metrics-reporter-service-api-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,640 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-hadoop-libraries-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-hadoop-libraries-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,641 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-amqp-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-amqp-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,641 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-site-to-site-reporting-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-site-to-site-reporting-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,642 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-beats-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-beats-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,642 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-distributed-cache-services-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-distributed-cache-services-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,643 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-redis-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-redis-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,643 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-azure-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-azure-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,644 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-mongodb-services-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-mongodb-services-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,644 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-livy-controller-service-api-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-livy-controller-service-api-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,645 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-ssl-context-service-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-ssl-context-service-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,646 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-flume-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-flume-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,646 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-registry-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-registry-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,650 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-hive-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-hive-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,650 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-jms-cf-service-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-jms-cf-service-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,651 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-websocket-processors-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-websocket-processors-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,651 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-kafka-0-11-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-kafka-0-11-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,652 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-ignite-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-ignite-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,653 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-kafka-1-0-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-kafka-1-0-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,653 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-kafka-0-10-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-kafka-0-10-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,654 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-scripting-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-scripting-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,654 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-email-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-email-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,655 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-cdc-mysql-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-cdc-mysql-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,656 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-kite-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-kite-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,657 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-kudu-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-kudu-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,658 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-lookup-services-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-lookup-services-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,659 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-windows-event-log-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-windows-event-log-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,660 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-aws-service-api-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-aws-service-api-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,660 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-stateful-analysis-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-stateful-analysis-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,660 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-evtx-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-evtx-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,662 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-elasticsearch-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-elasticsearch-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,663 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-cassandra-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-cassandra-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,664 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-record-serialization-services-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-record-serialization-services-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,665 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-livy-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-livy-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,666 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-websocket-services-jetty-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-websocket-services-jetty-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,666 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-hadoop-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-hadoop-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,666 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-metrics-reporting-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-metrics-reporting-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,667 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-jms-processors-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-jms-processors-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,668 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-parquet-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-parquet-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,670 INFO [main] org.apache.nifi.nar.NarClassLoaders Loaded NAR file: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked as class loader org.apache.nifi.nar.NarClassLoader[./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked] 2018-03-30 07:04:15,759 INFO [main] org.eclipse.jetty.util.log Logging initialized @13288ms to org.eclipse.jetty.util.log.Slf4jLog 2018-03-30 07:04:15,861 INFO [main] o.a.n.w.s.HostHeaderSanitizationCustomizer Created HostHeaderSanitizationCustomizer for b60de6df28f0:8080 2018-03-30 07:04:15,861 INFO [main] org.apache.nifi.web.server.JettyServer Added HostHeaderSanitizationCustomizer to HttpConfiguration: HostHeaderSanitizationCustomizer for b60de6df28f0:8080 2018-03-30 07:04:15,861 INFO [main] org.apache.nifi.web.server.JettyServer Configuring Jetty for HTTP on port: 8080 2018-03-30 07:04:15,981 INFO [main] org.apache.nifi.web.server.JettyServer Loading WAR: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-media-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-image-viewer-1.5.0.war with context path set to /nifi-image-viewer-1.5.0 2018-03-30 07:04:15,989 INFO [main] org.apache.nifi.web.server.JettyServer Loading WAR: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-jolt-transform-json-ui-1.5.0.war with context path set to /nifi-jolt-transform-json-ui-1.5.0 2018-03-30 07:04:15,989 INFO [main] org.apache.nifi.web.server.JettyServer Loading UI extension [ProcessorConfiguration, /nifi-jolt-transform-json-ui-1.5.0] for org.apache.nifi.processors.standard.JoltTransformJSON:org.apache.nifi:nifi-standard-nar:1.5.0 2018-03-30 07:04:15,992 INFO [main] org.apache.nifi.web.server.JettyServer Loading WAR: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-update-attribute-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-update-attribute-ui-1.5.0.war with context path set to /nifi-update-attribute-ui-1.5.0 2018-03-30 07:04:15,992 INFO [main] org.apache.nifi.web.server.JettyServer Loading UI extension [ProcessorConfiguration, /nifi-update-attribute-ui-1.5.0] for org.apache.nifi.processors.attributes.UpdateAttribute:org.apache.nifi:nifi-update-attribute-nar:1.5.0 2018-03-30 07:04:15,995 INFO [main] org.apache.nifi.web.server.JettyServer Loading WAR: /opt/nifi/nifi-1.5.0/./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-standard-content-viewer-1.5.0.war with context path set to /nifi-standard-content-viewer-1.5.0 2018-03-30 07:04:16,006 INFO [main] org.apache.nifi.web.server.JettyServer Loading WAR: /opt/nifi/nifi-1.5.0/./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-web-ui-1.5.0.war with context path set to /nifi 2018-03-30 07:04:16,007 INFO [main] org.apache.nifi.web.server.JettyServer Loading WAR: /opt/nifi/nifi-1.5.0/./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-web-api-1.5.0.war with context path set to /nifi-api 2018-03-30 07:04:16,008 INFO [main] org.apache.nifi.web.server.JettyServer Loading WAR: /opt/nifi/nifi-1.5.0/./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-web-content-viewer-1.5.0.war with context path set to /nifi-content-viewer 2018-03-30 07:04:16,009 INFO [main] org.apache.nifi.web.server.JettyServer Loading WAR: /opt/nifi/nifi-1.5.0/./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-web-docs-1.5.0.war with context path set to /nifi-docs 2018-03-30 07:04:16,028 INFO [main] org.apache.nifi.web.server.JettyServer Loading documents web app with context path set to /nifi-docs 2018-03-30 07:04:16,031 INFO [main] org.apache.nifi.web.server.JettyServer Loading WAR: /opt/nifi/nifi-1.5.0/./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-web-error-1.5.0.war with context path set to / 2018-03-30 07:04:16,074 INFO [main] o.a.nifi.web.server.HostHeaderHandler Created HostHeaderHandler for b60de6df28f0:8080 2018-03-30 07:04:16,075 INFO [main] org.apache.nifi.web.server.JettyServer Created HostHeaderHandler [HostHeaderHandler for b60de6df28f0:8080] 2018-03-30 07:04:22,099 INFO [main] org.apache.nifi.nar.ExtensionManager Extension Type Mapping to Bundle: === StateProvider Type === org.apache.nifi.controller.state.providers.local.WriteAheadLocalStateProvider org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked org.apache.nifi.redis.state.RedisStateProvider org.apache.nifi:nifi-redis-nar:1.5.0 || ./work/nar/extensions/nifi-redis-nar-1.5.0.nar-unpacked org.apache.nifi.controller.state.providers.zookeeper.ZooKeeperStateProvider org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked === End StateProvider types === === ControllerService Type === org.apache.nifi.mongodb.MongoDBControllerService org.apache.nifi:nifi-mongodb-services-nar:1.5.0 || ./work/nar/extensions/nifi-mongodb-services-nar-1.5.0.nar-unpacked org.apache.nifi.ssl.StandardRestrictedSSLContextService org.apache.nifi:nifi-ssl-context-service-nar:1.5.0 || ./work/nar/extensions/nifi-ssl-context-service-nar-1.5.0.nar-unpacked org.apache.nifi.json.JsonPathReader org.apache.nifi:nifi-record-serialization-services-nar:1.5.0 || ./work/nar/extensions/nifi-record-serialization-services-nar-1.5.0.nar-unpacked org.apache.nifi.csv.CSVRecordSetWriter org.apache.nifi:nifi-record-serialization-services-nar:1.5.0 || ./work/nar/extensions/nifi-record-serialization-services-nar-1.5.0.nar-unpacked org.apache.nifi.http.StandardHttpContextMap org.apache.nifi:nifi-http-context-map-nar:1.5.0 || ./work/nar/extensions/nifi-http-context-map-nar-1.5.0.nar-unpacked org.apache.nifi.lookup.XMLFileLookupService org.apache.nifi:nifi-lookup-services-nar:1.5.0 || ./work/nar/extensions/nifi-lookup-services-nar-1.5.0.nar-unpacked org.apache.nifi.websocket.jetty.JettyWebSocketClient org.apache.nifi:nifi-websocket-services-jetty-nar:1.5.0 || ./work/nar/extensions/nifi-websocket-services-jetty-nar-1.5.0.nar-unpacked org.apache.nifi.mongodb.MongoDBLookupService org.apache.nifi:nifi-mongodb-services-nar:1.5.0 || ./work/nar/extensions/nifi-mongodb-services-nar-1.5.0.nar-unpacked org.apache.nifi.couchbase.CouchbaseClusterService org.apache.nifi:nifi-couchbase-nar:1.5.0 || ./work/nar/extensions/nifi-couchbase-nar-1.5.0.nar-unpacked org.apache.nifi.dbcp.DBCPConnectionPool org.apache.nifi:nifi-dbcp-service-nar:1.5.0 || ./work/nar/extensions/nifi-dbcp-service-nar-1.5.0.nar-unpacked org.apache.nifi.distributed.cache.client.DistributedSetCacheClientService org.apache.nifi:nifi-distributed-cache-services-nar:1.5.0 || ./work/nar/extensions/nifi-distributed-cache-services-nar-1.5.0.nar-unpacked org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService org.apache.nifi:nifi-distributed-cache-services-nar:1.5.0 || ./work/nar/extensions/nifi-distributed-cache-services-nar-1.5.0.nar-unpacked org.apache.nifi.redis.service.RedisConnectionPoolService org.apache.nifi:nifi-redis-nar:1.5.0 || ./work/nar/extensions/nifi-redis-nar-1.5.0.nar-unpacked org.apache.nifi.jms.cf.JMSConnectionFactoryProvider org.apache.nifi:nifi-jms-processors-nar:1.5.0 || ./work/nar/extensions/nifi-jms-processors-nar-1.5.0.nar-unpacked org.apache.nifi.redis.service.RedisDistributedMapCacheClientService org.apache.nifi:nifi-redis-nar:1.5.0 || ./work/nar/extensions/nifi-redis-nar-1.5.0.nar-unpacked org.apache.nifi.hbase.HBase_1_1_2_RecordLookupService org.apache.nifi:nifi-hbase_1_1_2-client-service-nar:1.5.0 || ./work/nar/extensions/nifi-hbase_1_1_2-client-service-nar-1.5.0.nar-unpacked org.apache.nifi.lookup.script.ScriptedLookupService org.apache.nifi:nifi-scripting-nar:1.5.0 || ./work/nar/extensions/nifi-scripting-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.credentials.provider.service.AWSCredentialsProviderControllerService org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.hbase.HBase_1_1_2_ClientMapCacheService org.apache.nifi:nifi-hbase_1_1_2-client-service-nar:1.5.0 || ./work/nar/extensions/nifi-hbase_1_1_2-client-service-nar-1.5.0.nar-unpacked org.apache.nifi.processors.gcp.credentials.service.GCPCredentialsControllerService org.apache.nifi:nifi-gcp-nar:1.5.0 || ./work/nar/extensions/nifi-gcp-nar-1.5.0.nar-unpacked org.apache.nifi.csv.CSVReader org.apache.nifi:nifi-record-serialization-services-nar:1.5.0 || ./work/nar/extensions/nifi-record-serialization-services-nar-1.5.0.nar-unpacked org.apache.nifi.lookup.SimpleCsvFileLookupService org.apache.nifi:nifi-lookup-services-nar:1.5.0 || ./work/nar/extensions/nifi-lookup-services-nar-1.5.0.nar-unpacked org.apache.nifi.text.FreeFormTextRecordSetWriter org.apache.nifi:nifi-record-serialization-services-nar:1.5.0 || ./work/nar/extensions/nifi-record-serialization-services-nar-1.5.0.nar-unpacked org.apache.nifi.websocket.jetty.JettyWebSocketServer org.apache.nifi:nifi-websocket-services-jetty-nar:1.5.0 || ./work/nar/extensions/nifi-websocket-services-jetty-nar-1.5.0.nar-unpacked org.apache.nifi.schemaregistry.services.AvroSchemaRegistry org.apache.nifi:nifi-registry-nar:1.5.0 || ./work/nar/extensions/nifi-registry-nar-1.5.0.nar-unpacked org.apache.nifi.lookup.SimpleKeyValueLookupService org.apache.nifi:nifi-lookup-services-nar:1.5.0 || ./work/nar/extensions/nifi-lookup-services-nar-1.5.0.nar-unpacked org.apache.nifi.record.script.ScriptedReader org.apache.nifi:nifi-scripting-nar:1.5.0 || ./work/nar/extensions/nifi-scripting-nar-1.5.0.nar-unpacked org.apache.nifi.lookup.CSVRecordLookupService org.apache.nifi:nifi-lookup-services-nar:1.5.0 || ./work/nar/extensions/nifi-lookup-services-nar-1.5.0.nar-unpacked org.apache.nifi.controller.livy.LivySessionController org.apache.nifi:nifi-livy-nar:1.5.0 || ./work/nar/extensions/nifi-livy-nar-1.5.0.nar-unpacked org.apache.nifi.confluent.schemaregistry.ConfluentSchemaRegistry org.apache.nifi:nifi-confluent-platform-nar:1.5.0 || ./work/nar/extensions/nifi-confluent-platform-nar-1.5.0.nar-unpacked org.apache.nifi.avro.AvroReader org.apache.nifi:nifi-record-serialization-services-nar:1.5.0 || ./work/nar/extensions/nifi-record-serialization-services-nar-1.5.0.nar-unpacked org.apache.nifi.json.JsonRecordSetWriter org.apache.nifi:nifi-record-serialization-services-nar:1.5.0 || ./work/nar/extensions/nifi-record-serialization-services-nar-1.5.0.nar-unpacked org.apache.nifi.hbase.HBase_1_1_2_ClientService org.apache.nifi:nifi-hbase_1_1_2-client-service-nar:1.5.0 || ./work/nar/extensions/nifi-hbase_1_1_2-client-service-nar-1.5.0.nar-unpacked org.apache.nifi.dbcp.hive.HiveConnectionPool org.apache.nifi:nifi-hive-nar:1.5.0 || ./work/nar/extensions/nifi-hive-nar-1.5.0.nar-unpacked org.apache.nifi.grok.GrokReader org.apache.nifi:nifi-record-serialization-services-nar:1.5.0 || ./work/nar/extensions/nifi-record-serialization-services-nar-1.5.0.nar-unpacked org.apache.nifi.distributed.cache.server.map.DistributedMapCacheServer org.apache.nifi:nifi-distributed-cache-services-nar:1.5.0 || ./work/nar/extensions/nifi-distributed-cache-services-nar-1.5.0.nar-unpacked org.apache.nifi.lookup.PropertiesFileLookupService org.apache.nifi:nifi-lookup-services-nar:1.5.0 || ./work/nar/extensions/nifi-lookup-services-nar-1.5.0.nar-unpacked org.apache.nifi.json.JsonTreeReader org.apache.nifi:nifi-record-serialization-services-nar:1.5.0 || ./work/nar/extensions/nifi-record-serialization-services-nar-1.5.0.nar-unpacked org.apache.nifi.metrics.reporting.reporter.service.GraphiteMetricReporterService org.apache.nifi:nifi-metrics-reporting-nar:1.5.0 || ./work/nar/extensions/nifi-metrics-reporting-nar-1.5.0.nar-unpacked org.apache.nifi.avro.AvroRecordSetWriter org.apache.nifi:nifi-record-serialization-services-nar:1.5.0 || ./work/nar/extensions/nifi-record-serialization-services-nar-1.5.0.nar-unpacked org.apache.nifi.schemaregistry.hortonworks.HortonworksSchemaRegistry org.apache.nifi:nifi-hwx-schema-registry-nar:1.5.0 || ./work/nar/extensions/nifi-hwx-schema-registry-nar-1.5.0.nar-unpacked org.apache.nifi.record.script.ScriptedRecordSetWriter org.apache.nifi:nifi-scripting-nar:1.5.0 || ./work/nar/extensions/nifi-scripting-nar-1.5.0.nar-unpacked org.apache.nifi.lookup.maxmind.IPLookupService org.apache.nifi:nifi-lookup-services-nar:1.5.0 || ./work/nar/extensions/nifi-lookup-services-nar-1.5.0.nar-unpacked org.apache.nifi.ssl.StandardSSLContextService org.apache.nifi:nifi-ssl-context-service-nar:1.5.0 || ./work/nar/extensions/nifi-ssl-context-service-nar-1.5.0.nar-unpacked org.apache.nifi.distributed.cache.server.DistributedSetCacheServer org.apache.nifi:nifi-distributed-cache-services-nar:1.5.0 || ./work/nar/extensions/nifi-distributed-cache-services-nar-1.5.0.nar-unpacked === End ControllerService types === === AccessPolicyProvider Type === org.apache.nifi.authorization.FileAccessPolicyProvider org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked === End AccessPolicyProvider types === === Processor Type === org.apache.nifi.processors.aws.s3.PutS3Object org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ListenTCP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.ignite.cache.PutIgniteCache org.apache.nifi:nifi-ignite-nar:1.5.0 || ./work/nar/extensions/nifi-ignite-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ConvertRecord org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hadoop.FetchHDFS org.apache.nifi:nifi-hadoop-nar:1.5.0 || ./work/nar/extensions/nifi-hadoop-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.RouteOnContent org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.splunk.PutSplunk org.apache.nifi:nifi-splunk-nar:1.5.0 || ./work/nar/extensions/nifi-splunk-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.RouteText org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kudu.PutKudu org.apache.nifi:nifi-kudu-nar:1.5.0 || ./work/nar/extensions/nifi-kudu-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hl7.RouteHL7 org.apache.nifi:nifi-hl7-nar:1.5.0 || ./work/nar/extensions/nifi-hl7-nar-1.5.0.nar-unpacked org.apache.nifi.processors.couchbase.GetCouchbaseKey org.apache.nifi:nifi-couchbase-nar:1.5.0 || ./work/nar/extensions/nifi-couchbase-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kite.ConvertAvroSchema org.apache.nifi:nifi-kite-nar:1.5.0 || ./work/nar/extensions/nifi-kite-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.TailFile org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.sqs.DeleteSQS org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.Wait org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kite.ConvertCSVToAvro org.apache.nifi:nifi-kite-nar:1.5.0 || ./work/nar/extensions/nifi-kite-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ParseSyslog org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.elasticsearch.PutElasticsearchHttpRecord org.apache.nifi:nifi-elasticsearch-nar:1.5.0 || ./work/nar/extensions/nifi-elasticsearch-nar-1.5.0.nar-unpacked org.apache.nifi.processors.enrich.QueryWhois org.apache.nifi:nifi-enrich-nar:1.5.0 || ./work/nar/extensions/nifi-enrich-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.SplitJson org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.CountText org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ConvertCharacterSet org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.evtx.ParseEvtx org.apache.nifi:nifi-evtx-nar:1.5.0 || ./work/nar/extensions/nifi-evtx-nar-1.5.0.nar-unpacked org.apache.nifi.processors.ignite.cache.GetIgniteCache org.apache.nifi:nifi-ignite-nar:1.5.0 || ./work/nar/extensions/nifi-ignite-nar-1.5.0.nar-unpacked org.apache.nifi.processors.couchbase.PutCouchbaseKey org.apache.nifi:nifi-couchbase-nar:1.5.0 || ./work/nar/extensions/nifi-couchbase-nar-1.5.0.nar-unpacked org.apache.nifi.processors.email.ExtractTNEFAttachments org.apache.nifi:nifi-email-nar:1.5.0 || ./work/nar/extensions/nifi-email-nar-1.5.0.nar-unpacked org.apache.nifi.processors.gettcp.GetTCP org.apache.nifi:nifi-tcp-nar:1.5.0 || ./work/nar/extensions/nifi-tcp-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.kinesis.stream.PutKinesisStream org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.FetchFile org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.elasticsearch.FetchElasticsearch5 org.apache.nifi:nifi-elasticsearch-5-nar:1.5.0 || ./work/nar/extensions/nifi-elasticsearch-5-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_1_0 org.apache.nifi:nifi-kafka-1-0-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-1-0-nar-1.5.0.nar-unpacked org.apache.nifi.processors.email.ConsumeIMAP org.apache.nifi:nifi-email-nar:1.5.0 || ./work/nar/extensions/nifi-email-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.PostHTTP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.PutHTMLElement org.apache.nifi:nifi-html-nar:1.5.0 || ./work/nar/extensions/nifi-html-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ListenTCPRecord org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.azure.eventhub.PutAzureEventHub org.apache.nifi:nifi-azure-nar:1.5.0 || ./work/nar/extensions/nifi-azure-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.PutFile org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.gcp.storage.PutGCSObject org.apache.nifi:nifi-gcp-nar:1.5.0 || ./work/nar/extensions/nifi-gcp-nar-1.5.0.nar-unpacked org.apache.nifi.processors.elasticsearch.DeleteElasticsearch5 org.apache.nifi:nifi-elasticsearch-5-nar:1.5.0 || ./work/nar/extensions/nifi-elasticsearch-5-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ListDatabaseTables org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.PutFTP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.elasticsearch.PutElasticsearchHttp org.apache.nifi:nifi-elasticsearch-nar:1.5.0 || ./work/nar/extensions/nifi-elasticsearch-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.UnpackContent org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ControlRate org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hive.PutHiveQL org.apache.nifi:nifi-hive-nar:1.5.0 || ./work/nar/extensions/nifi-hive-nar-1.5.0.nar-unpacked org.apache.nifi.processors.cassandra.PutCassandraQL org.apache.nifi:nifi-cassandra-nar:1.5.0 || ./work/nar/extensions/nifi-cassandra-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ListenSyslog org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.PutDistributedMapCache org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.EvaluateXQuery org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.riemann.PutRiemann org.apache.nifi:nifi-riemann-nar:1.5.0 || ./work/nar/extensions/nifi-riemann-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ExecuteStreamCommand org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hive.SelectHiveQL org.apache.nifi:nifi-hive-nar:1.5.0 || ./work/nar/extensions/nifi-hive-nar-1.5.0.nar-unpacked org.apache.nifi.hbase.PutHBaseRecord org.apache.nifi:nifi-hbase-nar:1.5.0 || ./work/nar/extensions/nifi-hbase-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ExecuteProcess org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.avro.ConvertAvroToJSON org.apache.nifi:nifi-avro-nar:1.5.0 || ./work/nar/extensions/nifi-avro-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ExecuteSQL org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.PutSQL org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.amqp.processors.ConsumeAMQP org.apache.nifi:nifi-amqp-nar:1.5.0 || ./work/nar/extensions/nifi-amqp-nar-1.5.0.nar-unpacked org.apache.nifi.processors.email.ConsumeEWS org.apache.nifi:nifi-email-nar:1.5.0 || ./work/nar/extensions/nifi-email-nar-1.5.0.nar-unpacked org.apache.nifi.snmp.processors.GetSNMP org.apache.nifi:nifi-snmp-nar:1.5.0 || ./work/nar/extensions/nifi-snmp-nar-1.5.0.nar-unpacked org.apache.nifi.processors.websocket.PutWebSocket org.apache.nifi:nifi-websocket-processors-nar:1.5.0 || ./work/nar/extensions/nifi-websocket-processors-nar-1.5.0.nar-unpacked org.apache.nifi.snmp.processors.SetSNMP org.apache.nifi:nifi-snmp-nar:1.5.0 || ./work/nar/extensions/nifi-snmp-nar-1.5.0.nar-unpacked org.apache.nifi.processors.cybersecurity.CompareFuzzyHash org.apache.nifi:nifi-cybersecurity-nar:1.5.0 || ./work/nar/extensions/nifi-cybersecurity-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ScanAttribute org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.jms.processors.ConsumeJMS org.apache.nifi:nifi-jms-processors-nar:1.5.0 || ./work/nar/extensions/nifi-jms-processors-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ListenHTTP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.EvaluateJsonPath org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ReplaceText org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.sns.PutSNS org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.GetHTMLElement org.apache.nifi:nifi-html-nar:1.5.0 || ./work/nar/extensions/nifi-html-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0 org.apache.nifi:nifi-kafka-1-0-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-1-0-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_0_10 org.apache.nifi:nifi-kafka-0-10-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-0-10-nar-1.5.0.nar-unpacked org.apache.nifi.processors.media.ExtractMediaMetadata org.apache.nifi:nifi-media-nar:1.5.0 || ./work/nar/extensions/nifi-media-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hadoop.inotify.GetHDFSEvents org.apache.nifi:nifi-hadoop-nar:1.5.0 || ./work/nar/extensions/nifi-hadoop-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.SplitText org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.solr.GetSolr org.apache.nifi:nifi-solr-nar:1.5.0 || ./work/nar/extensions/nifi-solr-nar-1.5.0.nar-unpacked org.apache.nifi.processors.gcp.storage.FetchGCSObject org.apache.nifi:nifi-gcp-nar:1.5.0 || ./work/nar/extensions/nifi-gcp-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.DetectDuplicate org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kite.StoreInKiteDataset org.apache.nifi:nifi-kite-nar:1.5.0 || ./work/nar/extensions/nifi-kite-nar-1.5.0.nar-unpacked org.apache.nifi.processors.parquet.FetchParquet org.apache.nifi:nifi-parquet-nar:1.5.0 || ./work/nar/extensions/nifi-parquet-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ScanContent org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.image.ExtractImageMetadata org.apache.nifi:nifi-media-nar:1.5.0 || ./work/nar/extensions/nifi-media-nar-1.5.0.nar-unpacked org.apache.nifi.processors.azure.storage.FetchAzureBlobStorage org.apache.nifi:nifi-azure-nar:1.5.0 || ./work/nar/extensions/nifi-azure-nar-1.5.0.nar-unpacked org.apache.nifi.processors.elasticsearch.FetchElasticsearchHttp org.apache.nifi:nifi-elasticsearch-nar:1.5.0 || ./work/nar/extensions/nifi-elasticsearch-nar-1.5.0.nar-unpacked org.apache.nifi.processors.mongodb.PutMongoRecord org.apache.nifi:nifi-mongodb-nar:1.5.0 || ./work/nar/extensions/nifi-mongodb-nar-1.5.0.nar-unpacked org.apache.nifi.processors.azure.eventhub.ConsumeAzureEventHub org.apache.nifi:nifi-azure-nar:1.5.0 || ./work/nar/extensions/nifi-azure-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ConvertJSONToSQL org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ExtractText org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.elasticsearch.QueryElasticsearchHttp org.apache.nifi:nifi-elasticsearch-nar:1.5.0 || ./work/nar/extensions/nifi-elasticsearch-nar-1.5.0.nar-unpacked org.apache.nifi.processors.twitter.GetTwitter org.apache.nifi:nifi-social-media-nar:1.5.0 || ./work/nar/extensions/nifi-social-media-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ValidateCsv org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.GeoEnrichIP org.apache.nifi:nifi-enrich-nar:1.5.0 || ./work/nar/extensions/nifi-enrich-nar-1.5.0.nar-unpacked org.apache.nifi.processors.solr.PutSolrContentStream org.apache.nifi:nifi-solr-nar:1.5.0 || ./work/nar/extensions/nifi-solr-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.EvaluateXPath org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.FetchSFTP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.dynamodb.DeleteDynamoDB org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.MergeContent org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.amqp.processors.PublishAMQP org.apache.nifi:nifi-amqp-nar:1.5.0 || ./work/nar/extensions/nifi-amqp-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.SplitRecord org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ValidateRecord org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.CompressContent org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.GenerateTableFetch org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.MergeRecord org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ListFTP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hadoop.GetHDFSSequenceFile org.apache.nifi:nifi-hadoop-nar:1.5.0 || ./work/nar/extensions/nifi-hadoop-nar-1.5.0.nar-unpacked org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow org.apache.nifi:nifi-stateful-analysis-nar:1.5.0 || ./work/nar/extensions/nifi-stateful-analysis-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.cloudwatch.PutCloudWatchMetric org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.avro.ExtractAvroMetadata org.apache.nifi:nifi-avro-nar:1.5.0 || ./work/nar/extensions/nifi-avro-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.Notify org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.splunk.GetSplunk org.apache.nifi:nifi-splunk-nar:1.5.0 || ./work/nar/extensions/nifi-splunk-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.PutEmail org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.flume.ExecuteFlumeSource org.apache.nifi:nifi-flume-nar:1.5.0 || ./work/nar/extensions/nifi-flume-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.PutSyslog org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.LogMessage org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.windows.event.log.ConsumeWindowsEventLog org.apache.nifi:nifi-windows-event-log-nar:1.5.0 || ./work/nar/extensions/nifi-windows-event-log-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.s3.DeleteS3Object org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ParseCEF org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_11 org.apache.nifi:nifi-kafka-0-11-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-0-11-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.PutDatabaseRecord org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.HashContent org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.groovyx.ExecuteGroovyScript org.apache.nifi:nifi-groovyx-nar:1.5.0 || ./work/nar/extensions/nifi-groovyx-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ExtractGrok org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.ModifyHTMLElement org.apache.nifi:nifi-html-nar:1.5.0 || ./work/nar/extensions/nifi-html-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.rethinkdb.DeleteRethinkDB org.apache.nifi:nifi-rethinkdb-nar:1.5.0 || ./work/nar/extensions/nifi-rethinkdb-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ListenUDP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.beats.ListenBeats org.apache.nifi:nifi-beats-nar:1.5.0 || ./work/nar/extensions/nifi-beats-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.LookupRecord org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.GetKafka org.apache.nifi:nifi-kafka-0-8-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-0-8-nar-1.5.0.nar-unpacked org.apache.nifi.jms.processors.PublishJMS org.apache.nifi:nifi-jms-processors-nar:1.5.0 || ./work/nar/extensions/nifi-jms-processors-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.FetchFTP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_0_11 org.apache.nifi:nifi-kafka-0-11-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-0-11-nar-1.5.0.nar-unpacked org.apache.nifi.processors.email.ExtractEmailHeaders org.apache.nifi:nifi-email-nar:1.5.0 || ./work/nar/extensions/nifi-email-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.SplitXml org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.spring.SpringContextProcessor org.apache.nifi:nifi-spring-nar:1.5.0 || ./work/nar/extensions/nifi-spring-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.PutSFTP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.script.ExecuteScript org.apache.nifi:nifi-scripting-nar:1.5.0 || ./work/nar/extensions/nifi-scripting-nar-1.5.0.nar-unpacked org.apache.nifi.hbase.FetchHBaseRow org.apache.nifi:nifi-hbase-nar:1.5.0 || ./work/nar/extensions/nifi-hbase-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.GetFile org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.Base64EncodeContent org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.s3.ListS3 org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.JoltTransformJSON org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.email.ListenSMTP org.apache.nifi:nifi-email-nar:1.5.0 || ./work/nar/extensions/nifi-email-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.DistributeLoad org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.InvokeHTTP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.MonitorActivity org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.elasticsearch.PutElasticsearch5 org.apache.nifi:nifi-elasticsearch-5-nar:1.5.0 || ./work/nar/extensions/nifi-elasticsearch-5-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.HashAttribute org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.PartitionRecord org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.avro.SplitAvro org.apache.nifi:nifi-avro-nar:1.5.0 || ./work/nar/extensions/nifi-avro-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.EncryptContent org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.GetJMSQueue org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kite.ConvertJSONToAvro org.apache.nifi:nifi-kite-nar:1.5.0 || ./work/nar/extensions/nifi-kite-nar-1.5.0.nar-unpacked org.apache.nifi.hbase.PutHBaseJSON org.apache.nifi:nifi-hbase-nar:1.5.0 || ./work/nar/extensions/nifi-hbase-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hadoop.MoveHDFS org.apache.nifi:nifi-hadoop-nar:1.5.0 || ./work/nar/extensions/nifi-hadoop-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ListenUDPRecord org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.lambda.PutLambda org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.rethinkdb.PutRethinkDB org.apache.nifi:nifi-rethinkdb-nar:1.5.0 || ./work/nar/extensions/nifi-rethinkdb-nar-1.5.0.nar-unpacked org.apache.nifi.processors.mongodb.DeleteMongo org.apache.nifi:nifi-mongodb-nar:1.5.0 || ./work/nar/extensions/nifi-mongodb-nar-1.5.0.nar-unpacked org.apache.nifi.processors.elasticsearch.ScrollElasticsearchHttp org.apache.nifi:nifi-elasticsearch-nar:1.5.0 || ./work/nar/extensions/nifi-elasticsearch-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.sqs.PutSQS org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.dynamodb.PutDynamoDB org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.DuplicateFlowFile org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.poi.ConvertExcelToCSVProcessor org.apache.nifi:nifi-poi-nar:1.5.0 || ./work/nar/extensions/nifi-poi-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.GenerateFlowFile org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.azure.eventhub.GetAzureEventHub org.apache.nifi:nifi-azure-nar:1.5.0 || ./work/nar/extensions/nifi-azure-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.ConsumeKafka org.apache.nifi:nifi-kafka-0-9-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-0-9-nar-1.5.0.nar-unpacked org.apache.nifi.processors.image.ResizeImage org.apache.nifi:nifi-media-nar:1.5.0 || ./work/nar/extensions/nifi-media-nar-1.5.0.nar-unpacked org.apache.nifi.processors.mqtt.PublishMQTT org.apache.nifi:nifi-mqtt-nar:1.5.0 || ./work/nar/extensions/nifi-mqtt-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.EnforceOrder org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.hbase.PutHBaseCell org.apache.nifi:nifi-hbase-nar:1.5.0 || ./work/nar/extensions/nifi-hbase-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.PutJMS org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.SegmentContent org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hive.ConvertAvroToORC org.apache.nifi:nifi-hive-nar:1.5.0 || ./work/nar/extensions/nifi-hive-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.IdentifyMimeType org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.email.ConsumePOP3 org.apache.nifi:nifi-email-nar:1.5.0 || ./work/nar/extensions/nifi-email-nar-1.5.0.nar-unpacked org.apache.nifi.processors.mongodb.PutMongo org.apache.nifi:nifi-mongodb-nar:1.5.0 || ./work/nar/extensions/nifi-mongodb-nar-1.5.0.nar-unpacked org.apache.nifi.processors.enrich.QueryDNS org.apache.nifi:nifi-enrich-nar:1.5.0 || ./work/nar/extensions/nifi-enrich-nar-1.5.0.nar-unpacked org.apache.nifi.processors.mqtt.ConsumeMQTT org.apache.nifi:nifi-mqtt-nar:1.5.0 || ./work/nar/extensions/nifi-mqtt-nar-1.5.0.nar-unpacked org.apache.nifi.processors.parquet.PutParquet org.apache.nifi:nifi-parquet-nar:1.5.0 || ./work/nar/extensions/nifi-parquet-nar-1.5.0.nar-unpacked org.apache.nifi.processors.gcp.storage.ListGCSBucket org.apache.nifi:nifi-gcp-nar:1.5.0 || ./work/nar/extensions/nifi-gcp-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.PublishKafka org.apache.nifi:nifi-kafka-0-9-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-0-9-nar-1.5.0.nar-unpacked org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL org.apache.nifi:nifi-cdc-mysql-nar:1.5.0 || ./work/nar/extensions/nifi-cdc-mysql-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hadoop.ListHDFS org.apache.nifi:nifi-hadoop-nar:1.5.0 || ./work/nar/extensions/nifi-hadoop-nar-1.5.0.nar-unpacked org.apache.nifi.processors.azure.storage.PutAzureBlobStorage org.apache.nifi:nifi-azure-nar:1.5.0 || ./work/nar/extensions/nifi-azure-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.LogAttribute org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ReplaceTextWithMapping org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_0_10 org.apache.nifi:nifi-kafka-0-10-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-0-10-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.FlattenJson org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.LookupAttribute org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ModifyBytes org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ValidateXml org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.attributes.UpdateAttribute org.apache.nifi:nifi-update-attribute-nar:1.5.0 || ./work/nar/extensions/nifi-update-attribute-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.PutUDP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.HandleHttpRequest org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.QueryRecord org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_10 org.apache.nifi:nifi-kafka-0-10-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-0-10-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ListenRELP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.GetHTTP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.GetJMSTopic org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.UpdateRecord org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.AttributesToJSON org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_0_11 org.apache.nifi:nifi-kafka-0-11-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-0-11-nar-1.5.0.nar-unpacked org.apache.nifi.processors.script.InvokeScriptedProcessor org.apache.nifi:nifi-scripting-nar:1.5.0 || ./work/nar/extensions/nifi-scripting-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.s3.FetchS3Object org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hadoop.DeleteHDFS org.apache.nifi:nifi-hadoop-nar:1.5.0 || ./work/nar/extensions/nifi-hadoop-nar-1.5.0.nar-unpacked org.apache.nifi.processors.cybersecurity.FuzzyHashContent org.apache.nifi:nifi-cybersecurity-nar:1.5.0 || ./work/nar/extensions/nifi-cybersecurity-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.PublishKafka_1_0 org.apache.nifi:nifi-kafka-1-0-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-1-0-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.sqs.GetSQS org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.flume.ExecuteFlumeSink org.apache.nifi:nifi-flume-nar:1.5.0 || ./work/nar/extensions/nifi-flume-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kite.InferAvroSchema org.apache.nifi:nifi-kite-nar:1.5.0 || ./work/nar/extensions/nifi-kite-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_1_0 org.apache.nifi:nifi-kafka-1-0-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-1-0-nar-1.5.0.nar-unpacked org.apache.nifi.processors.lumberjack.ListenLumberjack org.apache.nifi:nifi-lumberjack-nar:1.5.0 || ./work/nar/extensions/nifi-lumberjack-nar-1.5.0.nar-unpacked org.apache.nifi.processors.rethinkdb.GetRethinkDB org.apache.nifi:nifi-rethinkdb-nar:1.5.0 || ./work/nar/extensions/nifi-rethinkdb-nar-1.5.0.nar-unpacked org.apache.nifi.processors.yandex.YandexTranslate org.apache.nifi:nifi-language-translation-nar:1.5.0 || ./work/nar/extensions/nifi-language-translation-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.UpdateCounter org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.cassandra.QueryCassandra org.apache.nifi:nifi-cassandra-nar:1.5.0 || ./work/nar/extensions/nifi-cassandra-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ListFile org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.FetchDistributedMapCache org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.GetSFTP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.aws.dynamodb.GetDynamoDB org.apache.nifi:nifi-aws-nar:1.5.0 || ./work/nar/extensions/nifi-aws-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.DebugFlow org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.HandleHttpResponse org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hadoop.PutHDFS org.apache.nifi:nifi-hadoop-nar:1.5.0 || ./work/nar/extensions/nifi-hadoop-nar-1.5.0.nar-unpacked org.apache.nifi.processors.slack.PutSlack org.apache.nifi:nifi-slack-nar:1.5.0 || ./work/nar/extensions/nifi-slack-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.QueryDatabaseTable org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.TransformXml org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.azure.storage.ListAzureBlobStorage org.apache.nifi:nifi-azure-nar:1.5.0 || ./work/nar/extensions/nifi-azure-nar-1.5.0.nar-unpacked org.apache.nifi.processors.elasticsearch.FetchElasticsearch org.apache.nifi:nifi-elasticsearch-nar:1.5.0 || ./work/nar/extensions/nifi-elasticsearch-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_0_11 org.apache.nifi:nifi-kafka-0-11-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-0-11-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hl7.ExtractHL7Attributes org.apache.nifi:nifi-hl7-nar:1.5.0 || ./work/nar/extensions/nifi-hl7-nar-1.5.0.nar-unpacked org.apache.nifi.processors.gcp.storage.DeleteGCSObject org.apache.nifi:nifi-gcp-nar:1.5.0 || ./work/nar/extensions/nifi-gcp-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.RouteOnAttribute org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.PutTCP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.livy.ExecuteSparkInteractive org.apache.nifi:nifi-livy-nar:1.5.0 || ./work/nar/extensions/nifi-livy-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hive.PutHiveStreaming org.apache.nifi:nifi-hive-nar:1.5.0 || ./work/nar/extensions/nifi-hive-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.SplitContent org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.websocket.ListenWebSocket org.apache.nifi:nifi-websocket-processors-nar:1.5.0 || ./work/nar/extensions/nifi-websocket-processors-nar-1.5.0.nar-unpacked org.apache.nifi.processors.elasticsearch.PutElasticsearch org.apache.nifi:nifi-elasticsearch-nar:1.5.0 || ./work/nar/extensions/nifi-elasticsearch-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.PutKafka org.apache.nifi:nifi-kafka-0-8-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-0-8-nar-1.5.0.nar-unpacked org.apache.nifi.processors.email.ExtractEmailAttachments org.apache.nifi:nifi-email-nar:1.5.0 || ./work/nar/extensions/nifi-email-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hadoop.GetHDFS org.apache.nifi:nifi-hadoop-nar:1.5.0 || ./work/nar/extensions/nifi-hadoop-nar-1.5.0.nar-unpacked org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_0_10 org.apache.nifi:nifi-kafka-0-10-nar:1.5.0 || ./work/nar/extensions/nifi-kafka-0-10-nar-1.5.0.nar-unpacked org.apache.nifi.processors.hadoop.CreateHadoopSequenceFile org.apache.nifi:nifi-hadoop-nar:1.5.0 || ./work/nar/extensions/nifi-hadoop-nar-1.5.0.nar-unpacked org.apache.nifi.processors.websocket.ConnectWebSocket org.apache.nifi:nifi-websocket-processors-nar:1.5.0 || ./work/nar/extensions/nifi-websocket-processors-nar-1.5.0.nar-unpacked org.apache.nifi.hbase.GetHBase org.apache.nifi:nifi-hbase-nar:1.5.0 || ./work/nar/extensions/nifi-hbase-nar-1.5.0.nar-unpacked org.apache.nifi.processors.mongodb.GetMongo org.apache.nifi:nifi-mongodb-nar:1.5.0 || ./work/nar/extensions/nifi-mongodb-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.ListSFTP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.standard.GetFTP org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.processors.ccda.ExtractCCDAAttributes org.apache.nifi:nifi-ccda-nar:1.5.0 || ./work/nar/extensions/nifi-ccda-nar-1.5.0.nar-unpacked org.apache.nifi.processors.ISPEnrichIP org.apache.nifi:nifi-enrich-nar:1.5.0 || ./work/nar/extensions/nifi-enrich-nar-1.5.0.nar-unpacked === End Processor types === === FlowFilePrioritizer Type === org.apache.nifi.prioritizer.PriorityAttributePrioritizer org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked org.apache.nifi.prioritizer.NewestFlowFileFirstPrioritizer org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked org.apache.nifi.prioritizer.OldestFlowFileFirstPrioritizer org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked org.apache.nifi.prioritizer.FirstInFirstOutPrioritizer org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked === End FlowFilePrioritizer types === === ProvenanceRepository Type === org.apache.nifi.provenance.PersistentProvenanceRepository org.apache.nifi:nifi-provenance-repository-nar:1.5.0 || ./work/nar/extensions/nifi-provenance-repository-nar-1.5.0.nar-unpacked org.apache.nifi.provenance.VolatileProvenanceRepository org.apache.nifi:nifi-provenance-repository-nar:1.5.0 || ./work/nar/extensions/nifi-provenance-repository-nar-1.5.0.nar-unpacked org.apache.nifi.provenance.WriteAheadProvenanceRepository org.apache.nifi:nifi-provenance-repository-nar:1.5.0 || ./work/nar/extensions/nifi-provenance-repository-nar-1.5.0.nar-unpacked org.apache.nifi.provenance.EncryptedWriteAheadProvenanceRepository org.apache.nifi:nifi-provenance-repository-nar:1.5.0 || ./work/nar/extensions/nifi-provenance-repository-nar-1.5.0.nar-unpacked === End ProvenanceRepository types === === FlowFileSwapManager Type === org.apache.nifi.controller.FileSystemSwapManager org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked === End FlowFileSwapManager types === === UserGroupProvider Type === org.apache.nifi.authorization.CompositeUserGroupProvider org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked org.apache.nifi.ldap.tenants.LdapUserGroupProvider org.apache.nifi:nifi-ldap-iaa-providers-nar:1.5.0 || ./work/nar/extensions/nifi-ldap-iaa-providers-nar-1.5.0.nar-unpacked org.apache.nifi.authorization.FileUserGroupProvider org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked org.apache.nifi.authorization.CompositeConfigurableUserGroupProvider org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked === End UserGroupProvider types === === LoginIdentityProvider Type === org.apache.nifi.kerberos.KerberosProvider org.apache.nifi:nifi-kerberos-iaa-providers-nar:1.5.0 || ./work/nar/extensions/nifi-kerberos-iaa-providers-nar-1.5.0.nar-unpacked org.apache.nifi.ldap.LdapProvider org.apache.nifi:nifi-ldap-iaa-providers-nar:1.5.0 || ./work/nar/extensions/nifi-ldap-iaa-providers-nar-1.5.0.nar-unpacked === End LoginIdentityProvider types === === ReportingTask Type === org.apache.nifi.reporting.ganglia.StandardGangliaReporter org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.reporting.SiteToSiteBulletinReportingTask org.apache.nifi:nifi-site-to-site-reporting-nar:1.5.0 || ./work/nar/extensions/nifi-site-to-site-reporting-nar-1.5.0.nar-unpacked org.apache.nifi.controller.MonitorMemory org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.reporting.SiteToSiteStatusReportingTask org.apache.nifi:nifi-site-to-site-reporting-nar:1.5.0 || ./work/nar/extensions/nifi-site-to-site-reporting-nar-1.5.0.nar-unpacked org.apache.nifi.controller.ControllerStatusReportingTask org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.reporting.script.ScriptedReportingTask org.apache.nifi:nifi-scripting-nar:1.5.0 || ./work/nar/extensions/nifi-scripting-nar-1.5.0.nar-unpacked org.apache.nifi.reporting.ambari.AmbariReportingTask org.apache.nifi:nifi-ambari-nar:1.5.0 || ./work/nar/extensions/nifi-ambari-nar-1.5.0.nar-unpacked org.apache.nifi.reporting.SiteToSiteProvenanceReportingTask org.apache.nifi:nifi-site-to-site-reporting-nar:1.5.0 || ./work/nar/extensions/nifi-site-to-site-reporting-nar-1.5.0.nar-unpacked org.apache.nifi.reporting.datadog.DataDogReportingTask org.apache.nifi:nifi-datadog-nar:1.5.0 || ./work/nar/extensions/nifi-datadog-nar-1.5.0.nar-unpacked org.apache.nifi.controller.MonitorDiskUsage org.apache.nifi:nifi-standard-nar:1.5.0 || ./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked org.apache.nifi.metrics.reporting.task.MetricsReportingTask org.apache.nifi:nifi-metrics-reporting-nar:1.5.0 || ./work/nar/extensions/nifi-metrics-reporting-nar-1.5.0.nar-unpacked === End ReportingTask types === === FlowFileRepository Type === org.apache.nifi.controller.repository.WriteAheadFlowFileRepository org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked org.apache.nifi.controller.repository.VolatileFlowFileRepository org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked === End FlowFileRepository types === === ContentRepository Type === org.apache.nifi.controller.repository.VolatileContentRepository org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked org.apache.nifi.controller.repository.FileSystemRepository org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked === End ContentRepository types === === ComponentStatusRepository Type === org.apache.nifi.controller.status.history.VolatileComponentStatusRepository org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked === End ComponentStatusRepository types === === Authorizer Type === org.apache.nifi.authorization.StandardManagedAuthorizer org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked org.apache.nifi.authorization.FileAuthorizer org.apache.nifi:nifi-framework-nar:1.5.0 || ./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked === End Authorizer types === 2018-03-30 07:04:22,604 INFO [main] org.eclipse.jetty.server.Server jetty-9.4.3.v20170317 2018-03-30 07:04:22,898 INFO [main] o.e.j.a.AnnotationConfiguration Scanning elapsed time=96ms 2018-03-30 07:04:23,033 INFO [main] org.eclipse.jetty.server.session DefaultSessionIdManager workerName=node0 2018-03-30 07:04:23,033 INFO [main] org.eclipse.jetty.server.session No SessionScavenger set, using defaults 2018-03-30 07:04:23,035 INFO [main] org.eclipse.jetty.server.session Scavenging every 660000ms 2018-03-30 07:04:23,071 INFO [main] o.e.jetty.server.handler.ContextHandler Started o.e.j.w.WebAppContext@7b8fcdf2{/nifi-image-viewer-1.5.0,file:///opt/nifi/nifi-1.5.0/work/jetty/nifi-image-viewer-1.5.0.war/webapp/,AVAILABLE}{./work/nar/extensions/nifi-media-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-image-viewer-1.5.0.war} 2018-03-30 07:04:24,823 INFO [main] o.e.j.a.AnnotationConfiguration Scanning elapsed time=1493ms 2018-03-30 07:04:24,954 INFO [main] o.e.jetty.server.handler.ContextHandler Started o.e.j.w.WebAppContext@6b71e98f{/nifi-jolt-transform-json-ui-1.5.0,file:///opt/nifi/nifi-1.5.0/work/jetty/nifi-jolt-transform-json-ui-1.5.0.war/webapp/,AVAILABLE}{./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-jolt-transform-json-ui-1.5.0.war} 2018-03-30 07:04:27,585 INFO [main] o.e.j.a.AnnotationConfiguration Scanning elapsed time=1944ms 2018-03-30 07:04:27,656 INFO [main] o.e.jetty.server.handler.ContextHandler Started o.e.j.w.WebAppContext@f4d391c{/nifi-update-attribute-ui-1.5.0,file:///opt/nifi/nifi-1.5.0/work/jetty/nifi-update-attribute-ui-1.5.0.war/webapp/,AVAILABLE}{./work/nar/extensions/nifi-update-attribute-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-update-attribute-ui-1.5.0.war} 2018-03-30 07:04:28,423 INFO [main] o.e.j.a.AnnotationConfiguration Scanning elapsed time=644ms 2018-03-30 07:04:28,574 INFO [main] o.e.jetty.server.handler.ContextHandler Started o.e.j.w.WebAppContext@6f4f2cc0{/nifi-standard-content-viewer-1.5.0,file:///opt/nifi/nifi-1.5.0/work/jetty/nifi-standard-content-viewer-1.5.0.war/webapp/,AVAILABLE}{./work/nar/extensions/nifi-standard-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-standard-content-viewer-1.5.0.war} 2018-03-30 07:04:29,225 INFO [main] o.e.j.a.AnnotationConfiguration Scanning elapsed time=127ms 2018-03-30 07:04:29,241 INFO [main] org.eclipse.jetty.ContextHandler./nifi No Spring WebApplicationInitializer types detected on classpath 2018-03-30 07:04:29,377 INFO [main] o.e.jetty.server.handler.ContextHandler Started o.e.j.w.WebAppContext@4f98ac31{/nifi,file:///opt/nifi/nifi-1.5.0/work/jetty/nifi-web-ui-1.5.0.war/webapp/,AVAILABLE}{./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-web-ui-1.5.0.war} 2018-03-30 07:04:29,731 INFO [main] o.e.j.a.AnnotationConfiguration Scanning elapsed time=186ms 2018-03-30 07:04:29,821 INFO [main] o.eclipse.jetty.ContextHandler./nifi-api No Spring WebApplicationInitializer types detected on classpath 2018-03-30 07:04:29,858 INFO [main] o.eclipse.jetty.ContextHandler./nifi-api Initializing Spring root WebApplicationContext 2018-03-30 07:04:35,252 INFO [main] o.a.nifi.properties.NiFiPropertiesLoader Determined default nifi.properties path to be '/opt/nifi/nifi-1.5.0/./conf/nifi.properties' 2018-03-30 07:04:35,253 INFO [main] o.a.nifi.properties.NiFiPropertiesLoader Determined default nifi.properties path to be '/opt/nifi/nifi-1.5.0/./conf/nifi.properties' 2018-03-30 07:04:35,254 INFO [main] o.a.nifi.properties.NiFiPropertiesLoader Loaded 144 properties from /opt/nifi/nifi-1.5.0/./conf/nifi.properties 2018-03-30 07:04:37,213 INFO [main] o.a.n.admin.AuditDataSourceFactoryBean Database not built for repository: jdbc:h2:./database_repository/nifi-flow-audit;AUTOCOMMIT=OFF;DB_CLOSE_ON_EXIT=FALSE;LOCK_MODE=3;LOCK_TIMEOUT=25000;WRITE_DELAY=0;AUTO_SERVER=FALSE. Building now... 2018-03-30 07:04:37,264 INFO [main] o.a.n.r.v.FileBasedVariableRegistry Loaded 83 properties from system properties and environment variables 2018-03-30 07:04:37,264 INFO [main] o.a.n.r.v.FileBasedVariableRegistry Loaded a total of 83 properties. Including precedence overrides effective accessible registry key size is 83 2018-03-30 07:04:37,331 INFO [main] o.a.n.c.r.WriteAheadFlowFileRepository Initialized FlowFile Repository using 256 partitions 2018-03-30 07:04:37,354 INFO [main] o.a.n.p.PersistentProvenanceRepository Recovered 0 records 2018-03-30 07:04:37,374 INFO [main] o.a.n.p.PersistentProvenanceRepository Created new Provenance Event Writers for events starting with ID 0 2018-03-30 07:04:37,380 INFO [main] o.a.n.c.repository.FileSystemRepository Maximum Threshold for Container default set to 113575513292 bytes; if volume exceeds this size, archived data will be deleted until it no longer exceeds this size 2018-03-30 07:04:37,383 INFO [main] o.a.n.c.repository.FileSystemRepository Initializing FileSystemRepository with 'Always Sync' set to false 2018-03-30 07:04:37,506 INFO [main] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 finished recovering records. Performing Checkpoint to ensure proper state of Partitions before updates 2018-03-30 07:04:37,506 INFO [main] org.wali.MinimalLockingWriteAheadLog Successfully recovered 0 records in 1 milliseconds 2018-03-30 07:04:37,539 INFO [main] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 0 Records and 0 Swap Files in 33 milliseconds (Stop-the-world time = 2 milliseconds, Clear Edit Logs time = 2 millis), max Transaction ID -1 2018-03-30 07:04:37,637 INFO [main] o.a.n.w.c.ApplicationStartupContextListener Starting Flow Controller... 2018-03-30 07:04:37,838 INFO [main] o.apache.nifi.controller.FlowController Successfully synchronized controller with proposed flow 2018-03-30 07:04:38,854 INFO [main] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 finished recovering records. Performing Checkpoint to ensure proper state of Partitions before updates 2018-03-30 07:04:38,854 INFO [main] org.wali.MinimalLockingWriteAheadLog Successfully recovered 0 records in 140 milliseconds 2018-03-30 07:04:39,015 INFO [main] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 161 milliseconds (Stop-the-world time = 57 milliseconds, Clear Edit Logs time = 45 millis), max Transaction ID -1 2018-03-30 07:04:39,015 INFO [main] o.a.n.c.r.WriteAheadFlowFileRepository Successfully restored 0 FlowFiles 2018-03-30 07:04:39,149 INFO [main] o.apache.nifi.controller.FlowController Starting 0 processors/ports/funnels 2018-03-30 07:04:39,150 INFO [main] o.apache.nifi.controller.FlowController Started 0 Remote Group Ports transmitting 2018-03-30 07:04:39,150 INFO [main] o.a.n.w.c.ApplicationStartupContextListener Flow Controller started successfully. 2018-03-30 07:04:42,450 INFO [main] o.e.jetty.server.handler.ContextHandler Started o.e.j.w.WebAppContext@74161ed7{/nifi-api,file:///opt/nifi/nifi-1.5.0/work/jetty/nifi-web-api-1.5.0.war/webapp/,AVAILABLE}{./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-web-api-1.5.0.war} 2018-03-30 07:04:43,080 INFO [main] o.e.j.a.AnnotationConfiguration Scanning elapsed time=460ms 2018-03-30 07:04:43,082 INFO [main] o.e.j.C./nifi-content-viewer No Spring WebApplicationInitializer types detected on classpath 2018-03-30 07:04:43,127 INFO [main] o.e.jetty.server.handler.ContextHandler Started o.e.j.w.WebAppContext@147c00c7{/nifi-content-viewer,file:///opt/nifi/nifi-1.5.0/work/jetty/nifi-web-content-viewer-1.5.0.war/webapp/,AVAILABLE}{./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-web-content-viewer-1.5.0.war} 2018-03-30 07:04:43,130 INFO [main] o.e.jetty.server.handler.ContextHandler Started o.e.j.s.h.ContextHandler@b0bd567{/nifi-docs,null,AVAILABLE} 2018-03-30 07:04:43,178 INFO [main] o.e.j.a.AnnotationConfiguration Scanning elapsed time=31ms 2018-03-30 07:04:43,180 INFO [main] o.e.jetty.ContextHandler./nifi-docs No Spring WebApplicationInitializer types detected on classpath 2018-03-30 07:04:43,230 INFO [main] o.e.jetty.server.handler.ContextHandler Started o.e.j.w.WebAppContext@7f8586f9{/nifi-docs,file:///opt/nifi/nifi-1.5.0/work/jetty/nifi-web-docs-1.5.0.war/webapp/,AVAILABLE}{./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-web-docs-1.5.0.war} 2018-03-30 07:04:43,271 INFO [main] o.e.j.a.AnnotationConfiguration Scanning elapsed time=26ms 2018-03-30 07:04:43,273 INFO [main] org.eclipse.jetty.ContextHandler./ No Spring WebApplicationInitializer types detected on classpath 2018-03-30 07:04:43,315 INFO [main] o.e.jetty.server.handler.ContextHandler Started o.e.j.w.WebAppContext@bf2aa3f{/,file:///opt/nifi/nifi-1.5.0/work/jetty/nifi-web-error-1.5.0.war/webapp/,AVAILABLE}{./work/nar/framework/nifi-framework-nar-1.5.0.nar-unpacked/META-INF/bundled-dependencies/nifi-web-error-1.5.0.war} 2018-03-30 07:04:43,354 INFO [main] o.eclipse.jetty.server.AbstractConnector Started ServerConnector@355004c1{HTTP/1.1,[http/1.1]}{b60de6df28f0:8080} 2018-03-30 07:04:43,354 INFO [main] org.eclipse.jetty.server.Server Started @40885ms 2018-03-30 07:04:43,366 INFO [main] org.apache.nifi.web.server.JettyServer NiFi has started. The UI is available at the following URLs: 2018-03-30 07:04:43,366 INFO [main] org.apache.nifi.web.server.JettyServer http://b60de6df28f0:8080/nifi 2018-03-30 07:04:43,368 INFO [main] org.apache.nifi.BootstrapListener Successfully initiated communication with Bootstrap 2018-03-30 07:04:43,368 INFO [main] org.apache.nifi.NiFi Controller initialization took 27625919794 nanoseconds (27 seconds). 2018-03-30 07:05:54,445 INFO [NiFi Web Server-20] o.a.nifi.groups.StandardProcessGroup Template[id=a938c28f-c19c-4a4c-a000-ab1a4409e09c] added to StandardProcessGroup[identifier=75b8f1c7-0162-1000-4308-93c99690958e] 2018-03-30 07:05:54,947 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:05:59,262 INFO [NiFi Web Server-65] o.a.n.c.s.StandardControllerServiceProvider Created Controller Service of type org.apache.nifi.avro.AvroRecordSetWriter with identifier 918908e1-0e32-390d-a182-699264168f8c 2018-03-30 07:05:59,277 INFO [NiFi Web Server-65] o.a.nifi.groups.StandardProcessGroup AvroRecordSetWriter[id=918908e1-0e32-390d-a182-699264168f8c] added to StandardProcessGroup[identifier=75b8f1c7-0162-1000-4308-93c99690958e] 2018-03-30 07:05:59,279 INFO [NiFi Web Server-65] o.a.n.c.s.StandardControllerServiceProvider Created Controller Service of type org.apache.nifi.confluent.schemaregistry.ConfluentSchemaRegistry with identifier 934bbbd6-f194-364b-c9d5-d4c0262c733f 2018-03-30 07:05:59,281 INFO [NiFi Web Server-65] o.a.nifi.groups.StandardProcessGroup ConfluentSchemaRegistry[id=934bbbd6-f194-364b-c9d5-d4c0262c733f] added to StandardProcessGroup[identifier=75b8f1c7-0162-1000-4308-93c99690958e] 2018-03-30 07:05:59,283 INFO [NiFi Web Server-65] o.a.n.c.s.StandardControllerServiceProvider Created Controller Service of type org.apache.nifi.csv.CSVReader with identifier 73da6c9f-035a-335e-df87-c815acfeae72 2018-03-30 07:05:59,284 INFO [NiFi Web Server-65] o.a.nifi.groups.StandardProcessGroup CSVReader[id=73da6c9f-035a-335e-df87-c815acfeae72] added to StandardProcessGroup[identifier=75b8f1c7-0162-1000-4308-93c99690958e] 2018-03-30 07:05:59,671 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:06:06,428 INFO [NiFi Web Server-21] o.a.nifi.groups.StandardProcessGroup Connection[Source ID=a3b8e207-ba68-3793-1042-a85ac3a55c5e,Dest ID=3d2c2fe3-e8fa-3a83-548e-7b409a11e708] removed from flow 2018-03-30 07:06:06,863 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:06:07,723 INFO [NiFi Web Server-23] o.a.nifi.groups.StandardProcessGroup PublishKafkaRecord_0_10[id=3d2c2fe3-e8fa-3a83-548e-7b409a11e708] removed from flow 2018-03-30 07:06:08,068 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:06:09,765 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:06:12,498 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:06:13,688 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:06:37,558 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 1 Records and 0 Swap Files in 17 milliseconds (Stop-the-world time = 3 milliseconds, Clear Edit Logs time = 3 millis), max Transaction ID 2 2018-03-30 07:06:39,017 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:06:39,091 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 74 milliseconds (Stop-the-world time = 46 milliseconds, Clear Edit Logs time = 19 millis), max Transaction ID -1 2018-03-30 07:06:39,091 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 74 milliseconds 2018-03-30 07:06:52,452 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:06:54,609 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:06:56,794 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:06:57,662 INFO [NiFi Web Server-66] o.a.nifi.groups.StandardProcessGroup Connection[Source ID=8a32c0b7-485e-37da-a97b-09437b17b08b,Dest ID=22b8f3a8-32cc-39f2-372e-206a2dd31f64] removed from flow 2018-03-30 07:06:57,962 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:06:59,610 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:07:02,348 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:07:05,032 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:07:08,695 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:07:12,341 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:07:18,478 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:08:37,570 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 1 Records and 0 Swap Files in 11 milliseconds (Stop-the-world time = 2 milliseconds, Clear Edit Logs time = 2 millis), max Transaction ID 2 2018-03-30 07:08:38,647 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:08:39,091 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:08:39,161 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 69 milliseconds (Stop-the-world time = 24 milliseconds, Clear Edit Logs time = 36 millis), max Transaction ID -1 2018-03-30 07:08:39,161 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 69 milliseconds 2018-03-30 07:08:40,795 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:09:06,455 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:10:26,884 INFO [NiFi Web Server-79] o.a.n.c.s.StandardControllerServiceProvider Created Controller Service of type org.apache.nifi.schemaregistry.services.AvroSchemaRegistry with identifier 75be4632-0162-1000-82d1-c9569280e592 2018-03-30 07:10:26,888 INFO [NiFi Web Server-79] o.a.nifi.groups.StandardProcessGroup AvroSchemaRegistry[id=75be4632-0162-1000-82d1-c9569280e592] added to StandardProcessGroup[identifier=75b8f1c7-0162-1000-4308-93c99690958e] 2018-03-30 07:10:27,149 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:10:30,315 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:10:33,618 INFO [NiFi Web Server-81] o.a.nifi.groups.StandardProcessGroup ConfluentSchemaRegistry[id=934bbbd6-f194-364b-c9d5-d4c0262c733f] removed from StandardProcessGroup[identifier=75b8f1c7-0162-1000-4308-93c99690958e] 2018-03-30 07:10:33,969 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:10:37,578 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 2 Records and 0 Swap Files in 8 milliseconds (Stop-the-world time = 1 milliseconds, Clear Edit Logs time = 1 millis), max Transaction ID 5 2018-03-30 07:10:39,162 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:10:39,238 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 75 milliseconds (Stop-the-world time = 43 milliseconds, Clear Edit Logs time = 22 millis), max Transaction ID -1 2018-03-30 07:10:39,238 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 75 milliseconds 2018-03-30 07:12:37,589 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 2 Records and 0 Swap Files in 10 milliseconds (Stop-the-world time = 2 milliseconds, Clear Edit Logs time = 2 millis), max Transaction ID 5 2018-03-30 07:12:39,238 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:12:39,290 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 51 milliseconds (Stop-the-world time = 25 milliseconds, Clear Edit Logs time = 18 millis), max Transaction ID -1 2018-03-30 07:12:39,290 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 51 milliseconds 2018-03-30 07:13:26,774 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:14:14,963 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:14:22,711 INFO [NiFi Web Server-79] o.a.nifi.groups.StandardProcessGroup AvroRecordSetWriter[id=918908e1-0e32-390d-a182-699264168f8c] removed from StandardProcessGroup[identifier=75b8f1c7-0162-1000-4308-93c99690958e] 2018-03-30 07:14:23,114 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:14:28,057 INFO [NiFi Web Server-78] o.a.n.c.s.StandardControllerServiceProvider Created Controller Service of type org.apache.nifi.json.JsonRecordSetWriter with identifier 75c1f455-0162-1000-a794-f275b7c53b07 2018-03-30 07:14:28,060 INFO [NiFi Web Server-78] o.a.nifi.groups.StandardProcessGroup JsonRecordSetWriter[id=75c1f455-0162-1000-a794-f275b7c53b07] added to StandardProcessGroup[identifier=75b8f1c7-0162-1000-4308-93c99690958e] 2018-03-30 07:14:28,246 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:14:37,597 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 3 Records and 0 Swap Files in 7 milliseconds (Stop-the-world time = 1 milliseconds, Clear Edit Logs time = 2 millis), max Transaction ID 8 2018-03-30 07:14:39,290 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:14:39,360 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 69 milliseconds (Stop-the-world time = 41 milliseconds, Clear Edit Logs time = 19 millis), max Transaction ID -1 2018-03-30 07:14:39,360 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 69 milliseconds 2018-03-30 07:14:45,222 INFO [NiFi Web Server-82] o.a.n.c.s.StandardProcessScheduler Enabling AvroSchemaRegistry[id=75be4632-0162-1000-82d1-c9569280e592] 2018-03-30 07:14:45,426 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:16:37,605 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 3 Records and 0 Swap Files in 8 milliseconds (Stop-the-world time = 1 milliseconds, Clear Edit Logs time = 1 millis), max Transaction ID 8 2018-03-30 07:16:39,360 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:16:39,429 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 68 milliseconds (Stop-the-world time = 41 milliseconds, Clear Edit Logs time = 17 millis), max Transaction ID -1 2018-03-30 07:16:39,429 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 68 milliseconds 2018-03-30 07:17:07,602 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:17:10,145 INFO [NiFi Web Server-82] o.a.n.c.s.StandardProcessScheduler Enabling CSVReader[id=73da6c9f-035a-335e-df87-c815acfeae72] 2018-03-30 07:17:10,750 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:17:15,494 INFO [NiFi Web Server-82] o.a.n.c.s.StandardProcessScheduler Enabling JsonRecordSetWriter[id=75c1f455-0162-1000-a794-f275b7c53b07] 2018-03-30 07:17:15,882 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:17:35,013 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:18:37,613 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 3 Records and 0 Swap Files in 7 milliseconds (Stop-the-world time = 1 milliseconds, Clear Edit Logs time = 1 millis), max Transaction ID 8 2018-03-30 07:18:39,429 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:18:39,497 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 67 milliseconds (Stop-the-world time = 42 milliseconds, Clear Edit Logs time = 17 millis), max Transaction ID -1 2018-03-30 07:18:39,497 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 67 milliseconds 2018-03-30 07:20:37,623 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 3 Records and 0 Swap Files in 9 milliseconds (Stop-the-world time = 1 milliseconds, Clear Edit Logs time = 2 millis), max Transaction ID 8 2018-03-30 07:20:39,497 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:20:39,567 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 68 milliseconds (Stop-the-world time = 43 milliseconds, Clear Edit Logs time = 17 millis), max Transaction ID -1 2018-03-30 07:20:39,567 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 68 milliseconds 2018-03-30 07:22:37,631 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 3 Records and 0 Swap Files in 7 milliseconds (Stop-the-world time = 1 milliseconds, Clear Edit Logs time = 1 millis), max Transaction ID 8 2018-03-30 07:22:39,567 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:22:39,635 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 68 milliseconds (Stop-the-world time = 38 milliseconds, Clear Edit Logs time = 21 millis), max Transaction ID -1 2018-03-30 07:22:39,636 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 68 milliseconds 2018-03-30 07:24:37,641 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 3 Records and 0 Swap Files in 9 milliseconds (Stop-the-world time = 2 milliseconds, Clear Edit Logs time = 1 millis), max Transaction ID 8 2018-03-30 07:24:39,636 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:24:39,691 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 54 milliseconds (Stop-the-world time = 22 milliseconds, Clear Edit Logs time = 24 millis), max Transaction ID -1 2018-03-30 07:24:39,691 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 55 milliseconds 2018-03-30 07:25:34,910 INFO [NiFi Web Server-84] o.a.n.c.s.StandardProcessScheduler Starting GenerateFlowFile[id=9b51d55e-84c0-330c-1e4e-09554aac25f9] 2018-03-30 07:25:34,946 INFO [StandardProcessScheduler Thread-1] o.a.n.c.s.TimerDrivenSchedulingAgent Scheduled GenerateFlowFile[id=9b51d55e-84c0-330c-1e4e-09554aac25f9] to run with 1 threads 2018-03-30 07:25:35,278 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:25:37,407 INFO [Provenance Maintenance Thread-3] o.a.n.p.PersistentProvenanceRepository Created new Provenance Event Writers for events starting with ID 1 2018-03-30 07:25:37,681 INFO [Provenance Repository Rollover Thread-1] o.a.n.p.lucene.SimpleIndexManager Index Writer for ./provenance_repository/index-1522394737000 has been returned to Index Manager and is no longer in use. Closing Index Writer 2018-03-30 07:25:37,683 INFO [Provenance Repository Rollover Thread-1] o.a.n.p.PersistentProvenanceRepository Successfully merged 16 journal files (1 records) into single Provenance Log File ./provenance_repository/0.prov in 270 milliseconds 2018-03-30 07:25:37,684 INFO [Provenance Repository Rollover Thread-1] o.a.n.p.PersistentProvenanceRepository Successfully Rolled over Provenance Event file containing 1 records. In the past 5 minutes, 1 events have been written to the Provenance Repository, totaling 312 bytes 2018-03-30 07:25:40,895 INFO [NiFi Web Server-96] o.a.n.c.s.StandardProcessScheduler Starting UpdateAttribute[id=75baff16-0162-1000-c164-aee99357f494] 2018-03-30 07:25:40,896 INFO [StandardProcessScheduler Thread-2] o.a.n.c.s.TimerDrivenSchedulingAgent Scheduled UpdateAttribute[id=75baff16-0162-1000-c164-aee99357f494] to run with 1 threads 2018-03-30 07:25:41,429 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:25:51,549 INFO [NiFi Web Server-87] o.a.n.c.s.StandardProcessScheduler Stopping UpdateAttribute[id=75baff16-0162-1000-c164-aee99357f494] 2018-03-30 07:25:51,549 INFO [NiFi Web Server-87] o.a.n.controller.StandardProcessorNode Stopping processor: class org.apache.nifi.processors.attributes.UpdateAttribute 2018-03-30 07:25:51,550 INFO [StandardProcessScheduler Thread-3] o.a.n.c.s.TimerDrivenSchedulingAgent Stopped scheduling UpdateAttribute[id=75baff16-0162-1000-c164-aee99357f494] to run 2018-03-30 07:25:51,551 INFO [NiFi Web Server-87] o.a.n.c.s.StandardProcessScheduler Stopping GenerateFlowFile[id=9b51d55e-84c0-330c-1e4e-09554aac25f9] 2018-03-30 07:25:51,551 INFO [NiFi Web Server-87] o.a.n.controller.StandardProcessorNode Stopping processor: class org.apache.nifi.processors.standard.GenerateFlowFile 2018-03-30 07:25:51,552 INFO [StandardProcessScheduler Thread-6] o.a.n.c.s.TimerDrivenSchedulingAgent Stopped scheduling GenerateFlowFile[id=9b51d55e-84c0-330c-1e4e-09554aac25f9] to run 2018-03-30 07:25:52,114 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:25:59,530 INFO [NiFi Web Server-96] o.a.n.controller.StandardFlowFileQueue Canceling ListFlowFile Request with ID 75cc7d33-0162-1000-7996-69d0d1d95e7d 2018-03-30 07:26:07,417 INFO [Provenance Maintenance Thread-3] o.a.n.p.PersistentProvenanceRepository Created new Provenance Event Writers for events starting with ID 5 2018-03-30 07:26:07,504 INFO [Provenance Repository Rollover Thread-1] o.a.n.p.lucene.SimpleIndexManager Index Writer for ./provenance_repository/index-1522394737000 has been returned to Index Manager and is no longer in use. Closing Index Writer 2018-03-30 07:26:07,505 INFO [Provenance Repository Rollover Thread-1] o.a.n.p.PersistentProvenanceRepository Successfully merged 16 journal files (4 records) into single Provenance Log File ./provenance_repository/1.prov in 96 milliseconds 2018-03-30 07:26:07,505 INFO [Provenance Repository Rollover Thread-1] o.a.n.p.PersistentProvenanceRepository Successfully Rolled over Provenance Event file containing 4 records. In the past 5 minutes, 5 events have been written to the Provenance Repository, totaling 2.15 KB 2018-03-30 07:26:21,966 INFO [NiFi Web Server-94] o.a.n.c.s.StandardProcessScheduler Starting PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] 2018-03-30 07:26:21,970 INFO [StandardProcessScheduler Thread-4] o.a.n.c.s.TimerDrivenSchedulingAgent Scheduled PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] to run with 1 threads 2018-03-30 07:26:22,021 INFO [Timer-Driven Process Thread-9] o.a.k.clients.producer.ProducerConfig ProducerConfig values: acks = 0 batch.size = 16384 bootstrap.servers = [kafka:29092] buffer.memory = 33554432 client.id = compression.type = none connections.max.idle.ms = 540000 enable.idempotence = false interceptor.classes = null key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 5000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 0 retry.backoff.ms = 100 sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer 2018-03-30 07:26:22,145 INFO [Timer-Driven Process Thread-9] o.a.kafka.common.utils.AppInfoParser Kafka version : 1.0.0 2018-03-30 07:26:22,146 INFO [Timer-Driven Process Thread-9] o.a.kafka.common.utils.AppInfoParser Kafka commitId : aaa7af6d4a11b29d 2018-03-30 07:26:22,182 ERROR [Timer-Driven Process Thread-9] o.a.n.p.k.pubsub.PublishKafkaRecord_1_0 PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] Failed to send StandardFlowFileRecord[uuid=71650caa-1b60-4e29-b1a3-e219251edfdb,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1522394734968-1, container=default, section=1], offset=0, length=525],offset=0,name=3132422897807,size=525] to Kafka: org.apache.nifi.serialization.record.util.IllegalTypeConversionException: Cannot convert value [36531253] of type class java.lang.String to Object Array for field session_number org.apache.nifi.serialization.record.util.IllegalTypeConversionException: Cannot convert value [36531253] of type class java.lang.String to Object Array for field session_number at org.apache.nifi.serialization.record.util.DataTypeUtils.toArray(DataTypeUtils.java:270) at org.apache.nifi.serialization.record.util.DataTypeUtils.convertType(DataTypeUtils.java:136) at org.apache.nifi.csv.CSVRecordReader.convert(CSVRecordReader.java:177) at org.apache.nifi.csv.CSVRecordReader.nextRecord(CSVRecordReader.java:117) at org.apache.nifi.serialization.RecordReader.nextRecord(RecordReader.java:50) at org.apache.nifi.serialization.RecordReader$1.next(RecordReader.java:96) at org.apache.nifi.processors.kafka.pubsub.PublisherLease.publish(PublisherLease.java:162) at org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0$1.process(PublishKafkaRecord_1_0.java:411) at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2175) at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2145) at org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0.onTrigger(PublishKafkaRecord_1_0.java:403) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1122) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:147) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:128) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 2018-03-30 07:26:22,185 ERROR [Timer-Driven Process Thread-9] o.a.n.p.k.pubsub.PublishKafkaRecord_1_0 PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] Failed to send StandardFlowFileRecord[uuid=71650caa-1b60-4e29-b1a3-e219251edfdb,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1522394734968-1, container=default, section=1], offset=0, length=525],offset=0,name=3132422897807,size=525] to Kafka: org.apache.nifi.serialization.record.util.IllegalTypeConversionException: Cannot convert value [36531253] of type class java.lang.String to Object Array for field session_number org.apache.nifi.serialization.record.util.IllegalTypeConversionException: Cannot convert value [36531253] of type class java.lang.String to Object Array for field session_number at org.apache.nifi.serialization.record.util.DataTypeUtils.toArray(DataTypeUtils.java:270) at org.apache.nifi.serialization.record.util.DataTypeUtils.convertType(DataTypeUtils.java:136) at org.apache.nifi.csv.CSVRecordReader.convert(CSVRecordReader.java:177) at org.apache.nifi.csv.CSVRecordReader.nextRecord(CSVRecordReader.java:117) at org.apache.nifi.serialization.RecordReader.nextRecord(RecordReader.java:50) at org.apache.nifi.serialization.RecordReader$1.next(RecordReader.java:96) at org.apache.nifi.processors.kafka.pubsub.PublisherLease.publish(PublisherLease.java:162) at org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0$1.process(PublishKafkaRecord_1_0.java:411) at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2175) at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2145) at org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0.onTrigger(PublishKafkaRecord_1_0.java:403) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1122) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:147) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:128) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 2018-03-30 07:26:22,186 ERROR [Timer-Driven Process Thread-9] o.a.n.p.k.pubsub.PublishKafkaRecord_1_0 PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] Failed to send StandardFlowFileRecord[uuid=4e0059d4-4bb1-40ab-9f05-31e79f8d05fa,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1522394734968-1, container=default, section=1], offset=525, length=525],offset=0,name=3142469592957,size=525] to Kafka: org.apache.nifi.serialization.record.util.IllegalTypeConversionException: Cannot convert value [36531253] of type class java.lang.String to Object Array for field session_number org.apache.nifi.serialization.record.util.IllegalTypeConversionException: Cannot convert value [36531253] of type class java.lang.String to Object Array for field session_number at org.apache.nifi.serialization.record.util.DataTypeUtils.toArray(DataTypeUtils.java:270) at org.apache.nifi.serialization.record.util.DataTypeUtils.convertType(DataTypeUtils.java:136) at org.apache.nifi.csv.CSVRecordReader.convert(CSVRecordReader.java:177) at org.apache.nifi.csv.CSVRecordReader.nextRecord(CSVRecordReader.java:117) at org.apache.nifi.serialization.RecordReader.nextRecord(RecordReader.java:50) at org.apache.nifi.serialization.RecordReader$1.next(RecordReader.java:96) at org.apache.nifi.processors.kafka.pubsub.PublisherLease.publish(PublisherLease.java:162) at org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0$1.process(PublishKafkaRecord_1_0.java:411) at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2175) at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2145) at org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0.onTrigger(PublishKafkaRecord_1_0.java:403) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1122) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:147) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:128) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 2018-03-30 07:26:22,186 ERROR [Timer-Driven Process Thread-9] o.a.n.p.k.pubsub.PublishKafkaRecord_1_0 PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] Failed to send StandardFlowFileRecord[uuid=4e0059d4-4bb1-40ab-9f05-31e79f8d05fa,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1522394734968-1, container=default, section=1], offset=525, length=525],offset=0,name=3142469592957,size=525] to Kafka: org.apache.nifi.serialization.record.util.IllegalTypeConversionException: Cannot convert value [36531253] of type class java.lang.String to Object Array for field session_number org.apache.nifi.serialization.record.util.IllegalTypeConversionException: Cannot convert value [36531253] of type class java.lang.String to Object Array for field session_number at org.apache.nifi.serialization.record.util.DataTypeUtils.toArray(DataTypeUtils.java:270) at org.apache.nifi.serialization.record.util.DataTypeUtils.convertType(DataTypeUtils.java:136) at org.apache.nifi.csv.CSVRecordReader.convert(CSVRecordReader.java:177) at org.apache.nifi.csv.CSVRecordReader.nextRecord(CSVRecordReader.java:117) at org.apache.nifi.serialization.RecordReader.nextRecord(RecordReader.java:50) at org.apache.nifi.serialization.RecordReader$1.next(RecordReader.java:96) at org.apache.nifi.processors.kafka.pubsub.PublisherLease.publish(PublisherLease.java:162) at org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0$1.process(PublishKafkaRecord_1_0.java:411) at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2175) at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2145) at org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0.onTrigger(PublishKafkaRecord_1_0.java:403) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1122) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:147) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:128) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 2018-03-30 07:26:22,189 INFO [Timer-Driven Process Thread-9] o.a.kafka.clients.producer.KafkaProducer [Producer clientId=producer-1] Closing the Kafka producer with timeoutMillis = 5000 ms. 2018-03-30 07:26:22,277 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:26:26,345 INFO [NiFi Web Server-103] o.a.n.c.s.StandardProcessScheduler Stopping PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] 2018-03-30 07:26:26,346 INFO [NiFi Web Server-103] o.a.n.controller.StandardProcessorNode Stopping processor: class org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0 2018-03-30 07:26:26,347 INFO [StandardProcessScheduler Thread-2] o.a.n.c.s.TimerDrivenSchedulingAgent Stopped scheduling PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] to run 2018-03-30 07:26:26,929 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:26:37,649 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 3 Records and 0 Swap Files in 7 milliseconds (Stop-the-world time = 1 milliseconds, Clear Edit Logs time = 1 millis), max Transaction ID 8 2018-03-30 07:26:39,691 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:26:39,748 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 56 milliseconds (Stop-the-world time = 34 milliseconds, Clear Edit Logs time = 17 millis), max Transaction ID 4 2018-03-30 07:26:39,748 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 57 milliseconds 2018-03-30 07:26:47,433 INFO [Provenance Maintenance Thread-2] o.a.n.p.PersistentProvenanceRepository Created new Provenance Event Writers for events starting with ID 7 2018-03-30 07:26:47,496 INFO [Provenance Repository Rollover Thread-2] o.a.n.p.lucene.SimpleIndexManager Index Writer for ./provenance_repository/index-1522394737000 has been returned to Index Manager and is no longer in use. Closing Index Writer 2018-03-30 07:26:47,498 INFO [Provenance Repository Rollover Thread-2] o.a.n.p.PersistentProvenanceRepository Successfully merged 16 journal files (2 records) into single Provenance Log File ./provenance_repository/5.prov in 68 milliseconds 2018-03-30 07:26:47,499 INFO [Provenance Repository Rollover Thread-2] o.a.n.p.PersistentProvenanceRepository Successfully Rolled over Provenance Event file containing 1 records. In the past 5 minutes, 7 events have been written to the Provenance Repository, totaling 3.05 KB 2018-03-30 07:28:37,657 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 3 Records and 0 Swap Files in 7 milliseconds (Stop-the-world time = 1 milliseconds, Clear Edit Logs time = 1 millis), max Transaction ID 8 2018-03-30 07:28:39,748 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:28:39,797 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 48 milliseconds (Stop-the-world time = 22 milliseconds, Clear Edit Logs time = 17 millis), max Transaction ID 4 2018-03-30 07:28:39,798 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 49 milliseconds 2018-03-30 07:30:37,664 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 3 Records and 0 Swap Files in 7 milliseconds (Stop-the-world time = 1 milliseconds, Clear Edit Logs time = 1 millis), max Transaction ID 8 2018-03-30 07:30:39,798 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:30:39,846 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 48 milliseconds (Stop-the-world time = 21 milliseconds, Clear Edit Logs time = 17 millis), max Transaction ID 4 2018-03-30 07:30:39,846 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 48 milliseconds 2018-03-30 07:32:37,675 INFO [Write-Ahead Local State Provider Maintenance] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@14927cd4 checkpointed with 3 Records and 0 Swap Files in 10 milliseconds (Stop-the-world time = 2 milliseconds, Clear Edit Logs time = 2 millis), max Transaction ID 8 2018-03-30 07:32:39,846 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository 2018-03-30 07:32:39,918 INFO [pool-10-thread-1] org.wali.MinimalLockingWriteAheadLog org.wali.MinimalLockingWriteAheadLog@66694050 checkpointed with 0 Records and 0 Swap Files in 71 milliseconds (Stop-the-world time = 36 milliseconds, Clear Edit Logs time = 24 millis), max Transaction ID 4 2018-03-30 07:32:39,918 INFO [pool-10-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 0 records in 71 milliseconds 2018-03-30 07:33:53,439 INFO [NiFi Web Server-84] o.a.n.c.s.StandardProcessScheduler Starting GenerateFlowFile[id=9b51d55e-84c0-330c-1e4e-09554aac25f9] 2018-03-30 07:33:53,444 INFO [StandardProcessScheduler Thread-5] o.a.n.c.s.TimerDrivenSchedulingAgent Scheduled GenerateFlowFile[id=9b51d55e-84c0-330c-1e4e-09554aac25f9] to run with 1 threads 2018-03-30 07:33:53,680 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:33:57,445 INFO [Provenance Maintenance Thread-3] o.a.n.p.PersistentProvenanceRepository Created new Provenance Event Writers for events starting with ID 8 2018-03-30 07:33:57,482 INFO [Provenance Repository Rollover Thread-1] o.a.n.p.lucene.SimpleIndexManager Index Writer for ./provenance_repository/index-1522394737000 has been returned to Index Manager and is no longer in use. Closing Index Writer 2018-03-30 07:33:57,483 INFO [Provenance Repository Rollover Thread-1] o.a.n.p.PersistentProvenanceRepository Successfully merged 16 journal files (1 records) into single Provenance Log File ./provenance_repository/7.prov in 40 milliseconds 2018-03-30 07:33:57,483 INFO [Provenance Repository Rollover Thread-1] o.a.n.p.PersistentProvenanceRepository Successfully Rolled over Provenance Event file containing 1 records. In the past 5 minutes, 1 events have been written to the Provenance Repository, totaling 312 bytes 2018-03-30 07:34:02,274 INFO [NiFi Web Server-93] o.a.n.c.s.StandardProcessScheduler Stopping GenerateFlowFile[id=9b51d55e-84c0-330c-1e4e-09554aac25f9] 2018-03-30 07:34:02,274 INFO [NiFi Web Server-93] o.a.n.controller.StandardProcessorNode Stopping processor: class org.apache.nifi.processors.standard.GenerateFlowFile 2018-03-30 07:34:02,274 INFO [StandardProcessScheduler Thread-3] o.a.n.c.s.TimerDrivenSchedulingAgent Stopped scheduling GenerateFlowFile[id=9b51d55e-84c0-330c-1e4e-09554aac25f9] to run 2018-03-30 07:34:02,822 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:34:03,949 INFO [NiFi Web Server-84] o.a.n.c.s.StandardProcessScheduler Starting UpdateAttribute[id=75baff16-0162-1000-c164-aee99357f494] 2018-03-30 07:34:03,952 INFO [StandardProcessScheduler Thread-1] o.a.n.c.s.TimerDrivenSchedulingAgent Scheduled UpdateAttribute[id=75baff16-0162-1000-c164-aee99357f494] to run with 1 threads 2018-03-30 07:34:04,465 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:34:06,378 INFO [NiFi Web Server-119] o.a.n.c.s.StandardProcessScheduler Starting PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] 2018-03-30 07:34:06,386 INFO [StandardProcessScheduler Thread-7] o.a.n.c.s.TimerDrivenSchedulingAgent Scheduled PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] to run with 1 threads 2018-03-30 07:34:06,391 INFO [Timer-Driven Process Thread-1] o.a.k.clients.producer.ProducerConfig ProducerConfig values: acks = 0 batch.size = 16384 bootstrap.servers = [kafka:29092] buffer.memory = 33554432 client.id = compression.type = none connections.max.idle.ms = 540000 enable.idempotence = false interceptor.classes = null key.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer linger.ms = 0 max.block.ms = 5000 max.in.flight.requests.per.connection = 5 max.request.size = 1048576 metadata.max.age.ms = 300000 metric.reporters = [] metrics.num.samples = 2 metrics.recording.level = INFO metrics.sample.window.ms = 30000 partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner receive.buffer.bytes = 32768 reconnect.backoff.max.ms = 1000 reconnect.backoff.ms = 50 request.timeout.ms = 30000 retries = 0 retry.backoff.ms = 100 sasl.jaas.config = null sasl.kerberos.kinit.cmd = /usr/bin/kinit sasl.kerberos.min.time.before.relogin = 60000 sasl.kerberos.service.name = null sasl.kerberos.ticket.renew.jitter = 0.05 sasl.kerberos.ticket.renew.window.factor = 0.8 sasl.mechanism = GSSAPI security.protocol = PLAINTEXT send.buffer.bytes = 131072 ssl.cipher.suites = null ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1] ssl.endpoint.identification.algorithm = null ssl.key.password = null ssl.keymanager.algorithm = SunX509 ssl.keystore.location = null ssl.keystore.password = null ssl.keystore.type = JKS ssl.protocol = TLS ssl.provider = null ssl.secure.random.implementation = null ssl.trustmanager.algorithm = PKIX ssl.truststore.location = null ssl.truststore.password = null ssl.truststore.type = JKS transaction.timeout.ms = 60000 transactional.id = null value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer 2018-03-30 07:34:06,399 INFO [Timer-Driven Process Thread-1] o.a.kafka.common.utils.AppInfoParser Kafka version : 1.0.0 2018-03-30 07:34:06,400 INFO [Timer-Driven Process Thread-1] o.a.kafka.common.utils.AppInfoParser Kafka commitId : aaa7af6d4a11b29d 2018-03-30 07:34:06,403 ERROR [Timer-Driven Process Thread-1] o.a.n.p.k.pubsub.PublishKafkaRecord_1_0 PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] Failed to send StandardFlowFileRecord[uuid=26306f03-9659-42b3-bbfd-97d19ee1b9b8,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1522394734968-1, container=default, section=1], offset=1050, length=525],offset=0,name=3630905036922,size=525] to Kafka: org.apache.nifi.serialization.record.util.IllegalTypeConversionException: Cannot convert value [36531253] of type class java.lang.String to Object Array for field session_number org.apache.nifi.serialization.record.util.IllegalTypeConversionException: Cannot convert value [36531253] of type class java.lang.String to Object Array for field session_number at org.apache.nifi.serialization.record.util.DataTypeUtils.toArray(DataTypeUtils.java:270) at org.apache.nifi.serialization.record.util.DataTypeUtils.convertType(DataTypeUtils.java:136) at org.apache.nifi.csv.CSVRecordReader.convert(CSVRecordReader.java:177) at org.apache.nifi.csv.CSVRecordReader.nextRecord(CSVRecordReader.java:117) at org.apache.nifi.serialization.RecordReader.nextRecord(RecordReader.java:50) at org.apache.nifi.serialization.RecordReader$1.next(RecordReader.java:96) at org.apache.nifi.processors.kafka.pubsub.PublisherLease.publish(PublisherLease.java:162) at org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0$1.process(PublishKafkaRecord_1_0.java:411) at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2175) at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2145) at org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0.onTrigger(PublishKafkaRecord_1_0.java:403) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1122) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:147) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:128) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 2018-03-30 07:34:06,403 ERROR [Timer-Driven Process Thread-1] o.a.n.p.k.pubsub.PublishKafkaRecord_1_0 PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] Failed to send StandardFlowFileRecord[uuid=26306f03-9659-42b3-bbfd-97d19ee1b9b8,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1522394734968-1, container=default, section=1], offset=1050, length=525],offset=0,name=3630905036922,size=525] to Kafka: org.apache.nifi.serialization.record.util.IllegalTypeConversionException: Cannot convert value [36531253] of type class java.lang.String to Object Array for field session_number org.apache.nifi.serialization.record.util.IllegalTypeConversionException: Cannot convert value [36531253] of type class java.lang.String to Object Array for field session_number at org.apache.nifi.serialization.record.util.DataTypeUtils.toArray(DataTypeUtils.java:270) at org.apache.nifi.serialization.record.util.DataTypeUtils.convertType(DataTypeUtils.java:136) at org.apache.nifi.csv.CSVRecordReader.convert(CSVRecordReader.java:177) at org.apache.nifi.csv.CSVRecordReader.nextRecord(CSVRecordReader.java:117) at org.apache.nifi.serialization.RecordReader.nextRecord(RecordReader.java:50) at org.apache.nifi.serialization.RecordReader$1.next(RecordReader.java:96) at org.apache.nifi.processors.kafka.pubsub.PublisherLease.publish(PublisherLease.java:162) at org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0$1.process(PublishKafkaRecord_1_0.java:411) at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2175) at org.apache.nifi.controller.repository.StandardProcessSession.read(StandardProcessSession.java:2145) at org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0.onTrigger(PublishKafkaRecord_1_0.java:403) at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1122) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:147) at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47) at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:128) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) 2018-03-30 07:34:06,404 INFO [Timer-Driven Process Thread-1] o.a.kafka.clients.producer.KafkaProducer [Producer clientId=producer-2] Closing the Kafka producer with timeoutMillis = 5000 ms. 2018-03-30 07:34:06,629 INFO [Flow Service Tasks Thread-1] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false 2018-03-30 07:34:11,256 INFO [NiFi Web Server-125] o.a.n.c.s.StandardProcessScheduler Stopping UpdateAttribute[id=75baff16-0162-1000-c164-aee99357f494] 2018-03-30 07:34:11,256 INFO [NiFi Web Server-125] o.a.n.controller.StandardProcessorNode Stopping processor: class org.apache.nifi.processors.attributes.UpdateAttribute 2018-03-30 07:34:11,257 INFO [StandardProcessScheduler Thread-6] o.a.n.c.s.TimerDrivenSchedulingAgent Stopped scheduling UpdateAttribute[id=75baff16-0162-1000-c164-aee99357f494] to run 2018-03-30 07:34:11,257 INFO [NiFi Web Server-125] o.a.n.c.s.StandardProcessScheduler Stopping PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] 2018-03-30 07:34:11,257 INFO [NiFi Web Server-125] o.a.n.controller.StandardProcessorNode Stopping processor: class org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_1_0 2018-03-30 07:34:11,258 INFO [StandardProcessScheduler Thread-4] o.a.n.c.s.TimerDrivenSchedulingAgent Stopped scheduling PublishKafkaRecord_1_0[id=22b8f3a8-32cc-39f2-372e-206a2dd31f64] to run 2018-03-30 07:34:11,762 INFO [Flow Service Tasks Thread-2] o.a.nifi.controller.StandardFlowService Saved flow controller org.apache.nifi.controller.FlowController@20fc70aa // Another save pending = false