Skip to main content
cancel
Showing results for 
Search instead for 
Did you mean: 

The 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.

Reply
Jcolucci09
Regular Visitor

Internal Error DirectQueryUnexpectedEndOfStream.

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)

1 REPLY 1
jennratten
Super User
Super User

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

Helpful resources

Announcements
Feb2025 Sticker Challenge

Join our Community Sticker Challenge 2025

If you love stickers, then you will definitely want to check out our Community Sticker Challenge!

Jan NL Carousel

Fabric Community Update - January 2025

Find out what's new and trending in the Fabric community.

Top Solution Authors
Top Kudoed Authors