Member since
09-23-2022
5
Posts
0
Kudos Received
0
Solutions
11-12-2025
07:22 PM
I am trying to read a json field from mySQL using executeSQLRecord and insert into snowflake VARIANT field type using PutDataBaseRecord in NiFi 2.6.0. its giving me this error " 03:20:05 UTC ERROR 1695731e-9b6f-3cb8-5a9a-98ab38589597 PutDatabaseRecord[id=1695731e-9b6f-3cb8-5a9a-98ab38589597] Failed to put Records to database for FlowFile[filename=c6087904-71a5-479c-9301-2c99883f5f59]. Routing to failure.: net.snowflake.client.jdbc.SnowflakeSQLException: SQL compilation error: Expression type does not match column data type, expecting VARIANT but got VARCHAR(2) for column JSON_STORE " how do I fix this?
... View more
Labels:
- Labels:
-
Apache NiFi
06-20-2023
10:21 AM
It just gave this information in DEBUG. "PutAzureDataLakeStorage DataLakeServiceClient is not found in the cache with the given credentials. Creating it."
... View more
06-20-2023
09:12 AM
Hi, I am connecting to ADLS from NiFi using PutAzureDataLakeStorage 1.21.0 How do I create a directory using this processor? The document says a directory will be created if it dont exist. https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-azure-nar/1.12.0/org.apache.nifi.processors.azure.storage.PutAzureDataLakeStorage/index.html But my processor is not creating the directory but its failing with error. I am providing the directory as "devfolder" "PutAzureDataLakeStorage PutAzureDataLakeStorage[id=ac451284-0924-383a-9840-06131cd20808] Failed to create file on Azure Data Lake Storage reactor.core.Exceptions$ReactiveException: io.netty.channel.ConnectTimeoutException: connection timed out:" do I have to do something special to create directories. Also, if I set the directory to empty string the file gets created in the root of my ADLS container. Regards.
... View more
Labels:
- Labels:
-
Apache NiFi