[ 
https://issues.apache.org/jira/browse/NIFI-2165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15362841#comment-15362841
 ] 

ASF subversion and git services commented on NIFI-2165:
-------------------------------------------------------

Commit 7e63b0036429d739b5d2ee4bca578d99db2b0037 in nifi's branch 
refs/heads/master from [~jeffoxenberg]
[ https://git-wip-us.apache.org/repos/asf?p=nifi.git;h=7e63b00 ]

NIFI-2165: fix support for inserting timestamps into cassandra

Signed-off-by: Matt Burgess <[email protected]>

This closes #602


> PutCassandraQL is handling timestamps as strings
> ------------------------------------------------
>
>                 Key: NIFI-2165
>                 URL: https://issues.apache.org/jira/browse/NIFI-2165
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Extensions
>    Affects Versions: 1.0.0, 0.6.1
>         Environment: Ubuntu 14.04, openjdk version "1.8.0_91"
>            Reporter: Jeff Oxenberg
>            Priority: Minor
>              Labels: cassandra, putcassandraql, timestamp
>             Fix For: 1.0.0
>
>   Original Estimate: 1h
>  Remaining Estimate: 1h
>
> PutCassandraQL fails when attempting to insert a (iso-8601-formatted) 
> timestamp on both Nifi 0.6 and 1.0 due to handling timestamps as strings.
> Input: 
> FlowFile Attribute Map Content
> Key: 'cql.args.1.type'
>         Value: 'text'
> Key: 'cql.args.1.value'
>         Value: 'temp3'
> Key: 'cql.args.2.type'
>         Value: 'timestamp'
> Key: 'cql.args.2.value'
>         Value: '2016-06-30T20:04:36Z'
> Key: 'cql.args.3.type'
>         Value: 'float'
> Key: 'cql.args.3.value'
>         Value: '6.7'
> Key: 'j.id'
>         Value: 'temp3'
> Key: 'j.ts'
>         Value: '2016-06-30T20:04:36Z'
> Key: 'j.value'
>         Value: '6.7'
> --------------------------------------------------
> INSERT INTO test.test2 (sensor, ts, value) VALUES(?,?,?)
> Output:
> com.datastax.driver.core.exceptions.CodecNotFoundException: Codec not found 
> for requested operation: [timestamp <-> java.lang.String]
> Record does not get inserted into Cassandra
> Expected output:
> Record gets inserted into Cassandra



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to