Giter VIP home page Giter VIP logo

analytics-solutions's People

Contributors

ambujaa10 avatar anugayan avatar dilini-muthumala avatar dnwick avatar erangatl avatar grainier avatar isharailanga avatar ksdperera avatar lahirurajapaksha avatar lakshanss avatar lasanthas avatar minudika avatar mohanvive avatar nisalaniroshana avatar niveathika avatar pamodaaw avatar pcnfernando avatar ramindu90 avatar raveensr avatar rolandhewage avatar ruwiniwj avatar sajithshn avatar sandalu95 avatar shilmyhasan avatar tanyam avatar tharindu-b-hewage avatar this avatar thisaruguruge avatar tishan89 avatar wso2-jenkins-bot avatar

Stargazers

 avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar

Watchers

 avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar  avatar

analytics-solutions's Issues

[IS Analytics] Inaccurate merging of rows in RoleAggregation & AuthStat Aggregation tables as 'identityProviderType' not being used as a group by field

Description:
There is a field called 'identityProviderType' in AuthStat Aggregation tables. This field gets a 'NULL' value in a single sign on situation while a user is already logged in from one app & try to login to another app. This field gets the value 'LOCAL' or 'FEDERATED' in other situations. The issue comes when data is persisted in higher level aggregation tables like hours, days, months etc... Where for a given username, serviceProvider, identityProvider, region, userStoreDomain, isFirstLogin fields which were the primary key fields there are situations where identityProviderType gets a value 'NULL' or something else & merge rows to form a single row which cause inaccurate counts. This is caused because 'identityProviderType' is not used as a group by field in SP based aggregation tables which was a primary key field in the identical old DAS based tables.

Suggested Assignees:
@RolandHewage

Affected Product Version:
IS 5.6.0, IS Analytics 5.6.0 & IS 5.7.0, IS Analytics 5.7.0

OS, DB, other environment details and versions:
MySQL 5.7.25
Java 1.8.0_191

Steps to reproduce:

  1. Follow quick start guide related with IS 5.7.0 documentation
  2. Select Single Sign On Scenario
  3. Try 4 failure attempts to pickup-manager app
  4. Make a successful login to pickup-dispatch app
  5. Try single sign on by login pickup-manager app
  6. See AuthStatAgg aggregation tables from SECONDS level to higher
  7. The field identityProviderType gets NULL in a single sign on situation
  8. This field gets an inaccurate value by merging rows in higher level aggregation tables

[APIM Analytics] siddhi-io-mgwfile

Description:

  1. License header not added for MGWFileSource
  2. Siddhi Extension annotation not filled(description, parameter, and example )
  3. Source parameter not validated (Line 65. the validateAndGetStaticValue(String optionkey) must be called. After which a isEmpty check is carried out)

Suggested Assignees:
@shilmyhasan

[IS Analytics] StoreQueryException in the filter when a date range is not selected

Description:
When the filter is used without selecting a data range first, following error can be seen.

`[2018-09-10 15:48:19,940] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error found in method : org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 76, near 'tion("Hand'. Stream with reference : null not found
[2018-09-10 15:48:19,953] INFO {org.wso2.siddhi.core.aggregation.IncrementalDataPurging} - Data purging has enabled for tables: SECONDS,MINUTES,HOURS,DAYS, with an interval of 900 seconds in AuthenticationStatAggregation aggregation
[2018-09-10 15:48:19,958] INFO {org.wso2.siddhi.core.aggregation.IncrementalDataPurging} - Data purging has enabled for tables: SECONDS,MINUTES,HOURS,DAYS, with an interval of 900 seconds in RoleAggregation aggregation
[2018-09-10 15:48:19,960] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error initializing the data provider endpoint for source type SiddhiStoreDataProvider. Error @ Line: 1. Position: 76, near 'tion("Hand'. Stream with reference : null not found org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 76, near 'tion("Hand'. Stream with reference : null not found
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:335)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:310)
at org.wso2.carbon.data.provider.siddhi.SiddhiProvider.init(SiddhiProvider.java:79)
at org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint.onMessage(DataProviderEndPoint.java:111)
at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.executeMethod(MSF4JWSConnectorListener.java:359)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.lambda$handleTextWebSocketMessage$61(MSF4JWSConnectorListener.java:193)
at java.util.Optional.ifPresent(Optional.java:159)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.handleTextWebSocketMessage(MSF4JWSConnectorListener.java:174)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.onMessage(MSF4JWSConnectorListener.java:87)
at org.wso2.transport.http.netty.contractimpl.HttpWsServerConnectorFuture.notifyWSListener(HttpWsServerConnectorFuture.java:115)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.notifyTextMessage(WebSocketSourceHandler.java:198)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.channelRead(WebSocketSourceHandler.java:167)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at org.wso2.transport.http.netty.listener.WebSocketServerHandshakeHandler.channelRead(WebSocketServerHandshakeHandler.java:100)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at org.wso2.transport.http.netty.listener.UriAndHeaderLengthValidator.channelRead(UriAndHeaderLengthValidator.java:68)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1336)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1127)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1162)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:489)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:428)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1359)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:935)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:645)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:580)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:497)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.wso2.siddhi.query.api.exception.SiddhiAppValidationException: Error on 'IS_ANALYTICS_AUTHENTICATION_AGGREGATIONS' @ Line: 1. Position: 76, near 'tion("Hand'. Stream with reference : null not found
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseVariable(ExpressionParser.java:1346)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:308)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseInnerExpression(ExpressionParser.java:1423)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:422)
at org.wso2.siddhi.core.aggregation.AggregationRuntime.compileExpression(AggregationRuntime.java:296)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.constructStoreQueryRuntime(StoreQueryParser.java:257)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.parse(StoreQueryParser.java:149)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:325)
... 56 more

[2018-09-10 15:48:19,961] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error found in method : org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 76, near 'tion("Hand'. Stream with reference : null not found
`

Suggested Labels:

Suggested Assignees:

Affected Product Version:

OS, DB, other environment details and versions:

Steps to reproduce:

Related Issues:

[IS Analytics] Unclear widget names

Description:
There are 2 widgets names as IsAnalyticsAreaChart and IsAnalyticsHorizontalBarChart.
These should be renamed to increase user-friendliness.

Suggested Labels:
Type/Improvement

Suggested Assignees:
@ThisaruGuruge

EI-Analytics Filter widget publishingWidgetConfigs is not added making it impossible to wire to a generated widget

Description:
$subject.
Filter widget publishes selectedComponet[1] to the other widgets but since the configs are not there this cannot be wired to a generated widget.

[1] https://github.com/wso2/analytics-solutions/blob/master/components/ei-analytics/org.wso2.analytics.solutions.ei.analytics/widgets/EIAnalyticsSearchBox/src/EIAnalyticsSearchBox.jsx#L405

Affected Product Version:
SP4.3.0 onwards

Steps to reproduce:

  1. Generate a widget
  2. Subscribe to filter
  3. Try to change the filter

Remove redundant logic to reset data before database call

Description:

In the analytic dashboard widgets, there was an issue, in which when the data is not returned from the database, the callback function was not executed in the WidgetChannelManager. This is now fixed and the redundant logic to reset data before the database call should be removed from the widgets.

Suggested Assignees:

@isharailanga @Ambujaa10

[EI-Analytics] In the aggregation itself the average can be calculated rather than when reading

Description:
$subject
Before:

define aggregation MediatorStatAgg
from PreProcessedMediatorStatStream
 select metaTenantId, entryPoint, entryPointHashcode, componentId, hashCode, componentName, componentType, **sum(duration) as totalDuration**, min(duration) as minDuration, max(duration) as maxDuration, **count() as noOfInvocation**, sum(faultCount) as faultCount, startTime
	group by metaTenantId, componentId, componentName, componentType, entryPoint, entryPointHashcode, hashCode
	aggregate by startTime every sec...years;

After:

from PreProcessedMediatorStatStream
 select metaTenantId, entryPoint, entryPointHashcode, componentId, hashCode, componentName, componentType, **avg(duration) as avgDuration**, min(duration) as minDuration, max(duration) as maxDuration, sum(faultCount) as faultCount, startTime
	group by metaTenantId, componentId, componentName, componentType, entryPoint, entryPointHashcode, hashCode
	aggregate by startTime every sec...years;

Suggested Labels:
Type/Task

As only the definition in siddhi apps would change and not internal tables, severity is minor.

[APIM Analytics] Is Cassandra store supported ?

Hi,
I want to change the store type to Cassandra.
Currently the store used is of type rdbms.

APIM 2.5.6 doc : https://docs.wso2.com/display/AM260/Configuring+APIM+Analytics#StandardSetup
The following is a list of database versions that are compatible with WSO2 API-M Analytics.

  • Postgres 9.5 and later
  • MySQL 5.6
  • MySQL 5.7
  • Oracle 12c
  • MS SQL Server 2012
  • DB2

I want to change the @store(type = 'rdbms', datasource = 'APIM_ANALYTICS_DB') on all siddhi-files (https://github.com/wso2/analytics-solutions/tree/master/features/apim-analytics-feature/org.wso2.analytics.solutions.apim.analytics.feature/src/main/resources/siddhi-files)

with a Store type Cassandra, but I did not find in the doc how to do : https://docs.wso2.com/display/SP430/Defining+Tables+for+Physical+Stores

There is a Cassandra implementation : https://github.com/wso2-extensions/siddhi-store-cassandra

wso2-stream-processor-graphical-editor-http-message-trace-analytics-and-more-30-638

Thanks
Youcef HILEM

[APIM Analytics][SP] Throughput bottleneck in APIM_ACCESS_SUMMARY Siddhi Application.

Description:
In the APIM_ACCESS_SUMMARY Siddhi application, we have identified the throughput bottleneck when updating the last API access time in 'ApiLastAccessSummary' table. According to the current logic, each and every event in Request stream left outer join with the ApiLastAccessSummary table.

If the event found in the table, it will check whether the timestamp in input event with the table value and only output the event from that query if it is greater than the existing value. After that each out prom this query update or insert into the same table again.

So, each request there were multiple databases connections initialise and as a result, whole throughput performance of the AMIP analytics solution degrades.

Issue:

-- Filter the event with the most recent request timestamp
from Request as R left outer join ApiLastAccessSummary as S
on R.apiName == S.apiName and R.apiCreatorTenantDomain == S.apiCreatorTenantDomain and R.apiCreator == S.apiCreator
select R.apiContext, R.apiName, R.apiVersion, R.apiCreator, R.apiCreatorTenantDomain, R.applicationOwner, R.requestTimestamp as lastAccessTime
having R.requestTimestamp >= S.lastAccessTime or S.lastAccessTime is null
insert into ApiLastAccessStream;

from ApiLastAccessStream
select apiContext, apiName, apiVersion, apiCreator,apiCreatorTenantDomain, applicationOwner, lastAccessTime
update or insert into ApiLastAccessSummary
set ApiLastAccessSummary.apiContext = apiContext, ApiLastAccessSummary.apiVersion = apiVersion, ApiLastAccessSummary.applicationOwner = applicationOwner, ApiLastAccessSummary.lastAccessTime = lastAccessTime
on ApiLastAccessSummary.apiName == apiName and ApiLastAccessSummary.apiCreatorTenantDomain == apiCreatorTenantDomain and ApiLastAccessSummary.apiCreator == apiCreator;

Solution:
Introduce 1 sec timeBatch on Request stream, before event send to the 'Filter the event with the most recent request timestamp' query.

-- Filter the event with the most recent request timestamp

from Request#window.timeBatch(1 sec)
select apiContext, apiName, apiVersion, apiCreator, apiCreatorTenantDomain, applicationOwner, max(requestTimestamp) as requestTimestamp
group by apiContext, apiCreatorTenantDomain, apiCreator
insert into RequestInterm;

from RequestInterm as R left outer join ApiLastAccessSummary as S
on R.apiName == S.apiName and R.apiCreatorTenantDomain == S.apiCreatorTenantDomain and R.apiCreator == S.apiCreator
select R.apiContext, R.apiName, R.apiVersion, R.apiCreator, R.apiCreatorTenantDomain, R.applicationOwner, R.requestTimestamp as lastAccessTime
having R.requestTimestamp >= S.lastAccessTime or S.lastAccessTime is null
insert into ApiLastAccessStream;

from ApiLastAccessStream
select apiContext, apiName, apiVersion, apiCreator,apiCreatorTenantDomain, applicationOwner, lastAccessTime
update or insert into ApiLastAccessSummary
set ApiLastAccessSummary.apiContext = apiContext, ApiLastAccessSummary.apiVersion = apiVersion, ApiLastAccessSummary.applicationOwner = applicationOwner, ApiLastAccessSummary.lastAccessTime = lastAccessTime
on ApiLastAccessSummary.apiName == apiName and ApiLastAccessSummary.apiCreatorTenantDomain == apiCreatorTenantDomain and ApiLastAccessSummary.apiCreator == apiCreator;

Suggested Labels:

Suggested Assignees:

Affected Product Version:
APIM 2.6.0

OS, DB, other environment details and versions:

Steps to reproduce:

  1. Remove the alert applications
  2. Do a perf testing with high TPS like > 500
  3. You'll observe the Event Queue Full log in the APIM node

Related Issues:

[APIM Analytics][SP] Handling Production and Sandbox traffics in analytics

Description:

Scenario:

  1. User create Application.
  2. Create production and sandbox key for the same application.
  3. Then there's two separate consumer keys for same application.

Do not have to way to separately taken the two aggregation of production and sandbox, since app_id used in grouping condition not the consumer_key.

The Distributed Message Tracer List Widget fails to show data

Description:
The Distributed Message Tracer's List Widget fails to load data. This is due to the table created by Siddhi having camel case column names while the widget expects the data to have upper case column names. This causes the widget to fail to show the data in the table.

Suggested Labels:
Type/Bug

Suggested Assignees:
@ramindu90, @ksdperera

Affected Product Version:
SP 4.2.x, SP 4.3.0

OS, DB, other environment details and versions:
N/A

Steps to reproduce:

  • Setup the Stream Processor and point to an external DB (eg:- MySQL).
  • Run the Message Tracer and publish data into it.
  • Open the dashboard and open the Distributed Message Tracer.
  • Click Search to load data.
  • Notice that the table is not populated and there are errors in the browser console.

Related Issues:
N/A

[IS Analytics] Store query exception

Description:
Store query exception occurs in overall login attempts UI

`[2018-09-05 09:49:16,737] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error initializing the data provider endpoint for source type SiddhiStoreDataProvider. Error @ Line: 1. Position: 151, near 'on") defi'. Stream with reference : null not found org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 151, near 'on") defi'. Stream with reference : null not found
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:332)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:307)
at org.wso2.carbon.data.provider.siddhi.SiddhiProvider.init(SiddhiProvider.java:78)
at org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint.onMessage(DataProviderEndPoint.java:111)
at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.executeMethod(MSF4JWSConnectorListener.java:359)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.lambda$handleTextWebSocketMessage$61(MSF4JWSConnectorListener.java:193)
at java.util.Optional.ifPresent(Optional.java:159)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.handleTextWebSocketMessage(MSF4JWSConnectorListener.java:174)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.onMessage(MSF4JWSConnectorListener.java:87)
at org.wso2.transport.http.netty.contractimpl.HttpWsServerConnectorFuture.notifyWSListener(HttpWsServerConnectorFuture.java:115)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.notifyTextMessage(WebSocketSourceHandler.java:198)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.channelRead(WebSocketSourceHandler.java:167)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at org.wso2.transport.http.netty.listener.WebSocketServerHandshakeHandler.channelRead(WebSocketServerHandshakeHandler.java:100)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at org.wso2.transport.http.netty.listener.UriAndHeaderLengthValidator.channelRead(UriAndHeaderLengthValidator.java:68)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1336)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1127)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1162)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:489)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:428)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1359)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:935)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:645)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:580)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:497)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.wso2.siddhi.query.api.exception.SiddhiAppValidationException: Error on 'IS_ANALYTICS_AUTHENTICATION_AGGREGATIONS' @ Line: 1. Position: 151, near 'on") defi'. Stream with reference : null not found
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseVariable(ExpressionParser.java:1346)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:308)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:258)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:241)
at org.wso2.siddhi.core.util.parser.OperatorParser.constructOperator(OperatorParser.java:89)
at org.wso2.siddhi.core.aggregation.AggregationRuntime.compileExpression(AggregationRuntime.java:310)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.constructStoreQueryRuntime(StoreQueryParser.java:257)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.parse(StoreQueryParser.java:149)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:322)
... 56 more

[2018-09-05 09:49:16,785] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error found in method : org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 151, near 'on") defi'. Stream with reference : null not found
[2018-09-05 09:49:16,810] INFO {org.wso2.siddhi.core.aggregation.IncrementalDataPurging} - Data purging has enabled for table: SECONDS,MINUTES,HOURS,DAYS, with an interval of 900 seconds
[2018-09-05 09:49:16,815] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error initializing the data provider endpoint for source type SiddhiStoreDataProvider. Error @ Line: 1. Position: 86, near 'e Event f'. Stream with reference : null not found org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 86, near 'e Event f'. Stream with reference : null not found
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:332)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:307)
at org.wso2.carbon.data.provider.siddhi.SiddhiProvider.init(SiddhiProvider.java:78)
at org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint.onMessage(DataProviderEndPoint.java:111)
at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.executeMethod(MSF4JWSConnectorListener.java:359)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.lambda$handleTextWebSocketMessage$61(MSF4JWSConnectorListener.java:193)
at java.util.Optional.ifPresent(Optional.java:159)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.handleTextWebSocketMessage(MSF4JWSConnectorListener.java:174)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.onMessage(MSF4JWSConnectorListener.java:87)
at org.wso2.transport.http.netty.contractimpl.HttpWsServerConnectorFuture.notifyWSListener(HttpWsServerConnectorFuture.java:115)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.notifyTextMessage(WebSocketSourceHandler.java:198)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.channelRead(WebSocketSourceHandler.java:167)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at org.wso2.transport.http.netty.listener.WebSocketServerHandshakeHandler.channelRead(WebSocketServerHandshakeHandler.java:100)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at org.wso2.transport.http.netty.listener.UriAndHeaderLengthValidator.channelRead(UriAndHeaderLengthValidator.java:68)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1336)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1127)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1162)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:489)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:428)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1359)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:935)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:645)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:580)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:497)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.wso2.siddhi.query.api.exception.SiddhiAppValidationException: Error on 'IS_ANALYTICS_AUTHENTICATION_AGGREGATIONS' @ Line: 1. Position: 86, near 'e Event f'. Stream with reference : null not found
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseVariable(ExpressionParser.java:1346)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:308)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:258)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:241)
at org.wso2.siddhi.core.util.parser.OperatorParser.constructOperator(OperatorParser.java:89)
at org.wso2.siddhi.core.aggregation.AggregationRuntime.compileExpression(AggregationRuntime.java:310)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.constructStoreQueryRuntime(StoreQueryParser.java:257)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.parse(StoreQueryParser.java:149)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:322)
... 56 more

[2018-09-05 09:49:16,822] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error found in method : org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 86, near 'e Event f'. Stream with reference : null not found
[2018-09-05 09:49:16,835] INFO {org.wso2.siddhi.core.aggregation.IncrementalDataPurging} - Data purging has enabled for table: SECONDS,MINUTES,HOURS,DAYS, with an interval of 900 seconds
[2018-09-05 09:49:16,837] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error initializing the data provider endpoint for source type SiddhiStoreDataProvider. Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:332)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:307)
at org.wso2.carbon.data.provider.siddhi.SiddhiProvider.init(SiddhiProvider.java:78)
at org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint.onMessage(DataProviderEndPoint.java:111)
at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.executeMethod(MSF4JWSConnectorListener.java:359)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.lambda$handleTextWebSocketMessage$61(MSF4JWSConnectorListener.java:193)
at java.util.Optional.ifPresent(Optional.java:159)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.handleTextWebSocketMessage(MSF4JWSConnectorListener.java:174)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.onMessage(MSF4JWSConnectorListener.java:87)
at org.wso2.transport.http.netty.contractimpl.HttpWsServerConnectorFuture.notifyWSListener(HttpWsServerConnectorFuture.java:115)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.notifyTextMessage(WebSocketSourceHandler.java:198)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.channelRead(WebSocketSourceHandler.java:167)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at org.wso2.transport.http.netty.listener.WebSocketServerHandshakeHandler.channelRead(WebSocketServerHandshakeHandler.java:100)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at org.wso2.transport.http.netty.listener.UriAndHeaderLengthValidator.channelRead(UriAndHeaderLengthValidator.java:68)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1336)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1127)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1162)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:489)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:428)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1359)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:935)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:645)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:580)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:497)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.wso2.siddhi.query.api.exception.SiddhiAppValidationException: Error on 'IS_ANALYTICS_AUTHENTICATION_AGGREGATIONS' @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseVariable(ExpressionParser.java:1346)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:308)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:258)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:241)
at org.wso2.siddhi.core.util.parser.OperatorParser.constructOperator(OperatorParser.java:89)
at org.wso2.siddhi.core.aggregation.AggregationRuntime.compileExpression(AggregationRuntime.java:310)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.constructStoreQueryRuntime(StoreQueryParser.java:257)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.parse(StoreQueryParser.java:149)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:322)
... 56 more

[2018-09-05 09:49:16,839] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error found in method : org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
[2018-09-05 09:49:16,848] INFO {org.wso2.siddhi.core.aggregation.IncrementalDataPurging} - Data purging has enabled for table: SECONDS,MINUTES,HOURS,DAYS, with an interval of 900 seconds
[2018-09-05 09:49:16,848] INFO {org.wso2.siddhi.core.aggregation.IncrementalDataPurging} - Data purging has enabled for table: SECONDS,MINUTES,HOURS,DAYS, with an interval of 900 seconds
[2018-09-05 09:49:16,850] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error initializing the data provider endpoint for source type SiddhiStoreDataProvider. Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:332)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:307)
at org.wso2.carbon.data.provider.siddhi.SiddhiProvider.init(SiddhiProvider.java:78)
at org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint.onMessage(DataProviderEndPoint.java:111)
at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.executeMethod(MSF4JWSConnectorListener.java:359)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.lambda$handleTextWebSocketMessage$61(MSF4JWSConnectorListener.java:193)
at java.util.Optional.ifPresent(Optional.java:159)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.handleTextWebSocketMessage(MSF4JWSConnectorListener.java:174)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.onMessage(MSF4JWSConnectorListener.java:87)
at org.wso2.transport.http.netty.contractimpl.HttpWsServerConnectorFuture.notifyWSListener(HttpWsServerConnectorFuture.java:115)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.notifyTextMessage(WebSocketSourceHandler.java:198)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.channelRead(WebSocketSourceHandler.java:167)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at org.wso2.transport.http.netty.listener.WebSocketServerHandshakeHandler.channelRead(WebSocketServerHandshakeHandler.java:100)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at org.wso2.transport.http.netty.listener.UriAndHeaderLengthValidator.channelRead(UriAndHeaderLengthValidator.java:68)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1336)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1127)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1162)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:489)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:428)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1359)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:935)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:645)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:580)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:497)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.wso2.siddhi.query.api.exception.SiddhiAppValidationException: Error on 'IS_ANALYTICS_AUTHENTICATION_AGGREGATIONS' @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseVariable(ExpressionParser.java:1346)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:308)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:258)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:241)
at org.wso2.siddhi.core.util.parser.OperatorParser.constructOperator(OperatorParser.java:89)
at org.wso2.siddhi.core.aggregation.AggregationRuntime.compileExpression(AggregationRuntime.java:310)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.constructStoreQueryRuntime(StoreQueryParser.java:257)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.parse(StoreQueryParser.java:149)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:322)
... 56 more

[2018-09-05 09:49:16,851] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error found in method : org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
[2018-09-05 09:49:16,862] INFO {org.wso2.siddhi.core.aggregation.IncrementalDataPurging} - Data purging has enabled for table: SECONDS,MINUTES,HOURS,DAYS, with an interval of 900 seconds
[2018-09-05 09:49:16,865] INFO {org.wso2.siddhi.core.aggregation.IncrementalDataPurging} - Data purging has enabled for table: SECONDS,MINUTES,HOURS,DAYS, with an interval of 900 seconds
[2018-09-05 09:49:16,867] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error initializing the data provider endpoint for source type SiddhiStoreDataProvider. Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:332)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:307)
at org.wso2.carbon.data.provider.siddhi.SiddhiProvider.init(SiddhiProvider.java:78)
at org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint.onMessage(DataProviderEndPoint.java:111)
at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.executeMethod(MSF4JWSConnectorListener.java:359)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.lambda$handleTextWebSocketMessage$61(MSF4JWSConnectorListener.java:193)
at java.util.Optional.ifPresent(Optional.java:159)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.handleTextWebSocketMessage(MSF4JWSConnectorListener.java:174)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.onMessage(MSF4JWSConnectorListener.java:87)
at org.wso2.transport.http.netty.contractimpl.HttpWsServerConnectorFuture.notifyWSListener(HttpWsServerConnectorFuture.java:115)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.notifyTextMessage(WebSocketSourceHandler.java:198)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.channelRead(WebSocketSourceHandler.java:167)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at org.wso2.transport.http.netty.listener.WebSocketServerHandshakeHandler.channelRead(WebSocketServerHandshakeHandler.java:100)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at org.wso2.transport.http.netty.listener.UriAndHeaderLengthValidator.channelRead(UriAndHeaderLengthValidator.java:68)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1336)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1127)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1162)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:489)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:428)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1359)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:935)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:645)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:580)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:497)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.wso2.siddhi.query.api.exception.SiddhiAppValidationException: Error on 'IS_ANALYTICS_AUTHENTICATION_AGGREGATIONS' @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseVariable(ExpressionParser.java:1346)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:308)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:258)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:241)
at org.wso2.siddhi.core.util.parser.OperatorParser.constructOperator(OperatorParser.java:89)
at org.wso2.siddhi.core.aggregation.AggregationRuntime.compileExpression(AggregationRuntime.java:310)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.constructStoreQueryRuntime(StoreQueryParser.java:257)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.parse(StoreQueryParser.java:149)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:322)
... 56 more

[2018-09-05 09:49:16,868] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error found in method : org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
[2018-09-05 09:49:16,877] INFO {org.wso2.siddhi.core.aggregation.IncrementalDataPurging} - Data purging has enabled for table: SECONDS,MINUTES,HOURS,DAYS, with an interval of 900 seconds
[2018-09-05 09:49:16,879] INFO {org.wso2.siddhi.core.aggregation.IncrementalDataPurging} - Data purging has enabled for table: SECONDS,MINUTES,HOURS,DAYS, with an interval of 900 seconds
[2018-09-05 09:49:16,880] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error initializing the data provider endpoint for source type SiddhiStoreDataProvider. Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:332)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:307)
at org.wso2.carbon.data.provider.siddhi.SiddhiProvider.init(SiddhiProvider.java:78)
at org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint.onMessage(DataProviderEndPoint.java:111)
at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.executeMethod(MSF4JWSConnectorListener.java:359)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.lambda$handleTextWebSocketMessage$61(MSF4JWSConnectorListener.java:193)
at java.util.Optional.ifPresent(Optional.java:159)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.handleTextWebSocketMessage(MSF4JWSConnectorListener.java:174)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.onMessage(MSF4JWSConnectorListener.java:87)
at org.wso2.transport.http.netty.contractimpl.HttpWsServerConnectorFuture.notifyWSListener(HttpWsServerConnectorFuture.java:115)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.notifyTextMessage(WebSocketSourceHandler.java:198)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.channelRead(WebSocketSourceHandler.java:167)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at org.wso2.transport.http.netty.listener.WebSocketServerHandshakeHandler.channelRead(WebSocketServerHandshakeHandler.java:100)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at org.wso2.transport.http.netty.listener.UriAndHeaderLengthValidator.channelRead(UriAndHeaderLengthValidator.java:68)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1336)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1127)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1162)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:489)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:428)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1359)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:935)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:645)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:580)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:497)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.wso2.siddhi.query.api.exception.SiddhiAppValidationException: Error on 'IS_ANALYTICS_AUTHENTICATION_AGGREGATIONS' @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseVariable(ExpressionParser.java:1346)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:308)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:258)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:241)
at org.wso2.siddhi.core.util.parser.OperatorParser.constructOperator(OperatorParser.java:89)
at org.wso2.siddhi.core.aggregation.AggregationRuntime.compileExpression(AggregationRuntime.java:310)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.constructStoreQueryRuntime(StoreQueryParser.java:257)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.parse(StoreQueryParser.java:149)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:322)
... 56 more

[2018-09-05 09:49:16,881] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error found in method : org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
[2018-09-05 09:49:16,886] INFO {org.wso2.siddhi.core.aggregation.IncrementalDataPurging} - Data purging has enabled for table: SECONDS,MINUTES,HOURS,DAYS, with an interval of 900 seconds
[2018-09-05 09:49:16,889] INFO {org.wso2.siddhi.core.aggregation.IncrementalDataPurging} - Data purging has enabled for table: SECONDS,MINUTES,HOURS,DAYS, with an interval of 900 seconds
[2018-09-05 09:49:16,890] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error initializing the data provider endpoint for source type SiddhiStoreDataProvider. Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:332)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:307)
at org.wso2.carbon.data.provider.siddhi.SiddhiProvider.init(SiddhiProvider.java:78)
at org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint.onMessage(DataProviderEndPoint.java:111)
at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.executeMethod(MSF4JWSConnectorListener.java:359)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.lambda$handleTextWebSocketMessage$61(MSF4JWSConnectorListener.java:193)
at java.util.Optional.ifPresent(Optional.java:159)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.handleTextWebSocketMessage(MSF4JWSConnectorListener.java:174)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.onMessage(MSF4JWSConnectorListener.java:87)
at org.wso2.transport.http.netty.contractimpl.HttpWsServerConnectorFuture.notifyWSListener(HttpWsServerConnectorFuture.java:115)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.notifyTextMessage(WebSocketSourceHandler.java:198)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.channelRead(WebSocketSourceHandler.java:167)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at org.wso2.transport.http.netty.listener.WebSocketServerHandshakeHandler.channelRead(WebSocketServerHandshakeHandler.java:100)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at org.wso2.transport.http.netty.listener.UriAndHeaderLengthValidator.channelRead(UriAndHeaderLengthValidator.java:68)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1336)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1127)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1162)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:489)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:428)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1359)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:935)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:645)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:580)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:497)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.wso2.siddhi.query.api.exception.SiddhiAppValidationException: Error on 'IS_ANALYTICS_AUTHENTICATION_AGGREGATIONS' @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseVariable(ExpressionParser.java:1346)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:308)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:258)
at org.wso2.siddhi.core.util.parser.ExpressionParser.parseExpression(ExpressionParser.java:241)
at org.wso2.siddhi.core.util.parser.OperatorParser.constructOperator(OperatorParser.java:89)
at org.wso2.siddhi.core.aggregation.AggregationRuntime.compileExpression(AggregationRuntime.java:310)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.constructStoreQueryRuntime(StoreQueryParser.java:257)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.parse(StoreQueryParser.java:149)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:322)
... 56 more

[2018-09-05 09:49:16,891] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error found in method : org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 85, near 'le Event '. Stream with reference : null not found
[2018-09-05 09:49:16,894] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error initializing the data provider endpoint for source type SiddhiStoreDataProvider. Error @ Line: 1. Position: 145, near 'ion") def'. Cannot find attribute type as 'undefined' does not exist in 'OverallAuthenticationTable'; @store( type = 'rdbms', datasource = 'IS_ANALYTICS_DB')@PrimaryKey( 'meta_tenantId', 'contextId', 'eventId', 'eventType', 'region')define table OverallAuthenticationTable (meta_tenantId int, contextId string, eventId string, eventType string, authenticationSuccess bool, username string, localUsername string, userStoreDomain string, tenantDomain string, remoteIp string, region string, inboundAuthType string, serviceProvider string, rememberMeEnabled bool, forceAuthEnabled bool, passiveAuthEnabled bool, rolesCommaSeparated string, authenticationStep string, identityProvider string, authStepSuccess bool, stepAuthenticator string, isFirstLogin bool, identityProviderType string, utcTime string, timestamp long) Input Stream: OverallAuthenticationTable with reference: null org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 145, near 'ion") def'. Cannot find attribute type as 'undefined' does not exist in 'OverallAuthenticationTable'; @store( type = 'rdbms', datasource = 'IS_ANALYTICS_DB')@PrimaryKey( 'meta_tenantId', 'contextId', 'eventId', 'eventType', 'region')define table OverallAuthenticationTable (meta_tenantId int, contextId string, eventId string, eventType string, authenticationSuccess bool, username string, localUsername string, userStoreDomain string, tenantDomain string, remoteIp string, region string, inboundAuthType string, serviceProvider string, rememberMeEnabled bool, forceAuthEnabled bool, passiveAuthEnabled bool, rolesCommaSeparated string, authenticationStep string, identityProvider string, authStepSuccess bool, stepAuthenticator string, isFirstLogin bool, identityProviderType string, utcTime string, timestamp long) Input Stream: OverallAuthenticationTable with reference: null
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:332)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:307)
at org.wso2.carbon.data.provider.siddhi.SiddhiProvider.init(SiddhiProvider.java:78)
at org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint.onMessage(DataProviderEndPoint.java:111)
at sun.reflect.GeneratedMethodAccessor6.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.executeMethod(MSF4JWSConnectorListener.java:359)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.lambda$handleTextWebSocketMessage$61(MSF4JWSConnectorListener.java:193)
at java.util.Optional.ifPresent(Optional.java:159)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.handleTextWebSocketMessage(MSF4JWSConnectorListener.java:174)
at org.wso2.msf4j.internal.MSF4JWSConnectorListener.onMessage(MSF4JWSConnectorListener.java:87)
at org.wso2.transport.http.netty.contractimpl.HttpWsServerConnectorFuture.notifyWSListener(HttpWsServerConnectorFuture.java:115)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.notifyTextMessage(WebSocketSourceHandler.java:198)
at org.wso2.transport.http.netty.listener.WebSocketSourceHandler.channelRead(WebSocketSourceHandler.java:167)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at org.wso2.transport.http.netty.listener.WebSocketServerHandshakeHandler.channelRead(WebSocketServerHandshakeHandler.java:100)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at org.wso2.transport.http.netty.listener.UriAndHeaderLengthValidator.channelRead(UriAndHeaderLengthValidator.java:68)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:86)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:310)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:284)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.handler.ssl.SslHandler.unwrap(SslHandler.java:1336)
at io.netty.handler.ssl.SslHandler.decodeJdkCompatible(SslHandler.java:1127)
at io.netty.handler.ssl.SslHandler.decode(SslHandler.java:1162)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:489)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:428)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1359)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:935)
at io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:134)
at io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:645)
at io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:580)
at io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:497)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:459)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:858)
at io.netty.util.concurrent.DefaultThreadFactory$DefaultRunnableDecorator.run(DefaultThreadFactory.java:138)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.wso2.siddhi.query.api.exception.SiddhiAppValidationException: Error on 'IS_ANALYTICS_AUTHENTICATION_OVERALL' @ Line: 1. Position: 145, near 'ion") def'. Cannot find attribute type as 'undefined' does not exist in 'OverallAuthenticationTable'; @store( type = 'rdbms', datasource = 'IS_ANALYTICS_DB')@PrimaryKey( 'meta_tenantId', 'contextId', 'eventId', 'eventType', 'region')define table OverallAuthenticationTable (meta_tenantId int, contextId string, eventId string, eventType string, authenticationSuccess bool, username string, localUsername string, userStoreDomain string, tenantDomain string, remoteIp string, region string, inboundAuthType string, serviceProvider string, rememberMeEnabled bool, forceAuthEnabled bool, passiveAuthEnabled bool, rolesCommaSeparated string, authenticationStep string, identityProvider string, authStepSuccess bool, stepAuthenticator string, isFirstLogin bool, identityProviderType string, utcTime string, timestamp long) Input Stream: OverallAuthenticationTable with reference: null
at org.wso2.siddhi.core.table.record.ExpressionBuilder.buildVariableExecutors(ExpressionBuilder.java:335)
at org.wso2.siddhi.core.table.record.ExpressionBuilder.buildVariableExecutors(ExpressionBuilder.java:133)
at org.wso2.siddhi.core.table.record.ExpressionBuilder.buildVariableExecutors(ExpressionBuilder.java:106)
at org.wso2.siddhi.core.table.record.ExpressionBuilder.build(ExpressionBuilder.java:94)
at org.wso2.extension.siddhi.store.rdbms.RDBMSEventTable.compileCondition(RDBMSEventTable.java:750)
at org.wso2.siddhi.core.table.record.AbstractRecordTable.compileCondition(AbstractRecordTable.java:358)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.constructStoreQueryRuntime(StoreQueryParser.java:314)
at org.wso2.siddhi.core.util.parser.StoreQueryParser.parse(StoreQueryParser.java:143)
at org.wso2.siddhi.core.SiddhiAppRuntime.getStoreQueryOutputAttributes(SiddhiAppRuntime.java:322)
... 56 more

[2018-09-05 09:49:16,895] ERROR {org.wso2.carbon.data.provider.endpoint.DataProviderEndPoint} - Error found in method : org.wso2.siddhi.core.exception.StoreQueryCreationException: Error @ Line: 1. Position: 145, near 'ion") def'. Cannot find attribute type as 'undefined' does not exist in 'OverallAuthenticationTable'; @store( type = 'rdbms', datasource = 'IS_ANALYTICS_DB')@PrimaryKey( 'meta_tenantId', 'contextId', 'eventId', 'eventType', 'region')define table OverallAuthenticationTable (meta_tenantId int, contextId string, eventId string, eventType string, authenticationSuccess bool, username string, localUsername string, userStoreDomain string, tenantDomain string, remoteIp string, region string, inboundAuthType string, serviceProvider string, rememberMeEnabled bool, forceAuthEnabled bool, passiveAuthEnabled bool, rolesCommaSeparated string, authenticationStep string, identityProvider string, authStepSuccess bool, stepAuthenticator string, isFirstLogin bool, identityProviderType string, utcTime string, timestamp long) Input Stream: OverallAuthenticationTable with reference: null
`

Steps to reproduce:

  1. Go to overall login attempts page.
  2. Filter with username By all
  3. Filter with username By first login
  4. Again filter with username By all

[EI-Analytics] - EI_Analytics_StatApp.siddhi error when purging query

Description:
In the following query 'time:dateSub(triggered_time, 2, 'week')' returns the String type, but its then evaluate in the delete on condition with the long type attribute 'ConfigEntryTable.eventTimestamp'

from    TablePurgingTriggerStream
select  time:dateSub(triggered_time, 2, 'week') as purgingTime
delete  ConfigEntryTable
on      ConfigEntryTable.eventTimestamp < purgingTime;

Suggested Labels:

Suggested Assignees:

Affected Product Version:
wso2 EI Analytics-6.4

OS, DB, other environment details and versions:

Steps to reproduce:

  1. wso2 EI Analytics-6.4 package (EI + Analytics worker)
  2. EI_Analytics_StatApp.siddhi file is just "out of the box"; we use postgres for datasources
  3. Error performing record deletion on table 'ConfigEntryTable': Batch entry 0 DELETE FROM ConfigEntryTable WHERE (ConfigEntryTable.eventTimestamp < '1548194400031' ) was aborted: ERROR: operator does not exist: bigint < character varying
    Hint: No operator matches the given name and argument type(s). You might need to add explicit type casts.

Related Issues:

[EIAnalytics] EIAnalyticsHorizontalBarChart widget shows data only from the ''MINUTE'' aggregation

Description:
"EIAnalyticsHorizontalBarChart" widget's fetch query is hardcoded to "minute" granularity although the Date Time Range Filter consists of a granularity selector.

Suggested Labels:

Suggested Assignees:

Affected Product Version:
WSO2 EI 6.4.0

OS, DB, other environment details and versions:
N/A

Steps to reproduce:

  1. Setup the Analytics profile of WSO2 Enterprise Integrator (WSO2 EI) 6.4.0
  2. Start the ESB profile & publish some data
  3. Start the Analytics dashboard
  4. Go to the Overview section
  5. Notice that the horizontal barcharts of the Top Proxy Server by Request Count, Top APIs by Request Count, Top Endpoints by Request Count, Top Sequence by Request Count, Top Inbound Endpoint by Request Count sections doesn't change according to the interval (eg. hour, day, month) selected by the Date Time Range Filter.

Related Issues:
N/A

[EI Analytics] When selecting time span selection option, dashboard server backend throws exception

Description:
Error on '0dc4be3f-ece4-4591-94df-7fd88731c147'. Invalid input given to dateFormat(timestampInMilliseconds,dateTargetFormat) function. First argument cannot be null Exception on class 'org.wso2.extension.siddhi.execution.time.DateFormatFunctionExtension'. org.wso2.siddhi.core.exception.SiddhiAppRuntimeException: Invalid input given to dateFormat(timestampInMilliseconds,dateTargetFormat) function. First argument cannot be null
at org.wso2.extension.siddhi.execution.time.DateFormatFunctionExtension.execute(DateFormatFunctionExtension.java:234)
at org.wso2.siddhi.core.executor.function.FunctionExecutor.execute(FunctionExecutor.java:109)
at org.wso2.siddhi.core.query.selector.attribute.processor.AttributeProcessor.process(AttributeProcessor.java:41)
at org.wso2.siddhi.core.query.selector.QuerySelector.processInBatchGroupBy(QuerySelector.java:309)
at org.wso2.siddhi.core.query.selector.QuerySelector.process(QuerySelector.java:84)
at org.wso2.siddhi.core.query.FindStoreQueryRuntime.reset(FindStoreQueryRuntime.java:119)
at org.wso2.siddhi.core.SiddhiAppRuntime.query(SiddhiAppRuntime.java:284)
at org.wso2.siddhi.core.SiddhiAppRuntime.query(SiddhiAppRuntime.java:266)
at org.wso2.carbon.data.provider.siddhi.SiddhiProvider.publish(SiddhiProvider.java:125)
at org.wso2.carbon.data.provider.AbstractDataProvider.lambda$start$0(AbstractDataProvider.java:74)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)

Suggested Labels:
EI

Affected Product Version:
4.3.0-Beta
OS, DB, other environment details and versions:
MySQL, Linux

[IS Analytics] Buttons and Text Fields are getting jumbled in widgets

Description:

In IS Analytics User Preferences and IS Analytics Login AttemptsMap widgets, Buttons and the text input fields are getting jumbled when loading. [See attached screenshot]

screen shot 2018-09-11 at 6 06 50 pm

This happens when the two widgets:

  • IsAnalyticsLoginAttemptsMap
  • IsAnalyticsUserPreferences

are loaded. This is due to a naming conflict in material-ui. (Check related issue)

Suggested Assignees:

@ThisaruGuruge

Steps to reproduce:

Create a dashboard with IS Analytics User Preferences widget and IS Analytics Login Attempts Map widget.

Related Issues:

marmelab/react-admin#1782

[IS Analytics] Overall Login Attempt Summary based on authStepSuccessCount eventhough it was implemented based on old DAS logic which uses authSuccessCount

Description:
The 'overall login attempt summary' in the new SP based IS Analytics dashboard is based on 'authStepSuccessCount'. But in a single sign on situation this field never increment eventhough its a login attempt made. In the old DAS based IS Analytics this was based on 'authSuccessCount'. This issue was clearly seen for identical use case scenarios tested on DAS & SP based IS Analytics dashboards. They showed different counts. As in the definition it should be the final result of a collection of authentication steps (A collection of authentication steps is considered as an overall attempt). So in a multifactored authentication situation this 'Overall login attempt count should be incremented by one eventhough it passes a no. of steps in a single login attempt. 'authSuccessCount' field behave in such a manner.

Suggested Assignees:
@RolandHewage

Affected Product Version:
IS 5.6.0, IS Analytics 5.6.0 & IS 5.7.0, IS Analytics 5.7.0

OS, DB, other environment details and versions:
MySQL 5.7.25
Java 1.8.0_191

Steps to reproduce:

  1. Follow the quickstart guide related with IS 5.6.0 & 5.7.0 documentation
  2. Try out identical use case flows with IS Analytics 5.6.0 & IS Analytics 5.7.0 to generate an identical data set & compare the dashboard results shown for the same flow
  3. They are different

Error when connecting to Mysql RDBMS

Description:
APIM analytics 2.6.0 gives following error when connecting to MYSQL (5.7) with character set utf8.

Unable to initialize table 'APIM_ReqCountAgg_HOURS': Specified key was too long; max key length is 3072 bytes
at org.wso2.extension.siddhi.store.rdbms.RDBMSEventTable.connect(RDBMSEventTable.java:882)
at org.wso2.siddhi.core.table.Table.connectWithRetry(Table.java:364)
at org.wso2.siddhi.core.table.Table$1.run(Table.java:376)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.wso2.extension.siddhi.store.rdbms.exception.RDBMSTableException: Unable to initialize table 'APIM_ReqCountAgg_HOURS': Specified key was too long; max key length is 3072 bytes

Suggested Labels:

Suggested Assignees:

Affected Product Version: APIM Analytics 2.6.0

OS, DB, other environment details and versions:
MYSQL 5.7 with utf8 character set.

Steps to reproduce:
Coonect Analytics server to MYSQL DB with utf8 character set enabled.

Related Issues:

[EI Analytics] Changes in chart types and widget titles

Description:
The following changes should be done in the EI analytics dashboard.

  1. Following charts should be line charts. Bar charts are not suitable in this particular scenario.

screen shot 2018-09-11 at 12 33 39 am

  1. Widget titles should be changed as follows.
    "OVERALL EIAnalyticsTPS" -> "OVERALL TPS"
    "[Overall Message Count]" -> "OVERALL MESSAGE COUNT"

Please refer to this doc for examples.

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    ๐Ÿ–– Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. ๐Ÿ“Š๐Ÿ“ˆ๐ŸŽ‰

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google โค๏ธ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.