search

microsoft / TrillSamples

Sample applications to demonstrate how to use the Trill library and API
MIT License
169 stars 44 forks source link

Out-Of-Order events exception in PerformanceTest #10

Closed ismaelhamed closed 5 years ago

ismaelhamed commented 5 years ago

When running the PerformanceTest with more than 5M TotalInputEvents, I always get:

Caching the input dataset into main memory...

Unhandled Exception: Microsoft.StreamProcessing.StreamProcessingException: Out-of-order event received during Cache() call
   at Microsoft.StreamProcessing.RxReplacements.SynchronousForEachWorker`1.DoIt(IObservable`1 observable, Action`1 action) in D:\a\1\s\Sources\Core\Microsoft.StreamProcessing\Utilities\RxReplacements.cs:line 40
   at Microsoft.StreamProcessing.Streamable.Cache[TKey,TPayload](IStreamable`2 stream, UInt64 limit, Boolean inferProperties, Boolean coalesceEndEdges) in D:\a\1\s\Sources\Core\Microsoft.StreamProcessing\CacheUtilities\StreamableIO.cs:line 89
   at PerformanceTest.Program.Main(String[] args)
peterfreiling-zz commented 5 years ago

Thanks @ismaelhamed , this exposed a bug in Trill that has been fixed by https://github.com/Microsoft/Trill/pull/75. PR in TrillSamples that updates the Trill Nuget version with this fix - #11