Хранилище данных Azure: ошибка Polybase при загрузке из внешней таблицы (хранилище больших двоичных объектов)
Я получаю ошибку ниже при выполнении CTAS из внешнего стола в Azure Data Warehouse, Внешняя таблица указывает на хранилище BLOB-объектов.
Данные в хранилище BLOB-объектов выводятся Stream Analytics работа каждые 10 секунд (TumblingWindow(секунда, 10)). Я только начал получать эту ошибку, когда объем данных значительно увеличился.
Я предполагаю, что это связано с тем, что самый последний файл BLOB обновляется во время выполнения задания, и что ETAG изменился Если это так, то какой подход следует использовать для загрузки файлов, которые меняются?
Если это не так, то что не так?
System.Data.SqlClient.SqlException (0x80131904): com.microsoft.azure.storage.StorageException: условие, указанное с помощью условных заголовков HTTP, не выполнено. Файл: '/eventsoutfullv2/logs/2018/01/18/16/526834440_7808fc2c79eb481ba8a4bf4f8d6555f9_1.csv', идентификаторы запросов: '7b03dff8-001e-0008-617b-908f56000000000000000000006006000080000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000-e-mail -057b-90a33e000000, 1398f50e-001e-0024-207b-900d6b000000, 7b03e49f-001e-0008-367b-908f56000000, bd1cbb9a-001e-0018-407b-90b9b00000000001-b-0000-b-100 -5e7b-90b9b0000000, e085113c-001e-0011-267b-90a33e000000'
в System.Data.SqlClient.SqlConnection.OnError(исключение SqlException, логическое breakConnection, Action1 wrapCloseInAction) в System.Data.SqlClient.SqlInternalConnection.OnError(исключение SqlException, Boolean. breakConnection.ar. (TdsParserStateObject stateObj, булева callerHasConnectionLock, булева asyncClose) при System.Data.SqlClient.TdsParser.TryRun(RunBehavior runBehavior, SqlCommand cmdHandler, SqlDataReader DATASTREAM, BulkCopySimpleResultSet bulkCopyHandler, TdsParserStateObject stateObj, булевой & dataReady) в System.Data.SqlClient.SqlDataReader.TryConsumeMetaData() в System.Data.SqlClient.SqlDataReader.get_MetaData() в System.Data.SqlClient.SqlCommand.FinishExecuteReader(SqlDataReader ds, RunBehavior runBehavior, строка String resetOptionsSt. Boolean isInternal, логическое значение для DescribeParameterEncryption) в System.Data.SqlClient.SqlCommand.InternalEndExecuteReader(IAsyncResult AsyncResult, Струнный endMethod, Boolean IsInternal) в System.Data.SqlClient.SqlCommand.EndExecuteReaderInternal(IAsyncResult AsyncResult) в System.Data.SqlClient.SqlCommand.EndExecuteReaderAsync(IAsyncResult AsyncResult) в System.Threading.Tasks.TaskFactory1.FromAsyncCoreLogic(функция IAsyncResult, функция endcunction Func2, операция action1 end, обещание задачи 1, логическое значение требует синхронизации)