Copy Activity from Oracle to ASQL - Logging failed error SessionLogFailToWriteLog

Chan, Joyce (IST-BRUNELENERGYPL) 0 Reputation points
2023-04-14T15:35:13.61+00:00

I have existing pipeline copying data from Oracle to Azure SQL executing successfully. Then added Logging with level = Warning and mode = Reliable , see below. But pipeline stuck at source and eventually failed, because pipeline timeout set to 15mins Error messages received is as below. Did I missed out some configs? Please provide some advice as to why this is the case, thanks! User's image

User's image

Operation on target AC_COPY_SRC_TO_STG failed: ErrorCode=SessionLogFailToWriteLog,'Type=Microsoft.DataTransfer.Common.Shared.HybridDeliveryException,Message=Write log is failed with error message: 'Microsoft.DataTransfer.Common.Shared.HybridDeliveryException: ADLS Gen2 operation failed for: An error occurred while sending the request.. Account: 'storageAccount'. FileSystem: 'raw'.. ---> System.Net.Http.HttpRequestException: An error occurred while sending the request. ---> System.Net.WebException: Unable to connect to the remote server ---> System.Net.Sockets.SocketException: A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond 10.41.33.170:443
   at System.Net.Sockets.Socket.InternalEndConnect(IAsyncResult asyncResult)
   at System.Net.Sockets.Socket.EndConnect(IAsyncResult asyncResult)
   at System.Net.ServicePoint.ConnectSocketInternal(Boolean connectFailure, Socket s4, Socket s6, Socket& socket, IPAddress& address, ConnectSocketState state, IAsyncResult asyncResult, Exception& exception)
   --- End of inner exception stack trace ---
   at System.Net.HttpWebRequest.EndGetResponse(IAsyncResult asyncResult)
   at System.Net.Http.HttpClientHandler.GetResponseCallback(IAsyncResult ar)
   --- End of inner exception stack trace ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at Microsoft.Rest.RetryAfterDelegatingHandler.<SendAsync>d__7.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.Rest.RetryDelegatingHandler.<>c__DisplayClass15_0.<<SendAsync>b__0>d.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.Rest.RetryDelegatingHandler.<SendAsync>d__15.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.Azure.Storage.Data.RequestHandler.<SendAsync>d__3.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.Azure.Storage.Data.AzureDfsClient.<GetFilesystemPropertiesWithHttpMessagesAsync>d__42.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.Azure.Storage.Data.AzureDfsClientExtensions.<GetFilesystemPropertiesAsync>d__14.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
   at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw()
   at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
   at Microsoft.Azure.Storage.Data.AzureDfsClientExtensions.GetFilesystemProperties(IAzureDfsClient operations, String filesystem, String resource, String xMsClientRequestId, Nullable`1 timeout, String xMsDate)
   at Microsoft.Azure.Storage.Data.BlobFSClient.<>c__DisplayClass32_0.<IsFileSystemExist>b__1()
   at Microsoft.Rest.TransientFaultHandling.RetryPolicy.ExecuteAction[TResult](Func`1 func)
   at Microsoft.Azure.Storage.Data.BlobFSClient.<>c__DisplayClass32_0.<IsFileSystemExist>b__0()
   at Microsoft.Azure.Storage.Data.ExceptionHandler.ExecuteAction[TResult](Func`1 func, String fileSystem, String path, String actionName)
   --- End of inner exception stack trace ---
   at Microsoft.Azure.Storage.Data.ExceptionHandler.HandleException(Exception ex, String fileSystem, String path, String actionName)
   at Microsoft.Azure.Storage.Data.ExceptionHandler.ExecuteAction[TResult](Func`1 func, String fileSystem, String path, String actionName)
   at Microsoft.Azure.Storage.Data.BlobFSClient.IsFileSystemExist(String filesystem, Boolean swallowForbiddenError, Boolean useListPathApi)
   at Microsoft.Azure.Storage.Data.BlobFSClient.CreateFileSystemIfNotExist(String filesystem, Boolean swallowForbiddenError, Boolean useListPathApiToCheckFileSystemExist)
   at Microsoft.DataTransfer.Runtime.BlobFSMultipartSink..ctor(AzureBlobFSConnection connection, AzureBlobFSWriteInternalSettings writeSettings)
   at Microsoft.DataTransfer.Runtime.AzureBlobFSConnection.CreateSink(IDictionary`2 properties)
   at Microsoft.DataTransfer.Runtime.BinarySinkStageProcessor..ctor(PluginRegistration plugins, IDictionary`2 stageProperties, BinaryTelemetryCollector telemetryCollector)
   at Microsoft.DataTransfer.Runtime.Provider.HybirdRuntimeBinaryWriter.<>c__DisplayClass11_0.<ProcessCommandSettings>b__1()
   at Microsoft.DataTransfer.Runtime.PipelineProcessStage`3.CreateProcessor(Func`1 createNextProcessor)
   at Microsoft.DataTransfer.Runtime.PipelineProcessStageProcessor`2.Process(TInput data)
   at Microsoft.DataTransfer.Runtime.Provider.HybridRuntimeCommand.ExecuteBinaryWriter(IEnumerable`1 data)
   at Microsoft.DataTransfer.Runtime.FileBasedLogHandler.CreateEmptyLogFile(Int32 currFileIndex)'.,Source=Microsoft.DataTransfer.ClientLibrary,'
Azure Data Factory
Azure Data Factory
An Azure service for ingesting, preparing, and transforming data at scale.
11,623 questions
{count} votes

1 answer

Sort by: Most helpful
  1. AnnuKumari-MSFT 34,556 Reputation points Microsoft Employee Moderator
    2023-04-17T12:13:22.48+00:00

    Hi Chan, Joyce (IST-BRUNELENERGYPL) , Welcome to Microsoft Q&A platform and thanks for posting your question here. As per my understanding you are facing error after enabling session log option in copy activity supposed to copy data from Oracle server to Azure SQL server. Please let me know if that is not the case. Before jumping into the conclusion on why the pipeline is failing, I want to know if you are executing the pipeline in debug mode or in trigger mode? Kindly confirm whether without session log , the pipeline is running is successfully getting executed or not? The error message specifies that the pipeline is failing while writing logs to ADLS. These could be two possible reasons for the failure:

    1. You mentioned that you set the pipeline timeout to 15 minutes, but it's possible that the pipeline is taking longer than that to complete. While it's still writing the logs, pipeline is timedout and throwing error. You may want to consider increasing the pipeline timeout to a higher value to see if that resolves the issue.
    2. It might be the case that your Azure active directory is lacking access to ADLS account where logs are supposed to be stored. Ensure that the pipeline has the necessary permissions to write logs to the location. Hope it helps. Kindly accept the answer if it is helpful else revert back with followup queries. Thankyou

Your answer

Answers can be marked as Accepted Answers by the question author, which helps users to know the answer solved the author's problem.