Created
September 25, 2017 21:58
-
-
Save bbende/fa2bff34e721fef21453986336664cb2 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?xml version="1.0" ?> | |
<template encoding-version="1.1"> | |
<description></description> | |
<groupId>189258d5-015d-1000-c182-3a88f8e41fb5</groupId> | |
<name>Multi-Line Log Processing</name> | |
<snippet> | |
<connections> | |
<id>b121feac-1134-391d-0000-000000000000</id> | |
<parentGroupId>be1a51ae-b5cb-32d9-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>be1a51ae-b5cb-32d9-0000-000000000000</groupId> | |
<id>010bb671-5579-3954-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>failure</selectedRelationships> | |
<source> | |
<groupId>be1a51ae-b5cb-32d9-0000-000000000000</groupId> | |
<id>1d56ccfd-fcad-39b3-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>36c1af75-61a7-3542-0000-000000000000</id> | |
<parentGroupId>be1a51ae-b5cb-32d9-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>be1a51ae-b5cb-32d9-0000-000000000000</groupId> | |
<id>fb0015f7-a6ee-3edf-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>be1a51ae-b5cb-32d9-0000-000000000000</groupId> | |
<id>0a501edd-28a2-3a04-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<connections> | |
<id>4b9fcd23-7695-3285-0000-000000000000</id> | |
<parentGroupId>be1a51ae-b5cb-32d9-0000-000000000000</parentGroupId> | |
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> | |
<backPressureObjectThreshold>10000</backPressureObjectThreshold> | |
<destination> | |
<groupId>be1a51ae-b5cb-32d9-0000-000000000000</groupId> | |
<id>1d56ccfd-fcad-39b3-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</destination> | |
<flowFileExpiration>0 sec</flowFileExpiration> | |
<labelIndex>1</labelIndex> | |
<name></name> | |
<selectedRelationships>success</selectedRelationships> | |
<source> | |
<groupId>be1a51ae-b5cb-32d9-0000-000000000000</groupId> | |
<id>569daa4b-b872-3d8b-0000-000000000000</id> | |
<type>PROCESSOR</type> | |
</source> | |
<zIndex>0</zIndex> | |
</connections> | |
<controllerServices> | |
<id>a1813f12-8138-3482-0000-000000000000</id> | |
<parentGroupId>be1a51ae-b5cb-32d9-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-registry-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.4.0-SNAPSHOT</version> | |
</bundle> | |
<comments></comments> | |
<descriptors> | |
<entry> | |
<key>nifi_logs</key> | |
<value> | |
<name>nifi_logs</name> | |
</value> | |
</entry> | |
<entry> | |
<key>person</key> | |
<value> | |
<name>person</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>AvroSchemaRegistry</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>nifi_logs</key> | |
<value>{ | |
"type": "record", | |
"name": "nifi_logs", | |
"fields": [ | |
{ "name": "timestamp", "type": "string" }, | |
{ "name": "level", "type": "string" }, | |
{ "name": "thread", "type": "string" }, | |
{ "name": "class", "type": "string" }, | |
{ "name": "message", "type": "string" }, | |
{ "name": "stackTrace", "type": "string" } | |
] | |
}</value> | |
</entry> | |
<entry> | |
<key>person</key> | |
<value>{ | |
"name": "person", | |
"namespace": "nifi", | |
"type": "record", | |
"fields": [ | |
{ "name": "name", "type": "string" }, | |
{ "name": "age", "type": "int" } | |
] | |
}</value> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.schemaregistry.services.AvroSchemaRegistry</type> | |
</controllerServices> | |
<controllerServices> | |
<id>d5067cf3-c9be-342a-0000-000000000000</id> | |
<parentGroupId>be1a51ae-b5cb-32d9-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.4.0-SNAPSHOT</version> | |
</bundle> | |
<comments></comments> | |
<descriptors> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Grok Pattern File</key> | |
<value> | |
<name>Grok Pattern File</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Grok Expression</key> | |
<value> | |
<name>Grok Expression</name> | |
</value> | |
</entry> | |
<entry> | |
<key>no-match-behavior</key> | |
<value> | |
<name>no-match-behavior</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>GrokReader</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value>schema-name</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value>a1813f12-8138-3482-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value>nifi_logs</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value>${avro.schema}</value> | |
</entry> | |
<entry> | |
<key>Grok Pattern File</key> | |
</entry> | |
<entry> | |
<key>Grok Expression</key> | |
<value>%{TIMESTAMP_ISO8601:timestamp} %{LOGLEVEL:level} \[%{DATA:thread}\] %{DATA:class} %{GREEDYDATA:message}</value> | |
</entry> | |
<entry> | |
<key>no-match-behavior</key> | |
<value>append-to-previous-message</value> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.grok.GrokReader</type> | |
</controllerServices> | |
<controllerServices> | |
<id>15d658d7-744b-3ec0-0000-000000000000</id> | |
<parentGroupId>be1a51ae-b5cb-32d9-0000-000000000000</parentGroupId> | |
<bundle> | |
<artifact>nifi-record-serialization-services-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.4.0-SNAPSHOT</version> | |
</bundle> | |
<comments></comments> | |
<descriptors> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value> | |
<name>Schema Write Strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value> | |
<name>schema-access-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.schemaregistry.services.SchemaRegistry</identifiesControllerService> | |
<name>schema-registry</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value> | |
<name>schema-name</name> | |
</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value> | |
<name>schema-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
<value> | |
<name>Date Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
<value> | |
<name>Time Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
<value> | |
<name>Timestamp Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Pretty Print JSON</key> | |
<value> | |
<name>Pretty Print JSON</name> | |
</value> | |
</entry> | |
</descriptors> | |
<name>JsonRecordSetWriter</name> | |
<persistsState>false</persistsState> | |
<properties> | |
<entry> | |
<key>Schema Write Strategy</key> | |
<value>schema-name</value> | |
</entry> | |
<entry> | |
<key>schema-access-strategy</key> | |
<value>inherit-record-schema</value> | |
</entry> | |
<entry> | |
<key>schema-registry</key> | |
</entry> | |
<entry> | |
<key>schema-name</key> | |
<value>${schema.name}</value> | |
</entry> | |
<entry> | |
<key>schema-text</key> | |
<value>${avro.schema}</value> | |
</entry> | |
<entry> | |
<key>Date Format</key> | |
</entry> | |
<entry> | |
<key>Time Format</key> | |
</entry> | |
<entry> | |
<key>Timestamp Format</key> | |
</entry> | |
<entry> | |
<key>Pretty Print JSON</key> | |
<value>true</value> | |
</entry> | |
</properties> | |
<state>ENABLED</state> | |
<type>org.apache.nifi.json.JsonRecordSetWriter</type> | |
</controllerServices> | |
<processors> | |
<id>fb0015f7-a6ee-3edf-0000-000000000000</id> | |
<parentGroupId>be1a51ae-b5cb-32d9-0000-000000000000</parentGroupId> | |
<position> | |
<x>0.0</x> | |
<y>251.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.4.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Log Level</key> | |
<value> | |
<name>Log Level</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Log Payload</key> | |
<value> | |
<name>Log Payload</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attributes to Log</key> | |
<value> | |
<name>Attributes to Log</name> | |
</value> | |
</entry> | |
<entry> | |
<key>attributes-to-log-regex</key> | |
<value> | |
<name>attributes-to-log-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attributes to Ignore</key> | |
<value> | |
<name>Attributes to Ignore</name> | |
</value> | |
</entry> | |
<entry> | |
<key>attributes-to-ignore-regex</key> | |
<value> | |
<name>attributes-to-ignore-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Log prefix</key> | |
<value> | |
<name>Log prefix</name> | |
</value> | |
</entry> | |
<entry> | |
<key>character-set</key> | |
<value> | |
<name>character-set</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Log Level</key> | |
<value>info</value> | |
</entry> | |
<entry> | |
<key>Log Payload</key> | |
<value>true</value> | |
</entry> | |
<entry> | |
<key>Attributes to Log</key> | |
</entry> | |
<entry> | |
<key>attributes-to-log-regex</key> | |
<value>.*</value> | |
</entry> | |
<entry> | |
<key>Attributes to Ignore</key> | |
</entry> | |
<entry> | |
<key>attributes-to-ignore-regex</key> | |
</entry> | |
<entry> | |
<key>Log prefix</key> | |
</entry> | |
<entry> | |
<key>character-set</key> | |
<value>UTF-8</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<name>LogAttribute</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>RUNNING</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.LogAttribute</type> | |
</processors> | |
<processors> | |
<id>010bb671-5579-3954-0000-000000000000</id> | |
<parentGroupId>be1a51ae-b5cb-32d9-0000-000000000000</parentGroupId> | |
<position> | |
<x>486.0</x> | |
<y>430.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.4.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Log Level</key> | |
<value> | |
<name>Log Level</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Log Payload</key> | |
<value> | |
<name>Log Payload</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attributes to Log</key> | |
<value> | |
<name>Attributes to Log</name> | |
</value> | |
</entry> | |
<entry> | |
<key>attributes-to-log-regex</key> | |
<value> | |
<name>attributes-to-log-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Attributes to Ignore</key> | |
<value> | |
<name>Attributes to Ignore</name> | |
</value> | |
</entry> | |
<entry> | |
<key>attributes-to-ignore-regex</key> | |
<value> | |
<name>attributes-to-ignore-regex</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Log prefix</key> | |
<value> | |
<name>Log prefix</name> | |
</value> | |
</entry> | |
<entry> | |
<key>character-set</key> | |
<value> | |
<name>character-set</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Log Level</key> | |
<value>info</value> | |
</entry> | |
<entry> | |
<key>Log Payload</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Attributes to Log</key> | |
</entry> | |
<entry> | |
<key>attributes-to-log-regex</key> | |
<value>.*</value> | |
</entry> | |
<entry> | |
<key>Attributes to Ignore</key> | |
</entry> | |
<entry> | |
<key>attributes-to-ignore-regex</key> | |
</entry> | |
<entry> | |
<key>Log prefix</key> | |
</entry> | |
<entry> | |
<key>character-set</key> | |
<value>UTF-8</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<name>LogAttribute</name> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>RUNNING</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.LogAttribute</type> | |
</processors> | |
<processors> | |
<id>0a501edd-28a2-3a04-0000-000000000000</id> | |
<parentGroupId>be1a51ae-b5cb-32d9-0000-000000000000</parentGroupId> | |
<position> | |
<x>2.0</x> | |
<y>43.99861145019531</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.4.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Local Network Interface</key> | |
<value> | |
<name>Local Network Interface</name> | |
</value> | |
</entry> | |
<entry> | |
<key>port</key> | |
<value> | |
<name>port</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-size-socket-buffer</key> | |
<value> | |
<name>max-size-socket-buffer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>max-number-tcp-connections</key> | |
<value> | |
<name>max-number-tcp-connections</name> | |
</value> | |
</entry> | |
<entry> | |
<key>read-timeout</key> | |
<value> | |
<name>read-timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> | |
<name>record-reader</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.serialization.RecordSetWriterFactory</identifiesControllerService> | |
<name>record-writer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>reader-error-handling-strategy</key> | |
<value> | |
<name>reader-error-handling-strategy</name> | |
</value> | |
</entry> | |
<entry> | |
<key>record-batch-size</key> | |
<value> | |
<name>record-batch-size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>ssl-context-service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.RestrictedSSLContextService</identifiesControllerService> | |
<name>ssl-context-service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>client-auth</key> | |
<value> | |
<name>client-auth</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Local Network Interface</key> | |
</entry> | |
<entry> | |
<key>port</key> | |
<value>7087</value> | |
</entry> | |
<entry> | |
<key>max-size-socket-buffer</key> | |
<value>1 MB</value> | |
</entry> | |
<entry> | |
<key>max-number-tcp-connections</key> | |
<value>10</value> | |
</entry> | |
<entry> | |
<key>read-timeout</key> | |
<value>10 seconds</value> | |
</entry> | |
<entry> | |
<key>record-reader</key> | |
<value>d5067cf3-c9be-342a-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>record-writer</key> | |
<value>15d658d7-744b-3ec0-0000-000000000000</value> | |
</entry> | |
<entry> | |
<key>reader-error-handling-strategy</key> | |
<value>Transfer</value> | |
</entry> | |
<entry> | |
<key>record-batch-size</key> | |
<value>1000</value> | |
</entry> | |
<entry> | |
<key>ssl-context-service</key> | |
</entry> | |
<entry> | |
<key>client-auth</key> | |
<value>REQUIRED</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 ms</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<name>ListenTCPRecord</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>RUNNING</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.ListenTCPRecord</type> | |
</processors> | |
<processors> | |
<id>1d56ccfd-fcad-39b3-0000-000000000000</id> | |
<parentGroupId>be1a51ae-b5cb-32d9-0000-000000000000</parentGroupId> | |
<position> | |
<x>488.0</x> | |
<y>226.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.4.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>3</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>Hostname</key> | |
<value> | |
<name>Hostname</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Port</key> | |
<value> | |
<name>Port</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Max Size of Socket Send Buffer</key> | |
<value> | |
<name>Max Size of Socket Send Buffer</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Idle Connection Expiration</key> | |
<value> | |
<name>Idle Connection Expiration</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Connection Per FlowFile</key> | |
<value> | |
<name>Connection Per FlowFile</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Outgoing Message Delimiter</key> | |
<value> | |
<name>Outgoing Message Delimiter</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Timeout</key> | |
<value> | |
<name>Timeout</name> | |
</value> | |
</entry> | |
<entry> | |
<key>SSL Context Service</key> | |
<value> | |
<identifiesControllerService>org.apache.nifi.ssl.SSLContextService</identifiesControllerService> | |
<name>SSL Context Service</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Character Set</key> | |
<value> | |
<name>Character Set</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>Hostname</key> | |
<value>localhost</value> | |
</entry> | |
<entry> | |
<key>Port</key> | |
<value>7087</value> | |
</entry> | |
<entry> | |
<key>Max Size of Socket Send Buffer</key> | |
<value>1 MB</value> | |
</entry> | |
<entry> | |
<key>Idle Connection Expiration</key> | |
<value>5 seconds</value> | |
</entry> | |
<entry> | |
<key>Connection Per FlowFile</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>Outgoing Message Delimiter</key> | |
<value>\n</value> | |
</entry> | |
<entry> | |
<key>Timeout</key> | |
<value>10 seconds</value> | |
</entry> | |
<entry> | |
<key>SSL Context Service</key> | |
</entry> | |
<entry> | |
<key>Character Set</key> | |
<value>UTF-8</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>0 sec</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<name>PutTCP</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>failure</name> | |
</relationships> | |
<relationships> | |
<autoTerminate>true</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>RUNNING</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.PutTCP</type> | |
</processors> | |
<processors> | |
<id>569daa4b-b872-3d8b-0000-000000000000</id> | |
<parentGroupId>be1a51ae-b5cb-32d9-0000-000000000000</parentGroupId> | |
<position> | |
<x>481.0</x> | |
<y>0.0</y> | |
</position> | |
<bundle> | |
<artifact>nifi-standard-nar</artifact> | |
<group>org.apache.nifi</group> | |
<version>1.4.0-SNAPSHOT</version> | |
</bundle> | |
<config> | |
<bulletinLevel>WARN</bulletinLevel> | |
<comments></comments> | |
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> | |
<descriptors> | |
<entry> | |
<key>File Size</key> | |
<value> | |
<name>File Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Batch Size</key> | |
<value> | |
<name>Batch Size</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Data Format</key> | |
<value> | |
<name>Data Format</name> | |
</value> | |
</entry> | |
<entry> | |
<key>Unique FlowFiles</key> | |
<value> | |
<name>Unique FlowFiles</name> | |
</value> | |
</entry> | |
<entry> | |
<key>generate-ff-custom-text</key> | |
<value> | |
<name>generate-ff-custom-text</name> | |
</value> | |
</entry> | |
<entry> | |
<key>character-set</key> | |
<value> | |
<name>character-set</name> | |
</value> | |
</entry> | |
</descriptors> | |
<executionNode>ALL</executionNode> | |
<lossTolerant>false</lossTolerant> | |
<penaltyDuration>30 sec</penaltyDuration> | |
<properties> | |
<entry> | |
<key>File Size</key> | |
<value>0B</value> | |
</entry> | |
<entry> | |
<key>Batch Size</key> | |
<value>1</value> | |
</entry> | |
<entry> | |
<key>Data Format</key> | |
<value>Text</value> | |
</entry> | |
<entry> | |
<key>Unique FlowFiles</key> | |
<value>false</value> | |
</entry> | |
<entry> | |
<key>generate-ff-custom-text</key> | |
<value>2016-08-04 13:26:32,473 INFO [Leader Election Notification Thread-1] o.a.n.c.l.e.CuratorLeaderElectionManager org.apache.nifi.controller.leader.election.CuratorLeaderElectionManager$ElectionListener@1fa27ea5 has been interrupted; no longer leader for role 'Cluster Coordinator' | |
2016-08-04 13:26:32,474 ERROR [Leader Election Notification Thread-2] o.apache.nifi.controller.FlowController One | |
Two | |
Three | |
org.apache.nifi.exception.UnitTestException: Testing to ensure we are able to capture stack traces | |
at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoordinator.java:185) | |
at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoordinator.java:185) | |
at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoordinator.java:185) | |
at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoordinator.java:185) | |
at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoordinator.java:185) | |
at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoordinator.java:185) | |
at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoordinator.java:185) | |
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_45] | |
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [na:1.8.0_45] | |
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) [na:1.8.0_45] | |
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) [na:1.8.0_45] | |
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_45] | |
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_45] | |
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_45] | |
Caused by: org.apache.nifi.exception.UnitTestException: Testing to ensure we are able to capture stack traces | |
at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoordinator.java:185) | |
at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoordinator.java:185) | |
at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoordinator.java:185) | |
at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoordinator.java:185) | |
at org.apache.nifi.cluster.coordination.node.NodeClusterCoordinator.getElectedActiveCoordinatorAddress(NodeClusterCoordinator.java:185) | |
... 12 common frames omitted | |
2016-08-04 13:26:35,475 WARN [Curator-Framework-0] org.apache.curator.ConnectionState Connection attempt unsuccessful after 3008 (greater than max timeout of 3000). Resetting connection and trying again with a new connection. | |
</value> | |
</entry> | |
<entry> | |
<key>character-set</key> | |
<value>UTF-8</value> | |
</entry> | |
</properties> | |
<runDurationMillis>0</runDurationMillis> | |
<schedulingPeriod>10 second</schedulingPeriod> | |
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> | |
<yieldDuration>1 sec</yieldDuration> | |
</config> | |
<name>GenerateFlowFile</name> | |
<relationships> | |
<autoTerminate>false</autoTerminate> | |
<name>success</name> | |
</relationships> | |
<state>RUNNING</state> | |
<style></style> | |
<type>org.apache.nifi.processors.standard.GenerateFlowFile</type> | |
</processors> | |
</snippet> | |
<timestamp>09/25/2017 17:56:35 EDT</timestamp> | |
</template> |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment