none
Event type is not recognized

    Question

  • Good day!

    First time get error like this:

     Event type 'cep:/Server/Application/CEP_App/EventType/Microsoft.ComplexEventProcessing.PrimitivePayload`1[[System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089]], Microsoft.ComplexEventProcessing, Version=12.0.0.0, Culture=neutral, PublicKeyToken=89845dcd8080cc91' is not recognized.
    Parameter name: typeName
       at Microsoft.ComplexEventProcessing.Diagnostics.Exceptions.Throw(Exception exception)
       at Microsoft.ComplexEventProcessing.EmbeddedServerProxy.Create(XmlReader definition, Uri parentName)
       at Microsoft.ComplexEventProcessing.Server.CreateCepObject(CepObject obj)
       at Microsoft.ComplexEventProcessing.Application.CreateQueryTemplate(XmlReader queryTextReader, CepStreamSnapshot snapshot)
       at Microsoft.ComplexEventProcessing.Application.CreateQueryTemplate(String queryTemplateName, String description, CepStreamSnapshot snapshot)
       at Microsoft.ComplexEventProcessing.Application.CreateQuery[TPayload](String queryName, String queryDescription, CepStreamSnapshot snapshot, CepStreamConsumer`1 consumer, Boolean isResilient)
       at Microsoft.ComplexEventProcessing.Linq.CepStream`1.ToQuery(Application application, String queryName, String description, Type adapterFactoryType, Object adapterConfig, EventShape eventShape, StreamEventOrder eventOrder)
       at VimpelCom.Theseus.WinService.ProcessHandler.Process()

    InnerException - Event type 'cep:/Server/Application/CEP_App/EventType/Microsoft.ComplexEventProcessing.PrimitivePayload`1[[System.String, mscorlib, Version=4.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089]], Microsoft.ComplexEventProcessing, Version=12.0.0.0, Culture=neutral, PublicKeyToken=89845dcd8080cc91' is not recognized.
    Parameter name: typeName
       at Microsoft.ComplexEventProcessing.Diagnostics.Exceptions.Throw(Exception exception)
       at Microsoft.ComplexEventProcessing.Expressions.TypeService.GetRuntimeType(Uri typeName)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeImportOperator.OnAlgebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeOperator.Algebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeOperator.OnAlgebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeJoin.OnAlgebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeOperator.Algebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeOperator.OnAlgebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeGroupAndApply.OnAlgebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeOperator.Algebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeOperator.OnAlgebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeProject.OnAlgebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeOperator.Algebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeOperator.OnAlgebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeExportOperator.OnAlgebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeQueryTemplate.OnAlgebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.CompileNodeQueryTemplate.Algebrize(CompileContext context, QueryBindingInfo queryBindingInfo)
       at Microsoft.ComplexEventProcessing.Compiler.Compiler.ParseCreateAny(XmlReader reader)
       at Microsoft.ComplexEventProcessing.CommandDispatcher.CommandDispatcher.Create(XmlReader definition, Uri parent)
       at Microsoft.ComplexEventProcessing.EmbeddedServerProxy.Create(XmlReader definition, Uri parentName)

    What does it mean? What should I do?

     

    Maybe it happens when trying to run this code, because it down after this row in log file:

    using System;  using System.Collections.Generic;  using Microsoft.ComplexEventProcessing;  using Microsoft.ComplexEventProcessing.Linq;  using Vimpelcom.Theseus.StreamInsight;  namespace QueryLibrary { class Query {  public object GetStream(object args)  {   var streams = (List<object>)args;   var nrtrde = (CepStream<Payload>)streams[0];   var cepApp = (Application) streams[1];     var stubDateTime = DateTime.Now;     var tapHotNumbers = new List<string> {"123456"};
              CepStream<string> taps = tapHotNumbers.ToIntervalStream(cepApp,    e => IntervalEvent.CreateInsert(DateTimeOffset.MinValue, DateTimeOffset.MaxValue, e), AdvanceTimeSettings.IncreasingStartTime);     var stream = from n in nrtrde     from t in taps    where n.FieldInt1 == 17    where n.FieldString1 == t || n.FieldString3 == t    group n by n.FieldString into grouped    from window in grouped.TumblingWindow(TimeSpan.FromMinutes(1), HoppingWindowOutputPolicy.ClipToWindowEnd)    select new Payload    {     FieldDateTime = stubDateTime,     FieldDateTime1 = stubDateTime,     FieldInt = 0,     FieldInt1 = 0,     FieldInt2 = 0,     FieldInt3 = 0,     FieldInt4 = 0,     FieldInt5 = 0,     FieldLong = window.Count(),     FieldLong1 = 0,     FieldLong2 = 0,     FieldLong3 = 0,     FieldLong4 = 0,     FieldLong5 = 0,     FieldString = grouped.Key,     FieldString1 = String.Empty,     FieldString2 = String.Empty,     FieldString3 = String.Empty,     FieldString4 = String.Empty,     FieldString5 = String.Empty    };   return stream;  }}}
    Monday, October 10, 2011 1:47 AM

Answers

  • I resigned from that company where I worked with technology StreamInsight, so you can close all of my questions.
    Thanks to all for help me in cognition this interesting technology.
    Good luck!
    Wednesday, November 30, 2011 9:41 AM

All replies

  • First of all, please use the coding syntax. This is very hard to read. And in the second step, can you show your payload class type, too.

     

    Monday, October 10, 2011 7:22 AM
  • Hello!

    I wrote a specially no code block as I have stored this source code in the database, because it might be this problem.

    using System;
    using System.Collections.Generic;
    using Microsoft.ComplexEventProcessing;
    using Microsoft.ComplexEventProcessing.Linq;
    namespace QueryLibrary
    {
    	class Query
    	{
    		public object GetStream(object args)
    		{
    			var streams = (List<object>)args;
    			var nrtrde = (CepStream<Payload>)streams[0];
    			var cepApp = (Application)streams[1];
    			var stubDateTime = DateTime.Now;
    			var tapHotNumbers = new List<string> { "123456" };
    			CepStream<string> taps = tapHotNumbers.ToIntervalStream(cepApp, e =>
    				IntervalEvent.CreateInsert(DateTimeOffset.MinValue, DateTimeOffset.MaxValue, e),
    				AdvanceTimeSettings.IncreasingStartTime);
    
    			var stream = from n in nrtrde
    						 from t in taps
    						 where n.FieldInt1 == 17
    						 where n.FieldString1 == t || n.FieldString3 == t
    						 group n by n.FieldString into grouped
    						 from window in grouped.TumblingWindow(TimeSpan.FromMinutes(1), HoppingWindowOutputPolicy.ClipToWindowEnd)
    						 select new Payload
    						 {
    							 FieldDateTime = stubDateTime,
    							 FieldDateTime1 = stubDateTime,
    							 FieldInt = 0,
    							 FieldInt1 = 0,
    							 FieldInt2 = 0,
    							 FieldInt3 = 0,
    							 FieldInt4 = 0,
    							 FieldInt5 = 0,
    							 FieldLong = window.Count(),
    							 FieldLong1 = 0,
    							 FieldLong2 = 0,
    							 FieldLong3 = 0,
    							 FieldLong4 = 0,
    							 FieldLong5 = 0,
    							 FieldString = grouped.Key,
    							 FieldString1 = String.Empty,
    							 FieldString2 = String.Empty,
    							 FieldString3 = String.Empty,
    							 FieldString4 = String.Empty,
    							 FieldString5 = String.Empty
    						 }; return stream;
    		}
    	}
    }


    using System; namespace StreamInsight { public class Payload { public Int64 FieldLong { get; set; } public Int64 FieldLong1 { get; set; } public Int64 FieldLong2 { get; set; } public Int64 FieldLong3 { get; set; } public Int64 FieldLong4 { get; set; } public Int64 FieldLong5 { get; set; } public int FieldInt { get; set; } public int FieldInt1 { get; set; } public int FieldInt2 { get; set; } public int FieldInt3 { get; set; } public int FieldInt4 { get; set; } public int FieldInt5 { get; set; } public string FieldString { get; set; } public string FieldString1 { get; set; } public string FieldString2 { get; set; } public string FieldString3 { get; set; } public string FieldString4 { get; set; } public string FieldString5 { get; set; } public DateTime FieldDateTime { get; set; } public DateTime FieldDateTime1 { get; set; } } }
    Monday, October 10, 2011 7:41 AM
  • You have an aggregate/window query without using any aggregate functions and referencing fields that are not part of the aggregate. I think that this is your core issue. What are you trying to do with this query?
    DevBiker (aka J Sawyer)
    My Blog

    If I answered your question, please mark as answer.
    If my post was helpful, please mark as helpful.
    Tuesday, October 11, 2011 5:18 PM
    Moderator
  • Do you still have this issue? otherwise I'll mark the thread as answered.

    Roman


    MS StreamInsight Team

    Disclaimer: This posting is provided "AS IS" with no warranties, and confers no rights.
    Wednesday, November 30, 2011 8:27 AM
  • I resigned from that company where I worked with technology StreamInsight, so you can close all of my questions.
    Thanks to all for help me in cognition this interesting technology.
    Good luck!
    Wednesday, November 30, 2011 9:41 AM