Microsoft Fabric Community Conference 2025, March 31 - April 2, Las Vegas, Nevada. Use code MSCUST for a $150 discount.
Register nowThe Power BI DataViz World Championships are on! With four chances to enter, you could win a spot in the LIVE Grand Finale in Las Vegas. Show off your skills.
Can anyone help me with the following error I'm getting:
Unexpected error: Internal error DirectQueryUnexpectedEndOfStream.
Details:
Microsoft.Mashup.Evaluator.Interface.ErrorException: Internal error DirectQueryUnexpectedEndOfStream. ---> Microsoft.ServicePlatform.Exceptions.Common.Runtime.ValidationFailedException: Internal error DirectQueryUnexpectedEndOfStream. ---> Microsoft.ServicePlatform.Exceptions.Common.Runtime.ValidationFailedException: Internal error DirectQueryUnexpectedEndOfStream.
at Microsoft.ServicePlatform.Exceptions.Core.Check.ThrowValidationFailedException(ServicePlatformErrorCode errorCode,MessageClass messageClass,Object[] messageParameters)
at Microsoft.Dataflows.Core.Platform.Transport.ReadWithCertaintyStream.Read(Byte[] buffer,Int32 offset,Int32 count)
at Microsoft.PowerBI.DataMovement.Pipeline.OleDbBase.Serialization.PageReader.Read(Byte[] buffer,Int32 offset,Int32 count)
at Microsoft.PowerBI.DataMovement.Pipeline.OleDbBase.Serialization.PageReader.Read(Void* dst,Int32 length)
at Microsoft.PowerBI.DataMovement.Pipeline.OleDbBase.Serialization.PageReader.ReadArray(UInt64[] values,Int32 offset,Int32 count)
at Microsoft.PowerBI.DataMovement.Pipeline.OleDbBase.Serialization.ColumnsPage.Deserialize(PageReader reader)
at Microsoft.Dataflows.Core.Platform.Transport.PagingDataReader.ReadNewPage()
at Microsoft.Dataflows.Core.Platform.Transport.PagingDataReader.Read()
at Microsoft.Mashup.Engine1.Library.Common.TracingDbDataReader.Read()
at Microsoft.Mashup.Engine1.Library.Common.ProgressDbDataReader.Read()
at Microsoft.Mashup.Engine1.Library.Common.DbData+CachingDbDataReader+<>c__DisplayClass48_0.<WrappedRead>b__0()
at Microsoft.Mashup.Engine1.Library.Common.DbValueBuilder+PageCachingEnumerator.WrapWithTracingAndDbExceptionHandling(Action action)
at Microsoft.Mashup.Engine1.Library.Common.DbData+CachingDbDataReader.WrappedRead()
at Microsoft.Mashup.Engine1.Library.Common.DbData+CachingDbDataReader.Read()
at Microsoft.Mashup.Engine1.Library.Common.DbValueBuilder+PageCachingEnumerator.MoveNext()
at Microsoft.Mashup.Engine1.Runtime.SkipTakeEnumerator`1.MoveNext()
at Microsoft.Mashup.Engine1.Library.Common.DbValueBuilder+PagingEnumerator.MoveNext()
at Microsoft.Mashup.Engine1.Runtime.SkipTakeEnumerator`1.MoveNext()
at Microsoft.Mashup.Engine1.Language.Query.SelectRowsQuery+SelectRowsEnumerable+SelectRowsEnumerator.MoveNext()
at Microsoft.Mashup.Engine1.Library.Table.TableModule+Table+ErrorSelectingTableValue+ErrorFilteringEnumerator.MoveNext()
at Microsoft.Mashup.Engine1.Language.Query.SelectRowsQuery+SelectRowsEnumerable+SelectRowsEnumerator.MoveNext()
at Microsoft.Mashup.Engine1.Language.Query.DistinctQuery+DistinctEnumerable+DistinctEnumerator.MoveNext()
at Microsoft.Mashup.Engine1.Language.Query.DistinctQuery+DistinctEnumerable+DistinctEnumerator.MoveNext()
at Microsoft.Mashup.Engine1.Language.Query.DistinctQuery+DistinctEnumerable+DistinctEnumerator.MoveNext()
at Microsoft.Mashup.Engine1.Language.Query.CombineQuery+CombineEnumerable+CombineEnumerator.MoveNext()
at Microsoft.Mashup.Engine1.Language.Query.DistinctQuery+DistinctEnumerable+DistinctEnumerator.MoveNext()
at Microsoft.Mashup.Engine1.Language.Query.JoinAlgorithm+JoinPrologue.Read(JoinParameters parameters,Boolean readLeft,Boolean readRight)
at Microsoft.Mashup.Engine1.Language.Query.JoinAlgorithm+DynamicJoinAlgorithm+DynamicJoinEnumerable.GetEnumerator()
at Microsoft.Mashup.Engine1.Language.Query.ProjectColumnsQuery+SelectColumnsEnumerable.GetEnumerator()
at Microsoft.Mashup.Engine1.Language.Query.ProjectColumnsQuery+SelectColumnsEnumerable.GetEnumerator()
at Microsoft.Mashup.Engine1.Language.Query.JoinAlgorithm+JoinPrologue.Read(JoinParameters parameters,Boolean readLeft,Boolean readRight)
at Microsoft.Mashup.Engine1.Language.Query.JoinAlgorithm+DynamicJoinAlgorithm+DynamicJoinEnumerable.GetEnumerator()
at Microsoft.Mashup.Engine1.Language.Query.DistinctQuery+DistinctEnumerable.GetEnumerator()
at Microsoft.Mashup.Engine1.Language.Query.SelectRowsQuery+SelectRowsEnumerable.GetEnumerator()
at Microsoft.Mashup.Engine1.Language.Query.SkipTakeEnumerable.GetEnumerator()
at Microsoft.Mashup.Engine1.Language.Query.ProjectColumnsQuery+SelectColumnsEnumerable.GetEnumerator()
at Microsoft.Mashup.Engine1.Language.Query.QueryTableValue.GetEnumerator()
at Microsoft.Mashup.Engine1.Runtime.TableValue.Microsoft.Mashup.Engine.Interface.ITableValue.GetEnumerator()
at Microsoft.Mashup.Evaluator.SimpleDocumentEvaluator+ValuePreviewValueSource+TableValuePreviewValueSource.SerializeRows(Int32 count)
at Microsoft.Mashup.Evaluator.SimpleDocumentEvaluator+ValuePreviewValueSource+TableValuePreviewValueSource.get_SmallValue()
at Microsoft.Mashup.Evaluator.Interface.TracingPreviewValueSource.get_SmallValue()
at Microsoft.Mashup.Evaluator.RemotePreviewValueSource+<>c__DisplayClass0_0.<RunStub>b__0()
at Microsoft.Mashup.Evaluator.EvaluationHost.ReportExceptions(String entryName,IEngineHost engineHost,IMessageChannel channel,Action action)
at Microsoft.Mashup.Evaluator.RemoteDocumentEvaluator+Service+<>c__DisplayClass12_0`1.<OnBeginGetResult>b__0()
at Microsoft.Mashup.Evaluator.EvaluationHost.ReportExceptions(IHostTrace trace,IEngineHost engineHost,IMessageChannel channel,Action action)
at Microsoft.Mashup.Evaluator.RemoteDocumentEvaluator+Service.OnBeginGetResult(IMessageChannel channel,BeginGetResultMessage message,Action`1 action)
at Microsoft.Mashup.Evaluator.RemoteDocumentEvaluator+Service.OnBeginGetPreviewValueSource(IMessageChannel channel,BeginGetPreviewValueSourceMessage message)
at Microsoft.Mashup.Evaluator.MessageHandlers.TryDispatch(IMessageChannel channel,Message message)
at Microsoft.Mashup.Evaluator.ChannelMessenger+ChannelMessageHandlers.TryDispatch(IMessageChannel channel,Message message)
at Microsoft.Mashup.Evaluator.MessageHandlers.Dispatch(IMessageChannel channel,Message message)
at Microsoft.Mashup.Evaluator.ChannelMessenger.OnMessageWithUnknownChannel(IMessageChannel baseChannel,MessageWithUnknownChannel messageWithUnknownChannel)
at Microsoft.Mashup.Evaluator.MessageHandlers.TryDispatch(IMessageChannel channel,Message message)
at Microsoft.Mashup.Evaluator.ChannelMessenger+ChannelMessageHandlers.TryDispatch(IMessageChannel channel,Message message)
at Microsoft.Mashup.Evaluator.MessageHandlers.Dispatch(IMessageChannel channel,Message message)
at Microsoft.Mashup.Evaluator.EvaluationHost.Run()
at Microsoft.Mashup.Container.EvaluationContainerMain.Run(Object args)
at Microsoft.Mashup.Evaluator.SafeThread2+<>c__DisplayClass9_0.<CreateAction>b__0(Object o)
at Microsoft.Mashup.Container.EvaluationContainerMain.SafeRun(String[] args)
at Microsoft.Mashup.Container.EvaluationContainerMain.Main(String[] args)
at System.RuntimeMethodHandle.InvokeMethod(Object target,Object[] arguments,Signature sig,Boolean constructor)
at System.Reflection.RuntimeMethodInfo.UnsafeInvokeInternal(Object obj,Object[] parameters,Object[] arguments)
at System.Reflection.RuntimeMethodInfo.Invoke(Object obj,BindingFlags invokeAttr,Binder binder,Object[] parameters,CultureInfo culture)
at Microsoft.Mashup.Container.Program.Main(String[] args)
--- End of inner exception stack trace ---
at Microsoft.Mashup.Evaluator.EvaluationHost.<>c__DisplayClass17_0.<TryReportException>b__1()
at Microsoft.Mashup.Common.SafeExceptions.IgnoreSafeExceptions(IEngineHost host, IHostTrace trace, Action action)
at Microsoft.Mashup.Evaluator.EvaluationHost.TryReportException(IHostTrace trace, IEngineHost engineHost, IMessageChannel channel, Exception exception)
at Microsoft.Mashup.Evaluator.EvaluationHost.ReportExceptions(String entryName, IEngineHost engineHost, IMessageChannel channel, Action action)
at Microsoft.Mashup.Evaluator.RemoteDocumentEvaluator.Service.<>c__DisplayClass12_0`1.<OnBeginGetResult>b__0()
at Microsoft.Mashup.Evaluator.EvaluationHost.ReportExceptions(IHostTrace trace, IEngineHost engineHost, IMessageChannel channel, Action action)
at Microsoft.Mashup.Evaluator.RemoteDocumentEvaluator.Service.OnBeginGetResult[T](IMessageChannel channel, BeginGetResultMessage message, Action`1 action)
at Microsoft.Mashup.Evaluator.RemoteDocumentEvaluator.Service.OnBeginGetPreviewValueSource(IMessageChannel channel, BeginGetPreviewValueSourceMessage message)
at Microsoft.Mashup.Evaluator.MessageHandlers.TryDispatch(IMessageChannel channel, Message message)
at Microsoft.Mashup.Evaluator.ChannelMessenger.ChannelMessageHandlers.TryDispatch(IMessageChannel channel, Message message)
at Microsoft.Mashup.Evaluator.MessageHandlers.Dispatch(IMessageChannel channel, Message message)
at Microsoft.Mashup.Evaluator.ChannelMessenger.OnMessageWithUnknownChannel(IMessageChannel baseChannel, MessageWithUnknownChannel messageWithUnknownChannel)
at Microsoft.Mashup.Evaluator.MessageHandlers.TryDispatch(IMessageChannel channel, Message message)
at Microsoft.Mashup.Evaluator.ChannelMessenger.ChannelMessageHandlers.TryDispatch(IMessageChannel channel, Message message)
at Microsoft.Mashup.Evaluator.MessageHandlers.Dispatch(IMessageChannel channel, Message message)
at Microsoft.Mashup.Evaluator.EvaluationHost.Run()
at Microsoft.Mashup.Container.EvaluationContainerMain.Run(Object args)
at Microsoft.Mashup.Evaluator.SafeThread2.<>c__DisplayClass9_0.<CreateAction>b__0(Object o)
at Microsoft.Mashup.Container.EvaluationContainerMain.SafeRun(String[] args)
at Microsoft.Mashup.Container.EvaluationContainerMain.Main(String[] args)
at System.RuntimeMethodHandle.InvokeMethod(Object target, Object[] arguments, Signature sig, Boolean constructor)
at System.Reflection.RuntimeMethodInfo.UnsafeInvokeInternal(Object obj, Object[] parameters, Object[] arguments)
at System.Reflection.RuntimeMethodInfo.Invoke(Object obj, BindingFlags invokeAttr, Binder binder, Object[] parameters, CultureInfo culture)
at Microsoft.Mashup.Container.Program.Main(String[] args)
--- End of inner exception stack trace ---
at Microsoft.Mashup.Evaluator.EvaluationHost.OnException(IEngineHost engineHost, IMessageChannel channel, ExceptionMessage message)
at Microsoft.Mashup.Evaluator.MessageHandlers.TryDispatch(IMessageChannel channel, Message message)
at Microsoft.Mashup.Evaluator.MessageHandlers.Dispatch(IMessageChannel channel, Message message)
at Microsoft.Mashup.Evaluator.ChannelMessenger.ChannelMessageHandlers.TryDispatch(IMessageChannel channel, Message message)
at Microsoft.Mashup.Evaluator.MessageHandlers.Dispatch(IMessageChannel channel, Message message)
at Microsoft.Mashup.Evaluator.Interface.IMessageChannelExtensions.WaitFor[T](IMessageChannel channel)
at Microsoft.Mashup.Evaluator.RemotePreviewValueSource.PreviewValueSource.WaitFor(Func`1 condition, Boolean disposing)
at Microsoft.Mashup.Evaluator.RemotePreviewValueSource.PreviewValueSource.get_SmallValue()
at Microsoft.Mashup.Evaluator.Interface.TracingPreviewValueSource.get_SmallValue()
at Microsoft.Mashup.Host.Document.Analysis.PackageDocumentAnalysisInfo.PackagePartitionAnalysisInfo.SetPreviewValue(EvaluationResult2`1 result, Func`1 getStaleSince, Func`1 getSampled)
llello - can you please provide some additional context so that we can help? Where are you getting this error? When does it happen? What are your data sources? Are those sources being refreshed when this error is received? If the dataset is in a PowerBI workspace, is that workspace backed by a premium capacity?
If this post helps to answer your questions, please consider marking it as a solution so others can find it more quickly when faced with a similar challenge.
Proud to be a Microsoft Fabric Super User