报错信息如下:
GrapeCity.Enterprise.DataService.DataWarehouse.Facade.DataWarehouseException: [DW] Failed to create data file.
---> System.IO.EndOfStreamException: Expected to read 39 payload bytes but only received 35.
at MySqlConnector.Protocol.Serialization.ProtocolUtility.<DoReadPayloadAsync>g__AddContinuation|5_0(ValueTask`1 readPacketTask, BufferedByteReader bufferedByteReader, IByteHandler byteHandler, Func`1 getNextSequenceNumber, ArraySegmentHolder`1 previousPayloads, ProtocolErrorBehavior protocolErrorBehavior, IOBehavior ioBehavior) in /_/src/MySqlConnector/Protocol/Serialization/ProtocolUtility.cs:line 480
at MySqlConnector.Core.ServerSession.ReceiveReplyAsyncAwaited(ValueTask`1 task) in /_/src/MySqlConnector/Core/ServerSession.cs:line 956
at MySqlConnector.Core.ResultSet.<ScanRowAsync>g__ScanRowAsyncAwaited|9_0(ResultSet resultSet, Task`1 payloadTask, Row row, CancellationToken token) in /_/src/MySqlConnector/Core/ResultSet.cs:line 244
at MySqlConnector.Core.ResultSet.ReadAsync(IOBehavior ioBehavior, CancellationToken cancellationToken) in /_/src/MySqlConnector/Core/ResultSet.cs:line 215
at MySqlConnector.Core.ResultSet.Read() in /_/src/MySqlConnector/Core/ResultSet.cs:line 191
at GrapeCity.Enterprise.Data.DataSource.Common.SqlExecutor.SourceTable.<>c__DisplayClass25_0.<<LoadFromReaderImpl>g__IterateOnly|1>d.MoveNext()
at System.Linq.Lookup`2.CreateForJoin(IEnumerable`1 source, Func`2 keySelector, IEqualityComparer`1 comparer)
at System.Linq.Enumerable.GroupJoinIterator[TOuter,TInner,TKey,TResult](IEnumerable`1 outer, IEnumerable`1 inner, Func`2 outerKeySelector, Func`2 innerKeySelector, Func`3 resultSelector, IEqualityComparer`1 comparer)+MoveNext()
at System.Linq.Enumerable.SelectManyIterator[TSource,TCollection,TResult](IEnumerable`1 source, Func`2 collectionSelector, Func`3 resultSelector)+MoveNext()
at System.Linq.Enumerable.SelectEnumerableIterator`2.MoveNext()
at System.Linq.Lookup`2.Create(IEnumerable`1 source, Func`2 keySelector, IEqualityComparer`1 comparer)
at System.Linq.GroupedEnumerable`2.GetEnumerator()
at System.Linq.Enumerable.SelectEnumerableIterator`2.MoveNext()
at System.Linq.Enumerable.SelectIterator[TSource,TResult](IEnumerable`1 source, Func`3 selector)+MoveNext()
at GrapeCity.Enterprise.DataService.DataWarehouse.DuckDB.EnumerableExt.Partition[T](IEnumerable`1 input, Int32 blockSize)+MoveNext()
at GrapeCity.Enterprise.DataService.DataWarehouse.DuckDB.ParquetDuckDbDataWarehouse.CreateNewDataFileAsync(String filePath, ISourceData sourceData)
at GrapeCity.Enterprise.DataService.DataWarehouse.DuckDB.ParquetDuckDbDataWarehouse.CreateNewDataFileAsync(String filePath, ISourceData sourceData)
at GrapeCity.Enterprise.DataService.DataWarehouse.DuckDB.ParquetDuckDbDataWarehouse.CreateAsync(String tableName, ISourceData sourceData, UInt64 dataVersion)
--- End of inner exception stack trace ---
at GrapeCity.Enterprise.DataService.DataWarehouse.DuckDB.ParquetDuckDbDataWarehouse.CreateAsync(String tableName, ISourceData sourceData, UInt64 dataVersion)
at GrapeCity.Enterprise.Data.CacheWork.Processor.CommonCreateFullRefresh.CreateCacheWithDataAsync(CacheWorkReport report, ICacheWorkPayload payload, ISourceData sourceData)
|