Sign in
 
Home20122008 R2200820052000LibraryForums
SQL Server >
> 
> 
Event type is not recognized

Answered Event type is not recognized

  • Monday, October 10, 2011 1:47 AM
     
     
    Sign In to Vote
    0

    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;  }}}
     

All Replies

  • Monday, October 10, 2011 7:22 AM
     
     
    Sign In to Vote
    0

    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:41 AM
     
      Has Code
    Sign In to Vote
    0

    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; }
	}
}
     
  • Tuesday, October 11, 2011 5:18 PM
     
     
    Sign In to Vote
    0
    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.
     
  • Wednesday, November 30, 2011 8:27 AM
     
     
    Sign In to Vote
    0

    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 9:41 AM
     
     Answered
    Sign In to Vote
    0
    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!