Hi, for the moment I've done it with two branches and a Notify/Wait.   From the GetFile, a first Success branch go to the Execute SQL that have a Pre-Query that do the Truncate, and a Query that do a simple select query (here a select count() of the truncated table that should return 0 and could be used as check), then that go to a Notify to inform that the truncate is done.   From the GetFile, a Second Success branch go to the Wait (for the truncate to be done), than move to the PutDatabaseRecord (with a UpdateAttibute before to set the schema.name).     Also here https://stackoverflow.com/questions/59026724/nifi-1-10-putsql-error-query-must-be-like-insert/59069223#59069223   <?xml version="1.0" encoding="UTF-8" standalone="yes"?> <template encoding-version="1.3"> <description>Truncate Load for dimensions (slow batch frequency) with archive. No error management implemented</description> <groupId>a0377c1a-016e-1000-167a-e6f1c899a66f</groupId> <name>Clickhouse Truncate Load</name> <snippet> <connections> <id>0e31c732-4e03-37c9-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> <backPressureObjectThreshold>10000</backPressureObjectThreshold> <destination> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>6200e074-aa50-36e9-0000-000000000000</id> <type>PROCESSOR</type> </destination> <flowFileExpiration>0 sec</flowFileExpiration> <labelIndex>1</labelIndex> <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> <loadBalancePartitionAttribute></loadBalancePartitionAttribute> <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> <name></name> <selectedRelationships>success</selectedRelationships> <source> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>b8fa507a-797c-3714-0000-000000000000</id> <type>PROCESSOR</type> </source> <zIndex>0</zIndex> </connections> <connections> <id>19a865e3-39c1-3fee-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> <backPressureObjectThreshold>10000</backPressureObjectThreshold> <destination> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>f4b41b47-34d9-3bb4-0000-000000000000</id> <type>PROCESSOR</type> </destination> <flowFileExpiration>0 sec</flowFileExpiration> <labelIndex>1</labelIndex> <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> <loadBalancePartitionAttribute></loadBalancePartitionAttribute> <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> <name></name> <selectedRelationships>success</selectedRelationships> <source> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>6200e074-aa50-36e9-0000-000000000000</id> <type>PROCESSOR</type> </source> <zIndex>0</zIndex> </connections> <connections> <id>2c1086e0-bbca-393a-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> <backPressureObjectThreshold>10000</backPressureObjectThreshold> <destination> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>d741151d-7167-3026-0000-000000000000</id> <type>PROCESSOR</type> </destination> <flowFileExpiration>0 sec</flowFileExpiration> <labelIndex>1</labelIndex> <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> <loadBalancePartitionAttribute></loadBalancePartitionAttribute> <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> <name></name> <selectedRelationships>success</selectedRelationships> <source> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>56a6347a-9259-3a63-0000-000000000000</id> <type>PROCESSOR</type> </source> <zIndex>0</zIndex> </connections> <connections> <id>329ecc10-4aff-35e8-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> <backPressureObjectThreshold>10000</backPressureObjectThreshold> <destination> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>53f7bf4b-d5d4-32c6-0000-000000000000</id> <type>PROCESSOR</type> </destination> <flowFileExpiration>0 sec</flowFileExpiration> <labelIndex>1</labelIndex> <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> <loadBalancePartitionAttribute></loadBalancePartitionAttribute> <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> <name></name> <selectedRelationships>success</selectedRelationships> <source> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>d741151d-7167-3026-0000-000000000000</id> <type>PROCESSOR</type> </source> <zIndex>0</zIndex> </connections> <connections> <id>872806d3-be25-34ec-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> <backPressureObjectThreshold>10000</backPressureObjectThreshold> <destination> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>d24ba22b-88ad-34ae-0000-000000000000</id> <type>PROCESSOR</type> </destination> <flowFileExpiration>0 sec</flowFileExpiration> <labelIndex>1</labelIndex> <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> <loadBalancePartitionAttribute></loadBalancePartitionAttribute> <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> <name></name> <selectedRelationships>success</selectedRelationships> <source> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>62e39b15-77da-3fa5-0000-000000000000</id> <type>PROCESSOR</type> </source> <zIndex>0</zIndex> </connections> <connections> <id>8d81818b-b883-35f3-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> <backPressureObjectThreshold>10000</backPressureObjectThreshold> <destination> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>56a6347a-9259-3a63-0000-000000000000</id> <type>PROCESSOR</type> </destination> <flowFileExpiration>0 sec</flowFileExpiration> <labelIndex>1</labelIndex> <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> <loadBalancePartitionAttribute></loadBalancePartitionAttribute> <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> <name></name> <prioritizers>org.apache.nifi.prioritizer.FirstInFirstOutPrioritizer</prioritizers> <selectedRelationships>success</selectedRelationships> <source> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>f1513fa5-c26a-3157-0000-000000000000</id> <type>PROCESSOR</type> </source> <zIndex>0</zIndex> </connections> <connections> <id>ead6ac6b-a621-3f65-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> <backPressureObjectThreshold>10000</backPressureObjectThreshold> <destination> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>62e39b15-77da-3fa5-0000-000000000000</id> <type>PROCESSOR</type> </destination> <flowFileExpiration>0 sec</flowFileExpiration> <labelIndex>1</labelIndex> <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> <loadBalancePartitionAttribute></loadBalancePartitionAttribute> <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> <name></name> <prioritizers>org.apache.nifi.prioritizer.FirstInFirstOutPrioritizer</prioritizers> <selectedRelationships>success</selectedRelationships> <source> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>f1513fa5-c26a-3157-0000-000000000000</id> <type>PROCESSOR</type> </source> <zIndex>0</zIndex> </connections> <connections> <id>fccc8d95-eaed-3a31-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold> <backPressureObjectThreshold>10000</backPressureObjectThreshold> <destination> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>b8fa507a-797c-3714-0000-000000000000</id> <type>PROCESSOR</type> </destination> <flowFileExpiration>0 sec</flowFileExpiration> <labelIndex>1</labelIndex> <loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression> <loadBalancePartitionAttribute></loadBalancePartitionAttribute> <loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus> <loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy> <name></name> <prioritizers>org.apache.nifi.prioritizer.FirstInFirstOutPrioritizer</prioritizers> <selectedRelationships>success</selectedRelationships> <source> <groupId>bbf1ef49-f963-37ab-0000-000000000000</groupId> <id>f1513fa5-c26a-3157-0000-000000000000</id> <type>PROCESSOR</type> </source> <zIndex>0</zIndex> </connections> <controllerServices> <id>517808ef-0266-3e67-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <bundle> <artifact>nifi-dbcp-service-nar</artifact> <group>org.apache.nifi</group> <version>1.10.0</version> </bundle> <comments></comments> <descriptors> <entry> <key>Database Connection URL</key> <value> <name>Database Connection URL</name> </value> </entry> <entry> <key>Database Driver Class Name</key> <value> <name>Database Driver Class Name</name> </value> </entry> <entry> <key>database-driver-locations</key> <value> <name>database-driver-locations</name> </value> </entry> <entry> <key>kerberos-credentials-service</key> <value> <identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService> <name>kerberos-credentials-service</name> </value> </entry> <entry> <key>Database User</key> <value> <name>Database User</name> </value> </entry> <entry> <key>Password</key> <value> <name>Password</name> </value> </entry> <entry> <key>Max Wait Time</key> <value> <name>Max Wait Time</name> </value> </entry> <entry> <key>Max Total Connections</key> <value> <name>Max Total Connections</name> </value> </entry> <entry> <key>Validation-query</key> <value> <name>Validation-query</name> </value> </entry> <entry> <key>dbcp-min-idle-conns</key> <value> <name>dbcp-min-idle-conns</name> </value> </entry> <entry> <key>dbcp-max-idle-conns</key> <value> <name>dbcp-max-idle-conns</name> </value> </entry> <entry> <key>dbcp-max-conn-lifetime</key> <value> <name>dbcp-max-conn-lifetime</name> </value> </entry> <entry> <key>dbcp-time-between-eviction-runs</key> <value> <name>dbcp-time-between-eviction-runs</name> </value> </entry> <entry> <key>dbcp-min-evictable-idle-time</key> <value> <name>dbcp-min-evictable-idle-time</name> </value> </entry> <entry> <key>dbcp-soft-min-evictable-idle-time</key> <value> <name>dbcp-soft-min-evictable-idle-time</name> </value> </entry> </descriptors> <name>DBCP_SBST</name> <persistsState>false</persistsState> <properties> <entry> <key>Database Connection URL</key> <value>jdbc:clickhouse://192.168.1.185:8123/SBST</value> </entry> <entry> <key>Database Driver Class Name</key> <value>ru.yandex.clickhouse.ClickHouseDriver</value> </entry> <entry> <key>database-driver-locations</key> <value>/home/thales/downloads/clickhouse-jdbc/clickhouse-jdbc-release_0.2/target/clickhouse-jdbc-0.2-jar-with-dependencies.jar</value> </entry> <entry> <key>kerberos-credentials-service</key> </entry> <entry> <key>Database User</key> </entry> <entry> <key>Password</key> </entry> <entry> <key>Max Wait Time</key> <value>500 millis</value> </entry> <entry> <key>Max Total Connections</key> <value>8</value> </entry> <entry> <key>Validation-query</key> </entry> <entry> <key>dbcp-min-idle-conns</key> <value>0</value> </entry> <entry> <key>dbcp-max-idle-conns</key> <value>8</value> </entry> <entry> <key>dbcp-max-conn-lifetime</key> <value>-1</value> </entry> <entry> <key>dbcp-time-between-eviction-runs</key> <value>-1</value> </entry> <entry> <key>dbcp-min-evictable-idle-time</key> <value>30 mins</value> </entry> <entry> <key>dbcp-soft-min-evictable-idle-time</key> <value>-1</value> </entry> </properties> <state>ENABLED</state> <type>org.apache.nifi.dbcp.DBCPConnectionPool</type> </controllerServices> <controllerServices> <id>8d6517b8-c698-3871-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <bundle> <artifact>nifi-record-serialization-services-nar</artifact> <group>org.apache.nifi</group> <version>1.10.0</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-version</key> <value> <name>schema-version</name> </value> </entry> <entry> <key>schema-branch</key> <value> <name>schema-branch</name> </value> </entry> <entry> <key>schema-text</key> <value> <name>schema-text</name> </value> </entry> <entry> <key>csv-reader-csv-parser</key> <value> <name>csv-reader-csv-parser</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>CSV Format</key> <value> <name>CSV Format</name> </value> </entry> <entry> <key>Value Separator</key> <value> <name>Value Separator</name> </value> </entry> <entry> <key>Skip Header Line</key> <value> <name>Skip Header Line</name> </value> </entry> <entry> <key>ignore-csv-header</key> <value> <name>ignore-csv-header</name> </value> </entry> <entry> <key>Quote Character</key> <value> <name>Quote Character</name> </value> </entry> <entry> <key>Escape Character</key> <value> <name>Escape Character</name> </value> </entry> <entry> <key>Comment Marker</key> <value> <name>Comment Marker</name> </value> </entry> <entry> <key>Null String</key> <value> <name>Null String</name> </value> </entry> <entry> <key>Trim Fields</key> <value> <name>Trim Fields</name> </value> </entry> <entry> <key>csvutils-character-set</key> <value> <name>csvutils-character-set</name> </value> </entry> </descriptors> <name>CSVReaderTild</name> <persistsState>false</persistsState> <properties> <entry> <key>schema-access-strategy</key> <value>schema-name</value> </entry> <entry> <key>schema-registry</key> <value>f6754d68-6957-3155-0000-000000000000</value> </entry> <entry> <key>schema-name</key> <value>${schema.name}</value> </entry> <entry> <key>schema-version</key> </entry> <entry> <key>schema-branch</key> </entry> <entry> <key>schema-text</key> <value>${avro.schema}</value> </entry> <entry> <key>csv-reader-csv-parser</key> <value>commons-csv</value> </entry> <entry> <key>Date Format</key> </entry> <entry> <key>Time Format</key> </entry> <entry> <key>Timestamp Format</key> </entry> <entry> <key>CSV Format</key> <value>custom</value> </entry> <entry> <key>Value Separator</key> <value>~</value> </entry> <entry> <key>Skip Header Line</key> <value>false</value> </entry> <entry> <key>ignore-csv-header</key> <value>false</value> </entry> <entry> <key>Quote Character</key> <value>"</value> </entry> <entry> <key>Escape Character</key> <value>\</value> </entry> <entry> <key>Comment Marker</key> </entry> <entry> <key>Null String</key> </entry> <entry> <key>Trim Fields</key> <value>true</value> </entry> <entry> <key>csvutils-character-set</key> <value>UTF-8</value> </entry> </properties> <state>ENABLED</state> <type>org.apache.nifi.csv.CSVReader</type> </controllerServices> <controllerServices> <id>ccdef25c-4ad3-37ac-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <bundle> <artifact>nifi-distributed-cache-services-nar</artifact> <group>org.apache.nifi</group> <version>1.10.0</version> </bundle> <comments></comments> <descriptors> <entry> <key>Server Hostname</key> <value> <name>Server Hostname</name> </value> </entry> <entry> <key>Server Port</key> <value> <name>Server Port</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>Communications Timeout</key> <value> <name>Communications Timeout</name> </value> </entry> </descriptors> <name>DistributedMapCacheClientService</name> <persistsState>false</persistsState> <properties> <entry> <key>Server Hostname</key> <value>192.168.1.190</value> </entry> <entry> <key>Server Port</key> <value>4557</value> </entry> <entry> <key>SSL Context Service</key> </entry> <entry> <key>Communications Timeout</key> <value>30 secs</value> </entry> </properties> <state>ENABLED</state> <type>org.apache.nifi.distributed.cache.client.DistributedMapCacheClientService</type> </controllerServices> <controllerServices> <id>f6754d68-6957-3155-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <bundle> <artifact>nifi-registry-nar</artifact> <group>org.apache.nifi</group> <version>1.10.0</version> </bundle> <comments></comments> <descriptors> <entry> <key>avro-reg-validated-field-names</key> <value> <name>avro-reg-validated-field-names</name> </value> </entry> <entry> <key>functionalcat</key> <value> <name>functionalcat</name> </value> </entry> <entry> <key>geographicalcat</key> <value> <name>geographicalcat</name> </value> </entry> <entry> <key>hisevent</key> <value> <name>hisevent</name> </value> </entry> <entry> <key>hiseventorigin</key> <value> <name>hiseventorigin</name> </value> </entry> </descriptors> <name>AvroSchemaRegistry</name> <persistsState>false</persistsState> <properties> <entry> <key>avro-reg-validated-field-names</key> <value>true</value> </entry> <entry> <key>functionalcat</key> <value>{ "type": "record", "name": "functionalcat", "fields": [ { "name": "FUNCTIONALCAT", "type": "int" }, { "name": "FUNCTIONALDESC", "type": "string" } ] }</value> </entry> <entry> <key>geographicalcat</key> <value>{ "type": "record", "name": "geographicalcat", "fields": [ { "name": "GEOGRAPHICALCAT", "type": "int" }, { "name": "GEOGRAPHICALCODE", "type": "string" }, { "name": "GEOGRAPHICALDESC", "type": "string" } ] }</value> </entry> <entry> <key>hisevent</key> <value>{ "type": "record", "name": "hisevent", "fields": [ { "name": "ALARMID", "type": ["null", "long"] }, { "name": "ENVIRONMENT", "type": ["null", "string"] }, { "name": "VALUE", "type": "long" }, { "name": "ACKREQUIRED", "type": "long" }, { "name": "SEVERITY", "type": "long" }, { "name": "EQUIPMENTCLASS", "type": ["null", "long"] }, { "name": "FUNCTIONALCAT", "type": "long" }, { "name": "GEOGRAPHICALCAT", "type": "long" }, { "name": "DATEANDTIME", "type": "string" }, { "name": "EQUIPMENTNAME", "type": "string" }, { "name": "ASSETNAME", "type": "string" }, { "name": "MESSAGE", "type": ["null", "string"] }, { "name": "STATUS", "type": ["null", "string"] }, { "name": "GROUP1", "type": ["null", "string"] }, { "name": "GROUP2", "type": ["null", "string"] }, { "name": "FORMAT", "type": ["null", "string"] }, { "name": "DSSEVENTTYPE", "type": ["null", "string"] }, { "name": "OPER", "type": ["null", "string"] } ] }</value> </entry> <entry> <key>hiseventorigin</key> <value>{ "type": "record", "name": "hisevent", "fields": [ { "name": "ALARMID", "type": ["null", "long"] }, { "name": "ENVIRONMENT", "type": ["null", "string"] }, { "name": "VALUE", "type": "long" }, { "name": "ACKREQUIRED", "type": "long" }, { "name": "SEVERITY", "type": "long" }, { "name": "EQUIPMENTCLASS", "type": ["null", "long"] }, { "name": "FUNCTIONALCAT", "type": "long" }, { "name": "GEOGRAPHICALCAT", "type": "long" }, { "name": "DATEANDTIME", "type": "string" }, { "name": "EQUIPMENTNAME", "type": "string" }, { "name": "ASSETNAME", "type": "string" }, { "name": "MESSAGE", "type": ["null", "string"] }, { "name": "STATUS", "type": ["null", "string"] }, { "name": "GROUP1", "type": ["null", "string"] }, { "name": "GROUP2", "type": ["null", "string"] }, { "name": "FORMAT", "type": ["null", "string"] }, { "name": "DSSEVENTTYPE", "type": ["null", "string"] }, { "name": "OPER", "type": ["null", "string"] }, { "name": "EMPTY", "type": ["null", "string"] } ] }</value> </entry> </properties> <state>ENABLED</state> <type>org.apache.nifi.schemaregistry.services.AvroSchemaRegistry</type> </controllerServices> <labels> <id>7bbcc1a5-298e-31f1-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <position> <x>1040.0</x> <y>616.0</y> </position> <height>184.0</height> <label>Main Folder Level : Avro Registry, add Schema that describe the CSV Variable RootFolder : File Location root GetFile : input Directory based on RootFolder and File Name ExecuteSQL : Truncate table and count queries NotiFy and Wait : Name of the Identifier Update Attribute : Schema Name PutDatabaseRecord : Create a Record Reader controller CSVReader at this process group level, just changing the CSV format, and using the registry of the root process group, change the table name, the 2 Unmatched parmaters to Ignore</label> <style> <entry> <key>font-size</key> <value>14px</value> </entry> </style> <width>688.0</width> </labels> <processors> <id>53f7bf4b-d5d4-32c6-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <position> <x>624.0</x> <y>680.0</y> </position> <bundle> <artifact>nifi-standard-nar</artifact> <group>org.apache.nifi</group> <version>1.10.0</version> </bundle> <config> <bulletinLevel>WARN</bulletinLevel> <comments></comments> <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> <descriptors> <entry> <key>put-db-record-record-reader</key> <value> <identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService> <name>put-db-record-record-reader</name> </value> </entry> <entry> <key>put-db-record-statement-type</key> <value> <name>put-db-record-statement-type</name> </value> </entry> <entry> <key>put-db-record-dcbp-service</key> <value> <identifiesControllerService>org.apache.nifi.dbcp.DBCPService</identifiesControllerService> <name>put-db-record-dcbp-service</name> </value> </entry> <entry> <key>put-db-record-catalog-name</key> <value> <name>put-db-record-catalog-name</name> </value> </entry> <entry> <key>put-db-record-schema-name</key> <value> <name>put-db-record-schema-name</name> </value> </entry> <entry> <key>put-db-record-table-name</key> <value> <name>put-db-record-table-name</name> </value> </entry> <entry> <key>put-db-record-translate-field-names</key> <value> <name>put-db-record-translate-field-names</name> </value> </entry> <entry> <key>put-db-record-unmatched-field-behavior</key> <value> <name>put-db-record-unmatched-field-behavior</name> </value> </entry> <entry> <key>put-db-record-unmatched-column-behavior</key> <value> <name>put-db-record-unmatched-column-behavior</name> </value> </entry> <entry> <key>put-db-record-update-keys</key> <value> <name>put-db-record-update-keys</name> </value> </entry> <entry> <key>put-db-record-field-containing-sql</key> <value> <name>put-db-record-field-containing-sql</name> </value> </entry> <entry> <key>put-db-record-allow-multiple-statements</key> <value> <name>put-db-record-allow-multiple-statements</name> </value> </entry> <entry> <key>put-db-record-quoted-identifiers</key> <value> <name>put-db-record-quoted-identifiers</name> </value> </entry> <entry> <key>put-db-record-quoted-table-identifiers</key> <value> <name>put-db-record-quoted-table-identifiers</name> </value> </entry> <entry> <key>put-db-record-query-timeout</key> <value> <name>put-db-record-query-timeout</name> </value> </entry> <entry> <key>rollback-on-failure</key> <value> <name>rollback-on-failure</name> </value> </entry> <entry> <key>table-schema-cache-size</key> <value> <name>table-schema-cache-size</name> </value> </entry> <entry> <key>put-db-record-max-batch-size</key> <value> <name>put-db-record-max-batch-size</name> </value> </entry> </descriptors> <executionNode>ALL</executionNode> <lossTolerant>false</lossTolerant> <penaltyDuration>30 sec</penaltyDuration> <properties> <entry> <key>put-db-record-record-reader</key> <value>8d6517b8-c698-3871-0000-000000000000</value> </entry> <entry> <key>put-db-record-statement-type</key> <value>INSERT</value> </entry> <entry> <key>put-db-record-dcbp-service</key> <value>517808ef-0266-3e67-0000-000000000000</value> </entry> <entry> <key>put-db-record-catalog-name</key> </entry> <entry> <key>put-db-record-schema-name</key> <value>SBST</value> </entry> <entry> <key>put-db-record-table-name</key> <value>geographicalcat</value> </entry> <entry> <key>put-db-record-translate-field-names</key> <value>true</value> </entry> <entry> <key>put-db-record-unmatched-field-behavior</key> <value>Ignore Unmatched Fields</value> </entry> <entry> <key>put-db-record-unmatched-column-behavior</key> <value>Ignore Unmatched Columns</value> </entry> <entry> <key>put-db-record-update-keys</key> </entry> <entry> <key>put-db-record-field-containing-sql</key> </entry> <entry> <key>put-db-record-allow-multiple-statements</key> <value>false</value> </entry> <entry> <key>put-db-record-quoted-identifiers</key> <value>false</value> </entry> <entry> <key>put-db-record-quoted-table-identifiers</key> <value>false</value> </entry> <entry> <key>put-db-record-query-timeout</key> <value>0 seconds</value> </entry> <entry> <key>rollback-on-failure</key> <value>false</value> </entry> <entry> <key>table-schema-cache-size</key> <value>100</value> </entry> <entry> <key>put-db-record-max-batch-size</key> <value>0</value> </entry> </properties> <runDurationMillis>0</runDurationMillis> <schedulingPeriod>0 sec</schedulingPeriod> <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> <yieldDuration>1 sec</yieldDuration> </config> <executionNodeRestricted>false</executionNodeRestricted> <name>geographicalcat_PutDatabaseRecord</name> <relationships> <autoTerminate>true</autoTerminate> <name>failure</name> </relationships> <relationships> <autoTerminate>true</autoTerminate> <name>retry</name> </relationships> <relationships> <autoTerminate>true</autoTerminate> <name>success</name> </relationships> <state>STOPPED</state> <style/> <type>org.apache.nifi.processors.standard.PutDatabaseRecord</type> </processors> <processors> <id>56a6347a-9259-3a63-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <position> <x>624.0</x> <y>248.0</y> </position> <bundle> <artifact>nifi-standard-nar</artifact> <group>org.apache.nifi</group> <version>1.10.0</version> </bundle> <config> <bulletinLevel>WARN</bulletinLevel> <comments></comments> <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> <descriptors> <entry> <key>release-signal-id</key> <value> <name>release-signal-id</name> </value> </entry> <entry> <key>target-signal-count</key> <value> <name>target-signal-count</name> </value> </entry> <entry> <key>signal-counter-name</key> <value> <name>signal-counter-name</name> </value> </entry> <entry> <key>wait-buffer-count</key> <value> <name>wait-buffer-count</name> </value> </entry> <entry> <key>releasable-flowfile-count</key> <value> <name>releasable-flowfile-count</name> </value> </entry> <entry> <key>expiration-duration</key> <value> <name>expiration-duration</name> </value> </entry> <entry> <key>distributed-cache-service</key> <value> <identifiesControllerService>org.apache.nifi.distributed.cache.client.AtomicDistributedMapCacheClient</identifiesControllerService> <name>distributed-cache-service</name> </value> </entry> <entry> <key>attribute-copy-mode</key> <value> <name>attribute-copy-mode</name> </value> </entry> <entry> <key>wait-mode</key> <value> <name>wait-mode</name> </value> </entry> <entry> <key>wait-penalty-duration</key> <value> <name>wait-penalty-duration</name> </value> </entry> </descriptors> <executionNode>ALL</executionNode> <lossTolerant>false</lossTolerant> <penaltyDuration>30 sec</penaltyDuration> <properties> <entry> <key>release-signal-id</key> <value>NotifyGeographicalcatTruncated</value> </entry> <entry> <key>target-signal-count</key> <value>1</value> </entry> <entry> <key>signal-counter-name</key> </entry> <entry> <key>wait-buffer-count</key> <value>1</value> </entry> <entry> <key>releasable-flowfile-count</key> <value>1</value> </entry> <entry> <key>expiration-duration</key> <value>10 min</value> </entry> <entry> <key>distributed-cache-service</key> <value>ccdef25c-4ad3-37ac-0000-000000000000</value> </entry> <entry> <key>attribute-copy-mode</key> <value>keeporiginal</value> </entry> <entry> <key>wait-mode</key> <value>keep</value> </entry> <entry> <key>wait-penalty-duration</key> </entry> </properties> <runDurationMillis>0</runDurationMillis> <schedulingPeriod>0 sec</schedulingPeriod> <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> <yieldDuration>1 sec</yieldDuration> </config> <executionNodeRestricted>false</executionNodeRestricted> <name>geographicalcat_WaitTruncate</name> <relationships> <autoTerminate>true</autoTerminate> <name>expired</name> </relationships> <relationships> <autoTerminate>true</autoTerminate> <name>failure</name> </relationships> <relationships> <autoTerminate>false</autoTerminate> <name>success</name> </relationships> <relationships> <autoTerminate>true</autoTerminate> <name>wait</name> </relationships> <state>STOPPED</state> <style/> <type>org.apache.nifi.processors.standard.Wait</type> </processors> <processors> <id>6200e074-aa50-36e9-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <position> <x>0.0</x> <y>208.0</y> </position> <bundle> <artifact>nifi-standard-nar</artifact> <group>org.apache.nifi</group> <version>1.10.0</version> </bundle> <config> <bulletinLevel>WARN</bulletinLevel> <comments></comments> <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> <descriptors> <entry> <key>Mode</key> <value> <name>Mode</name> </value> </entry> <entry> <key>Compression Format</key> <value> <name>Compression Format</name> </value> </entry> <entry> <key>Compression Level</key> <value> <name>Compression Level</name> </value> </entry> <entry> <key>Update Filename</key> <value> <name>Update Filename</name> </value> </entry> </descriptors> <executionNode>ALL</executionNode> <lossTolerant>false</lossTolerant> <penaltyDuration>30 sec</penaltyDuration> <properties> <entry> <key>Mode</key> <value>compress</value> </entry> <entry> <key>Compression Format</key> <value>gzip</value> </entry> <entry> <key>Compression Level</key> <value>9</value> </entry> <entry> <key>Update Filename</key> <value>true</value> </entry> </properties> <runDurationMillis>0</runDurationMillis> <schedulingPeriod>0 sec</schedulingPeriod> <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> <yieldDuration>1 sec</yieldDuration> </config> <executionNodeRestricted>false</executionNodeRestricted> <name>CompressContent</name> <relationships> <autoTerminate>true</autoTerminate> <name>failure</name> </relationships> <relationships> <autoTerminate>false</autoTerminate> <name>success</name> </relationships> <state>STOPPED</state> <style/> <type>org.apache.nifi.processors.standard.CompressContent</type> </processors> <processors> <id>62e39b15-77da-3fa5-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <position> <x>1264.0</x> <y>40.0</y> </position> <bundle> <artifact>nifi-standard-nar</artifact> <group>org.apache.nifi</group> <version>1.10.0</version> </bundle> <config> <bulletinLevel>WARN</bulletinLevel> <comments></comments> <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> <descriptors> <entry> <key>Database Connection Pooling Service</key> <value> <identifiesControllerService>org.apache.nifi.dbcp.DBCPService</identifiesControllerService> <name>Database Connection Pooling Service</name> </value> </entry> <entry> <key>sql-pre-query</key> <value> <name>sql-pre-query</name> </value> </entry> <entry> <key>SQL select query</key> <value> <name>SQL select query</name> </value> </entry> <entry> <key>sql-post-query</key> <value> <name>sql-post-query</name> </value> </entry> <entry> <key>Max Wait Time</key> <value> <name>Max Wait Time</name> </value> </entry> <entry> <key>dbf-normalize</key> <value> <name>dbf-normalize</name> </value> </entry> <entry> <key>dbf-user-logical-types</key> <value> <name>dbf-user-logical-types</name> </value> </entry> <entry> <key>compression-format</key> <value> <name>compression-format</name> </value> </entry> <entry> <key>dbf-default-precision</key> <value> <name>dbf-default-precision</name> </value> </entry> <entry> <key>dbf-default-scale</key> <value> <name>dbf-default-scale</name> </value> </entry> <entry> <key>esql-max-rows</key> <value> <name>esql-max-rows</name> </value> </entry> <entry> <key>esql-output-batch-size</key> <value> <name>esql-output-batch-size</name> </value> </entry> </descriptors> <executionNode>ALL</executionNode> <lossTolerant>false</lossTolerant> <penaltyDuration>30 sec</penaltyDuration> <properties> <entry> <key>Database Connection Pooling Service</key> <value>517808ef-0266-3e67-0000-000000000000</value> </entry> <entry> <key>sql-pre-query</key> <value>truncate table SBST.geographicalcat</value> </entry> <entry> <key>SQL select query</key> <value>select count(*) as cnt from SBST.geographicalcat</value> </entry> <entry> <key>sql-post-query</key> </entry> <entry> <key>Max Wait Time</key> <value>0 seconds</value> </entry> <entry> <key>dbf-normalize</key> <value>false</value> </entry> <entry> <key>dbf-user-logical-types</key> <value>false</value> </entry> <entry> <key>compression-format</key> <value>NONE</value> </entry> <entry> <key>dbf-default-precision</key> <value>10</value> </entry> <entry> <key>dbf-default-scale</key> <value>0</value> </entry> <entry> <key>esql-max-rows</key> <value>0</value> </entry> <entry> <key>esql-output-batch-size</key> <value>0</value> </entry> </properties> <runDurationMillis>0</runDurationMillis> <schedulingPeriod>0 sec</schedulingPeriod> <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> <yieldDuration>1 sec</yieldDuration> </config> <executionNodeRestricted>false</executionNodeRestricted> <name>geographicalcat_ExecuteSQLTruncate</name> <relationships> <autoTerminate>true</autoTerminate> <name>failure</name> </relationships> <relationships> <autoTerminate>false</autoTerminate> <name>success</name> </relationships> <state>STOPPED</state> <style/> <type>org.apache.nifi.processors.standard.ExecuteSQL</type> </processors> <processors> <id>b8fa507a-797c-3714-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <position> <x>8.0</x> <y>0.0</y> </position> <bundle> <artifact>nifi-update-attribute-nar</artifact> <group>org.apache.nifi</group> <version>1.10.0</version> </bundle> <config> <bulletinLevel>WARN</bulletinLevel> <comments></comments> <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> <descriptors> <entry> <key>Delete Attributes Expression</key> <value> <name>Delete Attributes Expression</name> </value> </entry> <entry> <key>Store State</key> <value> <name>Store State</name> </value> </entry> <entry> <key>Stateful Variables Initial Value</key> <value> <name>Stateful Variables Initial Value</name> </value> </entry> <entry> <key>canonical-value-lookup-cache-size</key> <value> <name>canonical-value-lookup-cache-size</name> </value> </entry> <entry> <key>filename</key> <value> <name>filename</name> </value> </entry> </descriptors> <executionNode>ALL</executionNode> <lossTolerant>false</lossTolerant> <penaltyDuration>30 sec</penaltyDuration> <properties> <entry> <key>Delete Attributes Expression</key> </entry> <entry> <key>Store State</key> <value>Do not store state</value> </entry> <entry> <key>Stateful Variables Initial Value</key> </entry> <entry> <key>canonical-value-lookup-cache-size</key> <value>100</value> </entry> <entry> <key>filename</key> <value>${filename:prepend("_"):prepend(${now():format("yyyy-MM-dd-HH-mm-ss")})}</value> </entry> </properties> <runDurationMillis>0</runDurationMillis> <schedulingPeriod>0 sec</schedulingPeriod> <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> <yieldDuration>1 sec</yieldDuration> </config> <executionNodeRestricted>false</executionNodeRestricted> <name>UpdateAttribute</name> <relationships> <autoTerminate>false</autoTerminate> <name>success</name> </relationships> <state>STOPPED</state> <style/> <type>org.apache.nifi.processors.attributes.UpdateAttribute</type> </processors> <processors> <id>d24ba22b-88ad-34ae-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <position> <x>1264.0</x> <y>264.0</y> </position> <bundle> <artifact>nifi-standard-nar</artifact> <group>org.apache.nifi</group> <version>1.10.0</version> </bundle> <config> <bulletinLevel>WARN</bulletinLevel> <comments></comments> <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> <descriptors> <entry> <key>release-signal-id</key> <value> <name>release-signal-id</name> </value> </entry> <entry> <key>signal-counter-name</key> <value> <name>signal-counter-name</name> </value> </entry> <entry> <key>signal-counter-delta</key> <value> <name>signal-counter-delta</name> </value> </entry> <entry> <key>signal-buffer-count</key> <value> <name>signal-buffer-count</name> </value> </entry> <entry> <key>distributed-cache-service</key> <value> <identifiesControllerService>org.apache.nifi.distributed.cache.client.AtomicDistributedMapCacheClient</identifiesControllerService> <name>distributed-cache-service</name> </value> </entry> <entry> <key>attribute-cache-regex</key> <value> <name>attribute-cache-regex</name> </value> </entry> </descriptors> <executionNode>ALL</executionNode> <lossTolerant>false</lossTolerant> <penaltyDuration>30 sec</penaltyDuration> <properties> <entry> <key>release-signal-id</key> <value>NotifyGeographicalcatTruncated</value> </entry> <entry> <key>signal-counter-name</key> <value>default</value> </entry> <entry> <key>signal-counter-delta</key> <value>1</value> </entry> <entry> <key>signal-buffer-count</key> <value>1</value> </entry> <entry> <key>distributed-cache-service</key> <value>ccdef25c-4ad3-37ac-0000-000000000000</value> </entry> <entry> <key>attribute-cache-regex</key> </entry> </properties> <runDurationMillis>0</runDurationMillis> <schedulingPeriod>0 sec</schedulingPeriod> <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> <yieldDuration>1 sec</yieldDuration> </config> <executionNodeRestricted>false</executionNodeRestricted> <name>geographicalcat_NotifyTruncated</name> <relationships> <autoTerminate>true</autoTerminate> <name>failure</name> </relationships> <relationships> <autoTerminate>true</autoTerminate> <name>success</name> </relationships> <state>STOPPED</state> <style/> <type>org.apache.nifi.processors.standard.Notify</type> </processors> <processors> <id>d741151d-7167-3026-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <position> <x>624.0</x> <y>464.0</y> </position> <bundle> <artifact>nifi-update-attribute-nar</artifact> <group>org.apache.nifi</group> <version>1.10.0</version> </bundle> <config> <bulletinLevel>WARN</bulletinLevel> <comments></comments> <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> <descriptors> <entry> <key>Delete Attributes Expression</key> <value> <name>Delete Attributes Expression</name> </value> </entry> <entry> <key>Store State</key> <value> <name>Store State</name> </value> </entry> <entry> <key>Stateful Variables Initial Value</key> <value> <name>Stateful Variables Initial Value</name> </value> </entry> <entry> <key>canonical-value-lookup-cache-size</key> <value> <name>canonical-value-lookup-cache-size</name> </value> </entry> <entry> <key>schema.name</key> <value> <name>schema.name</name> </value> </entry> </descriptors> <executionNode>ALL</executionNode> <lossTolerant>false</lossTolerant> <penaltyDuration>30 sec</penaltyDuration> <properties> <entry> <key>Delete Attributes Expression</key> </entry> <entry> <key>Store State</key> <value>Do not store state</value> </entry> <entry> <key>Stateful Variables Initial Value</key> </entry> <entry> <key>canonical-value-lookup-cache-size</key> <value>100</value> </entry> <entry> <key>schema.name</key> <value>geographicalcat</value> </entry> </properties> <runDurationMillis>0</runDurationMillis> <schedulingPeriod>0 sec</schedulingPeriod> <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> <yieldDuration>1 sec</yieldDuration> </config> <executionNodeRestricted>false</executionNodeRestricted> <name>geographicalcat_UpdateAttributeSchemaName</name> <relationships> <autoTerminate>false</autoTerminate> <name>success</name> </relationships> <state>STOPPED</state> <style/> <type>org.apache.nifi.processors.attributes.UpdateAttribute</type> </processors> <processors> <id>f1513fa5-c26a-3157-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <position> <x>624.0</x> <y>32.0</y> </position> <bundle> <artifact>nifi-standard-nar</artifact> <group>org.apache.nifi</group> <version>1.10.0</version> </bundle> <config> <bulletinLevel>WARN</bulletinLevel> <comments></comments> <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> <descriptors> <entry> <key>Input Directory</key> <value> <name>Input Directory</name> </value> </entry> <entry> <key>File Filter</key> <value> <name>File Filter</name> </value> </entry> <entry> <key>Path Filter</key> <value> <name>Path Filter</name> </value> </entry> <entry> <key>Batch Size</key> <value> <name>Batch Size</name> </value> </entry> <entry> <key>Keep Source File</key> <value> <name>Keep Source File</name> </value> </entry> <entry> <key>Recurse Subdirectories</key> <value> <name>Recurse Subdirectories</name> </value> </entry> <entry> <key>Polling Interval</key> <value> <name>Polling Interval</name> </value> </entry> <entry> <key>Ignore Hidden Files</key> <value> <name>Ignore Hidden Files</name> </value> </entry> <entry> <key>Minimum File Age</key> <value> <name>Minimum File Age</name> </value> </entry> <entry> <key>Maximum File Age</key> <value> <name>Maximum File Age</name> </value> </entry> <entry> <key>Minimum File Size</key> <value> <name>Minimum File Size</name> </value> </entry> <entry> <key>Maximum File Size</key> <value> <name>Maximum File Size</name> </value> </entry> </descriptors> <executionNode>ALL</executionNode> <lossTolerant>false</lossTolerant> <penaltyDuration>30 sec</penaltyDuration> <properties> <entry> <key>Input Directory</key> <value>${FileSourceFolder}</value> </entry> <entry> <key>File Filter</key> <value>GeographicalCat.dat</value> </entry> <entry> <key>Path Filter</key> </entry> <entry> <key>Batch Size</key> <value>10</value> </entry> <entry> <key>Keep Source File</key> <value>false</value> </entry> <entry> <key>Recurse Subdirectories</key> <value>false</value> </entry> <entry> <key>Polling Interval</key> <value>0 sec</value> </entry> <entry> <key>Ignore Hidden Files</key> <value>true</value> </entry> <entry> <key>Minimum File Age</key> <value>60 sec</value> </entry> <entry> <key>Maximum File Age</key> </entry> <entry> <key>Minimum File Size</key> <value>0 B</value> </entry> <entry> <key>Maximum File Size</key> </entry> </properties> <runDurationMillis>0</runDurationMillis> <schedulingPeriod>10 sec</schedulingPeriod> <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> <yieldDuration>1 sec</yieldDuration> </config> <executionNodeRestricted>false</executionNodeRestricted> <name>geographicalcat_GetFile</name> <relationships> <autoTerminate>false</autoTerminate> <name>success</name> </relationships> <state>STOPPED</state> <style/> <type>org.apache.nifi.processors.standard.GetFile</type> </processors> <processors> <id>f4b41b47-34d9-3bb4-0000-000000000000</id> <parentGroupId>bbf1ef49-f963-37ab-0000-000000000000</parentGroupId> <position> <x>0.0</x> <y>456.0</y> </position> <bundle> <artifact>nifi-standard-nar</artifact> <group>org.apache.nifi</group> <version>1.10.0</version> </bundle> <config> <bulletinLevel>WARN</bulletinLevel> <comments></comments> <concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount> <descriptors> <entry> <key>Directory</key> <value> <name>Directory</name> </value> </entry> <entry> <key>Conflict Resolution Strategy</key> <value> <name>Conflict Resolution Strategy</name> </value> </entry> <entry> <key>Create Missing Directories</key> <value> <name>Create Missing Directories</name> </value> </entry> <entry> <key>Maximum File Count</key> <value> <name>Maximum File Count</name> </value> </entry> <entry> <key>Last Modified Time</key> <value> <name>Last Modified Time</name> </value> </entry> <entry> <key>Permissions</key> <value> <name>Permissions</name> </value> </entry> <entry> <key>Owner</key> <value> <name>Owner</name> </value> </entry> <entry> <key>Group</key> <value> <name>Group</name> </value> </entry> </descriptors> <executionNode>ALL</executionNode> <lossTolerant>false</lossTolerant> <penaltyDuration>30 sec</penaltyDuration> <properties> <entry> <key>Directory</key> <value>${FileArchiveFolder}/ref</value> </entry> <entry> <key>Conflict Resolution Strategy</key> <value>fail</value> </entry> <entry> <key>Create Missing Directories</key> <value>true</value> </entry> <entry> <key>Maximum File Count</key> </entry> <entry> <key>Last Modified Time</key> </entry> <entry> <key>Permissions</key> </entry> <entry> <key>Owner</key> </entry> <entry> <key>Group</key> </entry> </properties> <runDurationMillis>0</runDurationMillis> <schedulingPeriod>0 sec</schedulingPeriod> <schedulingStrategy>TIMER_DRIVEN</schedulingStrategy> <yieldDuration>1 sec</yieldDuration> </config> <executionNodeRestricted>false</executionNodeRestricted> <name>PutFile</name> <relationships> <autoTerminate>true</autoTerminate> <name>failure</name> </relationships> <relationships> <autoTerminate>true</autoTerminate> <name>success</name> </relationships> <state>STOPPED</state> <style/> <type>org.apache.nifi.processors.standard.PutFile</type> </processors> </snippet> <timestamp>11/29/2019 08:00:19 HKT</timestamp> </template> ... View more