Filter Query error
Hi, I have requirement to filter date folders from the container like shown below: 2022-01-15 2022-02-04 sample_data test_data out of these folder i want to filter only date folders (2022-01-15,2022-02-04) what query should i use in If…
Copy csv files from multiple sub folders and sink to adls
My source is adls, having different folders and folders contains csv files. I need to look in to each folder and copy data dynamically. storage account having multiple folders. i used get metadata to get folders and foreach to iterate each folder .…
Databricks mount (with SAS, using WASB driver) storage account gives update error on delta tables: Blob operation is not supported
Hi, We have an azure storage account mounted on our databricks workspace. Using databricks, we upsert delta tables located in the azure storage account. The azure storage account is mounted using a SAS token (WASB driver). We get sometimes (10-20% of…
Data Factory: Error Code 24200: Unable to establish a connection from link service to Data lake v2
Hello everyone, Apologies if this has already been asked, but I cannot find any similar answers on this forum. I am following an online course for Azure Data Factory and I'm setting up a pipeline. Right now this pipeline only has one activity (a copy…
How to execute Hive query in Databricks?
We are calling a ".jar" file from Azure Data Factory using Databricks JAR activity. In the JAR activity we are specifying the Cluster Id in Databricks Linked Service. In Databricks cluster we are adding below Spark config: …
SFTP Storage Algorithms issue
When connecting, we are getting an error that the server does not support FIPS compliant algorithms. Will this change/improve in the future? Is there a workaround?
Job failed due to reason: at Source... ...Job aborted due to stage failure
I have a pipeline in Synapse which calls a data flow. That data flow has started to fail and return the below error. {"message":"Job failed due to reason: at Source 'RawTransaction': org.apache.spark.SparkException: Job aborted due to…
dataflow taking toomuch time for executions need help on priority.
Hi In my production pipeline i am using dataflow activity to falttern json file into csv . it taking too much time that is 45 minutes and still either fail or success. same pipeline in dev environment same input data taking 4 to 5 min to complete.…
Problem while uploading specific files from sftp (ADF) : ErrorCode=UserErrorFailedToReadStream
Hello, I use Azure DataFactory for upload files from an SFTP to an Azure BlobStorage V2. Most of the time, everything works fine. But on specific files, i get the following error : ErrorCode=UserErrorFailedToReadStream I tried to…
Error: 'Key columns' expression should return string[], when passing array of parameters in DataFlow with "Delta" as Sink
Hello, I have set of parquet files that I need to Upsert (Update else Insert) into "Delta" (sink) using Data Flow with mainly following 3 transformations: SourceParquetFile==>AlterRowUpsert:true()==>SinkDelta (AllowUpsert) I…
ADF Release Pipeline- Deployment failed CD
Hi I am using the DeployAzureResourceGroup task and have a parameter in my deployment template of type securestring for a ls_connectionString. I have set this as a variable with the 'secret' box checked, and other way I'm done with Azure Keyvault…
Error in copying data to ADLS Gen2
I am trying to copy data from on-prem dataset to ADLS and Getting this error here: Operation on target CopyActivity_XXX failed: 'Type=System.TimeoutException,Message=This request operation sent to…
Source SQL Table Have 1 column with tab spaces, unable to copy data to ADLS it shows below.
Source is SQL: One of the table contains column as below: Basic document flow "Hi Team We are separated by our margins. Because of margin collapsing, we are separated by the width of one of our margins, not both. Charles…
The requested name is valid, but no data of the requested type was found error when renaming datalake file in C#
HI I am facing below issue when renaming a file in azure data lake using C# .net core 3.1 can any one show me a solution error The requested name is valid, but no data of the requested type was found. here is the sample code …
Need workaround to make event trigger on Datalake ADLS Gen1
I need to find out a workaround solution to trigger my ADF V2 pipeline when files are placed in data lake ADLS Gen1. So anyone tell me an alternative approach to make a workable solution. Any reference solutions or links are appreciated.
Multiple Storage Accounts for a Data lake
All, We are thinking of implementing the Zones using Storage Accounts. Which means, each of the 3 Zones (RAW, Staged, Curated) will have one Storage Account each. Are there any best practice document? Is it normal to have more than one Storage…
Returning result from azure databricks to azure datafacotry
I am new to using Azure Databricks and ADF. I have a table in azure databricks. I would like to run a select query on this table and return the result of my select query to ADF. When I searched on how this can be done, I see we can use…
Text Qualifier in ADF BLOB Source
Hi my blob file CSV has comma as row separator , In SSIS I specify text qualifier as " However in ADF source I cant find where can i define text qualifier File is like COLA, COLB 1222, 66666 1333,"Value with comma,…
Latest file extraction (Azure Data factory)
Hi Team, I want to extract latest file from Azure data lake store based on last modified date and want to process in another folder.Could you please someone let me know what needs to be done here if anyone has idea or implemented the same. for…
SFTP Enabled Azure Storage: How to assign a static public IP?
How can we assign a static public IP to the SFTP enabled storage? We currently connect using a the blob storage name, but we have clients that need to allow/add the public IP to their firewall. Thanks.