[jira] [Created] (NIFI-13671) QuerySalesforce record parsing fails with DateTime types

["Lehel Boér (Jira)" <ji...@apache.org>]

Lehel Boér created NIFI-13671:
---------------------------------

             Summary: QuerySalesforce record parsing fails with DateTime types
                 Key: NIFI-13671
                 URL: https://issues.apache.org/jira/browse/NIFI-13671
             Project: Apache NiFi
          Issue Type: Bug
            Reporter: Lehel Boér
            Assignee: Lehel Boér


When reading records with QuerySalesforceObject while using Property Based mode,

it fails to read DateTime objects due to new changes in the RecordReader.

 
{code:java}
java.lang.RuntimeException: org.apache.nifi.serialization.MalformedRecordException: Successfully parsed a JSON object from input but failed to convert into a Record object with the given schema
    at org.apache.nifi.processors.salesforce.QuerySalesforceObject.lambda$processRecordsCallback$2(QuerySalesforceObject.java:442)
    at org.apache.nifi.controller.repository.StandardProcessSession.write(StandardProcessSession.java:3121)
    at org.apache.nifi.processors.salesforce.QuerySalesforceObject.processQuery(QuerySalesforceObject.java:398)
    at org.apache.nifi.processors.salesforce.QuerySalesforceObject.onTrigger(QuerySalesforceObject.java:357)
    at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
    at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1274)
    at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:244)
    at org.apache.nifi.controller.scheduling.AbstractTimeBasedSchedulingAgent.lambda$doScheduleOnce$0(AbstractTimeBasedSchedulingAgent.java:59)
    at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
    at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
    at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
    at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
    at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: org.apache.nifi.serialization.MalformedRecordException: Successfully parsed a JSON object from input but failed to convert into a Record object with the given schema
    at org.apache.nifi.json.AbstractJsonRowRecordReader.nextRecord(AbstractJsonRowRecordReader.java:182)
    at org.apache.nifi.serialization.RecordReader.nextRecord(RecordReader.java:50)
    at org.apache.nifi.processors.salesforce.QuerySalesforceObject.handleRecordSet(QuerySalesforceObject.java:458)
    at org.apache.nifi.processors.salesforce.QuerySalesforceObject.lambda$processRecordsCallback$2(QuerySalesforceObject.java:434)
    ... 14 common frames omitted
Caused by: org.apache.nifi.serialization.record.field.FieldConversionException: Conversion failed for [2024-08-20T18:48:06.000+0000] named [CreatedDate] to [java.time.LocalDateTime] [java.lang.NumberFormatException] For input string: "2024-08-20T18:48:06.000+0000"
    at org.apache.nifi.serialization.record.field.ObjectLocalDateTimeFieldConverter.tryParseAsNumber(ObjectLocalDateTimeFieldConverter.java:97)
    at org.apache.nifi.serialization.record.field.ObjectLocalDateTimeFieldConverter.convertField(ObjectLocalDateTimeFieldConverter.java:75)
    at org.apache.nifi.serialization.record.field.ObjectTimestampFieldConverter.convertField(ObjectTimestampFieldConverter.java:42)
    at org.apache.nifi.serialization.record.field.ObjectTimestampFieldConverter.convertField(ObjectTimestampFieldConverter.java:28)
    at org.apache.nifi.serialization.record.util.DataTypeUtils.convertType(DataTypeUtils.java:232)
    at org.apache.nifi.serialization.record.util.DataTypeUtils.convertType(DataTypeUtils.java:179)
    at org.apache.nifi.json.JsonTreeRowRecordReader.convertField(JsonTreeRowRecordReader.java:220)
    at org.apache.nifi.json.JsonTreeRowRecordReader.convertJsonNodeToRecord(JsonTreeRowRecordReader.java:183)
    at org.apache.nifi.json.JsonTreeRowRecordReader.convertJsonNodeToRecord(JsonTreeRowRecordReader.java:129)
    at org.apache.nifi.json.JsonTreeRowRecordReader.convertJsonNodeToRecord(JsonTreeRowRecordReader.java:120)
    at org.apache.nifi.json.AbstractJsonRowRecordReader.nextRecord(AbstractJsonRowRecordReader.java:177)
    ... 17 common frames omitted {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)