Built a sample test for this for date as well and I get this error. If I go
look at RecordFieldType.DATE it shows the format as DATE("date", "yyyy-MM-dd")
which is what I'm using. Same with timestamp TIMESTAMP("timestamp", "yyyy-MM-dd
HH:mm:ss")
PutHive3Streaming[id=8a4f32d4-0169-1000-0000-000045f0eabb]
Error
[org.apache.nifi.serialization.record.util.IllegalTypeConversionException:
Could not convert value [2019-01-01] of type java.lang.String to Date
because the value is not in the expected date format:
org.apache.nifi.serialization.record.MapRecord$$Lambda$1216/421560596@5794948d
for field c_date] parsing Record [OW[class=class
org.apache.nifi.serialization.record.MapRecord,value=MapRecord[{c_string=Hello
World, c_timestamp=2019-01-01 09:23:15, c_date=2019-01-01}]]].:
See attached example...
Thanks
Shawn Weeks
From: Shawn Weeks <[email protected]>
Sent: Thursday, April 25, 2019 7:40 PM
To: [email protected]
Subject: PutHive3Streaming Doesn't Work with String Timestamps
Trying to figure out the correct way to stream timestamps as it appears that
using the Hive String Timestamp format no longer works.
Error [java.lang.NumberFormatException: For input string: "2019-04-26
00:05:00.363"]
Also What about dates?
Thanks
Shawn Weeks
<?xml version="1.0" encoding="UTF-8" standalone="yes"?><template
encoding-version="1.2">
<description/>
<groupId>8a46bbe2-0169-1000-ffff-ffffd67ee53e</groupId>
<name>Timestamp and Date Example</name>
<snippet>
<connections>
<id>1e028424-7409-3b24-0000-000000000000</id>
<parentGroupId>71b4b5db-dd78-3855-0000-000000000000</parentGroupId>
<versionedComponentId>1e028424-7409-3b24-9954-7294ff7fe345</versionedComponentId>
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
<backPressureObjectThreshold>1000000</backPressureObjectThreshold>
<destination>
<groupId>71b4b5db-dd78-3855-0000-000000000000</groupId>
<id>8d8f40a6-45d3-3a30-0000-000000000000</id>
<type>PROCESSOR</type>
<versionedComponentId>8d8f40a6-45d3-3a30-bb25-a0b0bdbcbcee</versionedComponentId>
</destination>
<flowFileExpiration>0 sec</flowFileExpiration>
<labelIndex>1</labelIndex>
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression>
<loadBalancePartitionAttribute/>
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus>
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy>
<name/>
<selectedRelationships>success</selectedRelationships>
<source>
<groupId>71b4b5db-dd78-3855-0000-000000000000</groupId>
<id>5ef1835d-a4b5-3993-0000-000000000000</id>
<type>PROCESSOR</type>
<versionedComponentId>5ef1835d-a4b5-3993-a9f6-5e72c571a2bd</versionedComponentId>
</source>
<zIndex>0</zIndex>
</connections>
<connections>
<id>a6e925e6-f551-3a25-0000-000000000000</id>
<parentGroupId>71b4b5db-dd78-3855-0000-000000000000</parentGroupId>
<versionedComponentId>a6e925e6-f551-3a25-a1af-180558814a5a</versionedComponentId>
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
<backPressureObjectThreshold>10000</backPressureObjectThreshold>
<destination>
<groupId>71b4b5db-dd78-3855-0000-000000000000</groupId>
<id>19888cae-3c69-3337-0000-000000000000</id>
<type>PROCESSOR</type>
<versionedComponentId>19888cae-3c69-3337-8554-519cdb12e62f</versionedComponentId>
</destination>
<flowFileExpiration>0 sec</flowFileExpiration>
<labelIndex>1</labelIndex>
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression>
<loadBalancePartitionAttribute/>
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus>
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy>
<name/>
<selectedRelationships>merged</selectedRelationships>
<source>
<groupId>71b4b5db-dd78-3855-0000-000000000000</groupId>
<id>8d8f40a6-45d3-3a30-0000-000000000000</id>
<type>PROCESSOR</type>
<versionedComponentId>8d8f40a6-45d3-3a30-bb25-a0b0bdbcbcee</versionedComponentId>
</source>
<zIndex>0</zIndex>
</connections>
<connections>
<id>e1d00ed9-02d8-34cd-0000-000000000000</id>
<parentGroupId>71b4b5db-dd78-3855-0000-000000000000</parentGroupId>
<versionedComponentId>e1d00ed9-02d8-34cd-9d74-8ba17e7e4bc6</versionedComponentId>
<backPressureDataSizeThreshold>1 GB</backPressureDataSizeThreshold>
<backPressureObjectThreshold>10000</backPressureObjectThreshold>
<destination>
<groupId>71b4b5db-dd78-3855-0000-000000000000</groupId>
<id>a1284dfd-9275-3d6d-0000-000000000000</id>
<type>FUNNEL</type>
<versionedComponentId>a1284dfd-9275-3d6d-943b-117b8479c3cb</versionedComponentId>
</destination>
<flowFileExpiration>0 sec</flowFileExpiration>
<labelIndex>1</labelIndex>
<loadBalanceCompression>DO_NOT_COMPRESS</loadBalanceCompression>
<loadBalancePartitionAttribute/>
<loadBalanceStatus>LOAD_BALANCE_NOT_CONFIGURED</loadBalanceStatus>
<loadBalanceStrategy>DO_NOT_LOAD_BALANCE</loadBalanceStrategy>
<name/>
<selectedRelationships>failure</selectedRelationships>
<selectedRelationships>retry</selectedRelationships>
<source>
<groupId>71b4b5db-dd78-3855-0000-000000000000</groupId>
<id>19888cae-3c69-3337-0000-000000000000</id>
<type>PROCESSOR</type>
<versionedComponentId>19888cae-3c69-3337-8554-519cdb12e62f</versionedComponentId>
</source>
<zIndex>0</zIndex>
</connections>
<controllerServices>
<id>25c14c0f-befd-3ac5-0000-000000000000</id>
<parentGroupId>71b4b5db-dd78-3855-0000-000000000000</parentGroupId>
<versionedComponentId>25c14c0f-befd-3ac5-9086-b3ef8942897b</versionedComponentId>
<bundle>
<artifact>nifi-record-serialization-services-nar</artifact>
<group>org.apache.nifi</group>
<version>1.9.0.3.4.0.0-155</version>
</bundle>
<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>cache-size</key>
<value>
<name>cache-size</name>
</value>
</entry>
</descriptors>
<name>AvroReader</name>
<persistsState>false</persistsState>
<properties>
<entry>
<key>schema-access-strategy</key>
<value>embedded-avro-schema</value>
</entry>
<entry>
<key>schema-registry</key>
</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>cache-size</key>
<value>1000</value>
</entry>
</properties>
<state>ENABLED</state>
<type>org.apache.nifi.avro.AvroReader</type>
</controllerServices>
<controllerServices>
<id>2d8ef401-4e92-35bf-0000-000000000000</id>
<parentGroupId>71b4b5db-dd78-3855-0000-000000000000</parentGroupId>
<versionedComponentId>2d8ef401-4e92-35bf-8464-ff9174857638</versionedComponentId>
<bundle>
<artifact>nifi-kerberos-credentials-service-nar</artifact>
<group>org.apache.nifi</group>
<version>1.9.0.3.4.0.0-155</version>
</bundle>
<comments/>
<descriptors>
<entry>
<key>Kerberos Keytab</key>
<value>
<name>Kerberos Keytab</name>
</value>
</entry>
<entry>
<key>Kerberos Principal</key>
<value>
<name>Kerberos Principal</name>
</value>
</entry>
</descriptors>
<name>KeytabCredentialsService</name>
<persistsState>false</persistsState>
<properties>
<entry>
<key>Kerberos Keytab</key>
<value>/etc/security/keytabs/nifi.service.keytab</value>
</entry>
<entry>
<key>Kerberos Principal</key>
<value>nifi/${hostname()}@DEV.BROCKTEC.COM</value>
</entry>
</properties>
<state>ENABLED</state>
<type>org.apache.nifi.kerberos.KeytabCredentialsService</type>
</controllerServices>
<controllerServices>
<id>394692a6-bf3a-3f20-0000-000000000000</id>
<parentGroupId>71b4b5db-dd78-3855-0000-000000000000</parentGroupId>
<versionedComponentId>394692a6-bf3a-3f20-9435-cb91d3949dd0</versionedComponentId>
<bundle>
<artifact>nifi-record-serialization-services-nar</artifact>
<group>org.apache.nifi</group>
<version>1.9.0.3.4.0.0-155</version>
</bundle>
<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>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>c_date</key>
<value>
<name>c_date</name>
</value>
</entry>
<entry>
<key>c_string</key>
<value>
<name>c_string</name>
</value>
</entry>
<entry>
<key>c_timestamp</key>
<value>
<name>c_timestamp</name>
</value>
</entry>
</descriptors>
<name>JsonPathReader</name>
<persistsState>false</persistsState>
<properties>
<entry>
<key>schema-access-strategy</key>
<value>infer-schema</value>
</entry>
<entry>
<key>schema-registry</key>
</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>Date Format</key>
</entry>
<entry>
<key>Time Format</key>
</entry>
<entry>
<key>Timestamp Format</key>
</entry>
<entry>
<key>c_date</key>
<value>$.c_date</value>
</entry>
<entry>
<key>c_string</key>
<value>$.c_string</value>
</entry>
<entry>
<key>c_timestamp</key>
<value>$.c_timestamp</value>
</entry>
</properties>
<state>ENABLED</state>
<type>org.apache.nifi.json.JsonPathReader</type>
</controllerServices>
<controllerServices>
<id>ecfc584f-6b9e-3414-0000-000000000000</id>
<parentGroupId>71b4b5db-dd78-3855-0000-000000000000</parentGroupId>
<versionedComponentId>ecfc584f-6b9e-3414-90a9-d3a465f13997</versionedComponentId>
<bundle>
<artifact>nifi-record-serialization-services-nar</artifact>
<group>org.apache.nifi</group>
<version>1.9.0.3.4.0.0-155</version>
</bundle>
<comments/>
<descriptors>
<entry>
<key>Schema Write Strategy</key>
<value>
<name>Schema Write Strategy</name>
</value>
</entry>
<entry>
<key>schema-cache</key>
<value>
<identifiesControllerService>org.apache.nifi.serialization.RecordSchemaCacheService</identifiesControllerService>
<name>schema-cache</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-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>compression-format</key>
<value>
<name>compression-format</name>
</value>
</entry>
<entry>
<key>cache-size</key>
<value>
<name>cache-size</name>
</value>
</entry>
<entry>
<key>encoder-pool-size</key>
<value>
<name>encoder-pool-size</name>
</value>
</entry>
</descriptors>
<name>AvroRecordSetWriter</name>
<persistsState>false</persistsState>
<properties>
<entry>
<key>Schema Write Strategy</key>
<value>avro-embedded</value>
</entry>
<entry>
<key>schema-cache</key>
</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-version</key>
</entry>
<entry>
<key>schema-branch</key>
</entry>
<entry>
<key>schema-text</key>
<value>${avro.schema}</value>
</entry>
<entry>
<key>compression-format</key>
<value>NONE</value>
</entry>
<entry>
<key>cache-size</key>
<value>1000</value>
</entry>
<entry>
<key>encoder-pool-size</key>
<value>32</value>
</entry>
</properties>
<state>ENABLED</state>
<type>org.apache.nifi.avro.AvroRecordSetWriter</type>
</controllerServices>
<funnels>
<id>a1284dfd-9275-3d6d-0000-000000000000</id>
<parentGroupId>71b4b5db-dd78-3855-0000-000000000000</parentGroupId>
<position>
<x>970.0</x>
<y>525.2615281818603</y>
</position>
<versionedComponentId>a1284dfd-9275-3d6d-943b-117b8479c3cb</versionedComponentId>
</funnels>
<labels>
<id>32ac5467-7066-3fca-0000-000000000000</id>
<parentGroupId>71b4b5db-dd78-3855-0000-000000000000</parentGroupId>
<position>
<x>51.499241337410865</x>
<y>0.0</y>
</position>
<height>248.96310424804688</height>
<label>create table test_hive_streaming(c_string string, c_date
date, c_timestamp timestamp);</label>
<style>
<entry>
<key>font-size</key>
<value>12px</value>
</entry>
</style>
<width>933.7876892089844</width>
</labels>
<processors>
<id>19888cae-3c69-3337-0000-000000000000</id>
<parentGroupId>71b4b5db-dd78-3855-0000-000000000000</parentGroupId>
<position>
<x>819.0</x>
<y>297.2615281818603</y>
</position>
<versionedComponentId>19888cae-3c69-3337-8554-519cdb12e62f</versionedComponentId>
<bundle>
<artifact>nifi-hive3-nar</artifact>
<group>org.apache.nifi</group>
<version>1.9.0.3.4.0.0-155</version>
</bundle>
<config>
<bulletinLevel>WARN</bulletinLevel>
<comments/>
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
<descriptors>
<entry>
<key>record-reader</key>
<value>
<identifiesControllerService>org.apache.nifi.serialization.RecordReaderFactory</identifiesControllerService>
<name>record-reader</name>
</value>
</entry>
<entry>
<key>hive3-stream-metastore-uri</key>
<value>
<name>hive3-stream-metastore-uri</name>
</value>
</entry>
<entry>
<key>hive3-config-resources</key>
<value>
<name>hive3-config-resources</name>
</value>
</entry>
<entry>
<key>hive3-stream-database-name</key>
<value>
<name>hive3-stream-database-name</name>
</value>
</entry>
<entry>
<key>hive3-stream-table-name</key>
<value>
<name>hive3-stream-table-name</name>
</value>
</entry>
<entry>
<key>hive3-stream-part-vals</key>
<value>
<name>hive3-stream-part-vals</name>
</value>
</entry>
<entry>
<key>hive3-stream-autocreate-partition</key>
<value>
<name>hive3-stream-autocreate-partition</name>
</value>
</entry>
<entry>
<key>hive3-stream-call-timeout</key>
<value>
<name>hive3-stream-call-timeout</name>
</value>
</entry>
<entry>
<key>hive3-stream-disable-optimizations</key>
<value>
<name>hive3-stream-disable-optimizations</name>
</value>
</entry>
<entry>
<key>rollback-on-failure</key>
<value>
<name>rollback-on-failure</name>
</value>
</entry>
<entry>
<key>kerberos-credentials-service</key>
<value>
<identifiesControllerService>org.apache.nifi.kerberos.KerberosCredentialsService</identifiesControllerService>
<name>kerberos-credentials-service</name>
</value>
</entry>
</descriptors>
<executionNode>ALL</executionNode>
<lossTolerant>false</lossTolerant>
<penaltyDuration>30 sec</penaltyDuration>
<properties>
<entry>
<key>record-reader</key>
<value>25c14c0f-befd-3ac5-0000-000000000000</value>
</entry>
<entry>
<key>hive3-stream-metastore-uri</key>
</entry>
<entry>
<key>hive3-config-resources</key>
<value>/etc/hadoop/conf/core-site.xml,/etc/hive/conf/hive-site.xml</value>
</entry>
<entry>
<key>hive3-stream-database-name</key>
<value>default</value>
</entry>
<entry>
<key>hive3-stream-table-name</key>
<value>test_hive_streaming</value>
</entry>
<entry>
<key>hive3-stream-part-vals</key>
</entry>
<entry>
<key>hive3-stream-autocreate-partition</key>
<value>true</value>
</entry>
<entry>
<key>hive3-stream-call-timeout</key>
<value>0</value>
</entry>
<entry>
<key>hive3-stream-disable-optimizations</key>
<value>false</value>
</entry>
<entry>
<key>rollback-on-failure</key>
<value>false</value>
</entry>
<entry>
<key>kerberos-credentials-service</key>
<value>2d8ef401-4e92-35bf-0000-000000000000</value>
</entry>
</properties>
<runDurationMillis>0</runDurationMillis>
<schedulingPeriod>0 sec</schedulingPeriod>
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
<yieldDuration>1 sec</yieldDuration>
</config>
<executionNodeRestricted>false</executionNodeRestricted>
<name>PutHive3Streaming</name>
<relationships>
<autoTerminate>false</autoTerminate>
<name>failure</name>
</relationships>
<relationships>
<autoTerminate>false</autoTerminate>
<name>retry</name>
</relationships>
<relationships>
<autoTerminate>true</autoTerminate>
<name>success</name>
</relationships>
<state>STOPPED</state>
<style/>
<type>org.apache.nifi.processors.hive.PutHive3Streaming</type>
</processors>
<processors>
<id>5ef1835d-a4b5-3993-0000-000000000000</id>
<parentGroupId>71b4b5db-dd78-3855-0000-000000000000</parentGroupId>
<position>
<x>0.0</x>
<y>296.2615281818603</y>
</position>
<versionedComponentId>5ef1835d-a4b5-3993-a9f6-5e72c571a2bd</versionedComponentId>
<bundle>
<artifact>nifi-standard-nar</artifact>
<group>org.apache.nifi</group>
<version>1.9.0.3.4.0.0-155</version>
</bundle>
<config>
<bulletinLevel>WARN</bulletinLevel>
<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>PRIMARY</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>{"c_string":"Hello
World","c_date":"2019-01-01","c_timestamp":"2019-01-01
09:23:15"}</value>
</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>
<executionNodeRestricted>false</executionNodeRestricted>
<name>GenerateFlowFile</name>
<relationships>
<autoTerminate>false</autoTerminate>
<name>success</name>
</relationships>
<state>STOPPED</state>
<style/>
<type>org.apache.nifi.processors.standard.GenerateFlowFile</type>
</processors>
<processors>
<id>8d8f40a6-45d3-3a30-0000-000000000000</id>
<parentGroupId>71b4b5db-dd78-3855-0000-000000000000</parentGroupId>
<position>
<x>408.0</x>
<y>297.2615281818603</y>
</position>
<versionedComponentId>8d8f40a6-45d3-3a30-bb25-a0b0bdbcbcee</versionedComponentId>
<bundle>
<artifact>nifi-standard-nar</artifact>
<group>org.apache.nifi</group>
<version>1.9.0.3.4.0.0-155</version>
</bundle>
<config>
<bulletinLevel>WARN</bulletinLevel>
<comments/>
<concurrentlySchedulableTaskCount>1</concurrentlySchedulableTaskCount>
<descriptors>
<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>merge-strategy</key>
<value>
<name>merge-strategy</name>
</value>
</entry>
<entry>
<key>correlation-attribute-name</key>
<value>
<name>correlation-attribute-name</name>
</value>
</entry>
<entry>
<key>Attribute Strategy</key>
<value>
<name>Attribute Strategy</name>
</value>
</entry>
<entry>
<key>min-records</key>
<value>
<name>min-records</name>
</value>
</entry>
<entry>
<key>max-records</key>
<value>
<name>max-records</name>
</value>
</entry>
<entry>
<key>min-bin-size</key>
<value>
<name>min-bin-size</name>
</value>
</entry>
<entry>
<key>max-bin-size</key>
<value>
<name>max-bin-size</name>
</value>
</entry>
<entry>
<key>max-bin-age</key>
<value>
<name>max-bin-age</name>
</value>
</entry>
<entry>
<key>max.bin.count</key>
<value>
<name>max.bin.count</name>
</value>
</entry>
</descriptors>
<executionNode>ALL</executionNode>
<lossTolerant>false</lossTolerant>
<penaltyDuration>30 sec</penaltyDuration>
<properties>
<entry>
<key>record-reader</key>
<value>394692a6-bf3a-3f20-0000-000000000000</value>
</entry>
<entry>
<key>record-writer</key>
<value>ecfc584f-6b9e-3414-0000-000000000000</value>
</entry>
<entry>
<key>merge-strategy</key>
<value>Bin-Packing Algorithm</value>
</entry>
<entry>
<key>correlation-attribute-name</key>
</entry>
<entry>
<key>Attribute Strategy</key>
<value>Keep Only Common Attributes</value>
</entry>
<entry>
<key>min-records</key>
<value>1</value>
</entry>
<entry>
<key>max-records</key>
<value>100</value>
</entry>
<entry>
<key>min-bin-size</key>
<value>0 B</value>
</entry>
<entry>
<key>max-bin-size</key>
</entry>
<entry>
<key>max-bin-age</key>
</entry>
<entry>
<key>max.bin.count</key>
<value>1</value>
</entry>
</properties>
<runDurationMillis>0</runDurationMillis>
<schedulingPeriod>0 sec</schedulingPeriod>
<schedulingStrategy>TIMER_DRIVEN</schedulingStrategy>
<yieldDuration>1 sec</yieldDuration>
</config>
<executionNodeRestricted>false</executionNodeRestricted>
<name>MergeRecord</name>
<relationships>
<autoTerminate>true</autoTerminate>
<name>failure</name>
</relationships>
<relationships>
<autoTerminate>false</autoTerminate>
<name>merged</name>
</relationships>
<relationships>
<autoTerminate>true</autoTerminate>
<name>original</name>
</relationships>
<state>STOPPED</state>
<style/>
<type>org.apache.nifi.processors.standard.MergeRecord</type>
</processors>
</snippet>
<timestamp>04/25/2019 19:54:05 CDT</timestamp>
</template>
