[
https://issues.apache.org/jira/browse/NIFI-2165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15359916#comment-15359916
]
ASF GitHub Bot commented on NIFI-2165:
--------------------------------------
Github user jeffoxenberg commented on the issue:
https://github.com/apache/nifi/pull/602
Thanks for working with me on this.
The real flow's value was double quoted, it was parsed from JSON.
[Here's](https://gist.github.com/jeffoxenberg/6f12bb11b7359e10180712500cb528e7)
the flow that I originally got the error from and here's a sample of the json
message that nifi would consume from kafka: {"senstype": "temp3", "ts":
"2016-07-01T20:52:46Z", "value": 8.72}. It also gave me an error when I used
UpdateAttribute to insert the values directly instead of using variables from
parsed JSON.
> 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)
