Hi All
The scenario we have a concern is with regard to tenant inactivation. We
noticed that the analytic scripts which are scheduled to run by tenant
user, keep running even after relavant tenant has been inactivated.
Is this the expected behaviour
Below are part of the relevant log from receiver node in which the tenant
was inactivated and the analyser node in which the analytic scripts are
executed.
*Receiver node *
TID: [9] [] [2015-10-21 13:05:37,499] @abc.com [9] [DAS] INFO
{org.wso2.carbon.core.services.authentication.AuthenticationAdmin} - '
[email protected] [9]' logged out at [2015-10-21 13:05:37,0499]
{org.wso2.carbon.core.services.authentication.AuthenticationAdmin}
TID: [-1234] [] [2015-10-21 13:05:43,522] INFO
{org.wso2.carbon.core.services.util.CarbonAuthenticationUtil} -
'[email protected] [-1234]' logged in at [2015-10-21 13:05:43,522+0000]
{org.wso2.carbon.core.services.util.CarbonAuthenticationUtil}
TID: [9] [] [*2015-10-21 13:06:12,116*] @abc.com [9] [DAS] INFO
{org.wso2.carbon.core.multitenancy.utils.TenantAxisUtils} - *Starting to
clean tenant : abc.com <http://abc.com> *
{org.wso2.carbon.core.multitenancy.utils.TenantAxisUtils}
*Analyser node*
TID: [9] [] [2015-10-21 13:30:25,926] @abc.com [9] [DAS] INFO
{org.wso2.carbon.core.
multitenancy.utils.TenantAxisUtils} - Starting to clean tenant : abc.com
{org.wso2.carbon.core.multitenancy.utils.TenantAxisUtils}
TID: [9] [] [2015-10-21* 13:30:25,941*] @abc.com [9] [DAS] INFO
{org.wso2.carbon.core.multitenancy.utils.TenantAxisUtils} -* Cleaned up
tenant abc.com <http://abc.com> *
{org.wso2.carbon.core.multitenancy.utils.TenantAxisUtils}
Time Elapsed: 0.015 seconds.
{org.wso2.carbon.analytics.spark.core.internal.SparkAnalyticsExecutor}
TID: [9] [] [2015-10-21 *13:31:04,084*] @abc.com [9] [DAS] INFO
{org.wso2.carbon.analytics.spark.core.internal.SparkAnalyticsExecutor} -
Executed query: insert overwrite table HighTrafficCountry select
countryName,countryCode,req_count From (select
CAST(toCountryName(first(remoteIp)) As STRING) as countryName,
CAST(toCountryCode(first(remoteIp)) As STRING) as countryCode,
count(*) as req_count from HttpLogTable group by
toCountryName(remoteIp), toCountryCode(remoteIp))tmp where req_count > 100
ORDER BY req_count DESC
Time Elapsed: 1.81 seconds.
{org.wso2.carbon.analytics.spark.core.internal.SparkAnalyticsExecutor}
TID: [9] [] [2015-10-21 13:31:04,102] @abc.com [9] [DAS] INFO
{org.wso2.carbon.analytics.spark.core.internal.SparkAnalyticsExecutor} -
Executed query: CREATE TEMPORARY TABLE LowTrafficCountry USING
CarbonAnalytics OPTIONS (tableName
"HTTPD_COUNTRY_LOW_TRAFFIC", schema "countryName STRING, countryCode
STRING, req_count INT", primaryKeys "countryName, countryCode")
Time Elapsed: 0.015 seconds.
{org.wso2.carbon.analytics.spark.core.internal.SparkAnalyticsExecutor}
TID: [9] [] [2015-10-21 *13:45:00,004*] @abc.com [9] [DAS] INFO
{org.wso2.carbon.analytics.spark.core.AnalyticsTask} - Executing the
schedule task for: httpd_log_analytics for tenant id: 9
{org.wso2.carbon.analytics.spark.core.AnalyticsTask}
Regards,
Shavantha Weerasinghe
Senior Software Engineer QA
WSO2, Inc.
lean.enterprise.middleware.
http://wso2.com
http://wso2.org
Tel : 94 11 214 5345
Fax :94 11 2145300
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
