I reproduced the error. If we set carbon.spark.master.count value to 2 this error will occur. Any solution available in this case?
On Thu, Dec 10, 2015 at 9:05 PM, Roshan Wijesena <ros...@wso2.com> wrote: > After I enabled the debug, it looks like below > > [2015-12-10 22:03:00,001] INFO > {org.wso2.carbon.analytics.spark.core.AnalyticsTask} - Executing the > schedule task for: httpd_log_analytics for tenant id: -1234 > [2015-12-10 22:03:00,013] DEBUG > {org.wso2.carbon.analytics.spark.core.internal.SparkAnalyticsExecutor} - > Executing : CREATE TEMPORARY TABLE X1234_HttpLogTable USING > org.wso2.carbon.analytics.spark.core.sources.AnalyticsRelationProvider > OPTIONS (tableName "ORG_WSO2_SAMPLE_HTTPD_LOGS" , tenantId "-1234") > [2015-12-10 22:03:00,013] ERROR > {org.wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter} - Error in > executing task: null > java.lang.NullPointerException > at > org.wso2.carbon.analytics.spark.core.internal.SparkAnalyticsExecutor.executeQueryLocal(SparkAnalyticsExecutor.java:710) > at > org.wso2.carbon.analytics.spark.core.internal.SparkAnalyticsExecutor.executeQuery(SparkAnalyticsExecutor.java:692) > at > org.wso2.carbon.analytics.spark.core.CarbonAnalyticsProcessorService.executeQuery(CarbonAnalyticsProcessorService.java:199) > at > org.wso2.carbon.analytics.spark.core.CarbonAnalyticsProcessorService.executeScript(CarbonAnalyticsProcessorService.java:149) > at > org.wso2.carbon.analytics.spark.core.AnalyticsTask.execute(AnalyticsTask.java:57) > at > org.wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter.execute(TaskQuartzJobAdapter.java:67) > at org.quartz.core.JobRunShell.run(JobRunShell.java:213) > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) > at java.util.concurrent.FutureTask.run(FutureTask.java:266) > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:745) > > does that query got modified? > > CREATE TEMPORARY TABLE X1234_HttpLogTable USING > org.wso2.carbon.analytics.spark.core.sources.AnalyticsRelationProvider > OPTIONS (tableName "ORG_WSO2_SAMPLE_HTTPD_LOGS" , tenantId "-1234") > > > > > > > On Thu, Dec 10, 2015 at 6:53 PM, Roshan Wijesena <ros...@wso2.com> wrote: > >> Hi DAS teaam, >> >> I am getting below null pointer exception while trying to execute a >> scheduled task. What I simply did was created a two node HA cluster and >> tried to run this example[1]. It has a scheduled task. However, this error >> can not be observed in a single node fresh pack. >> >> The error is, >> >> [2015-12-10 19:32:00,573] INFO >> {org.wso2.carbon.analytics.spark.core.AnalyticsTask} - Executing the >> schedule task for: httpd_log_analytics for tenant id: -1234 >> [2015-12-10 19:32:21,899] INFO >> {org.wso2.carbon.event.processor.manager.core.internal.CarbonEventManagementService} >> - Starting polling event receivers >> [2015-12-10 19:32:32,096] ERROR >> {org.wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter} - Error in >> executing task: null >> java.lang.NullPointerException >> at >> org.wso2.carbon.analytics.spark.core.internal.SparkAnalyticsExecutor.executeQueryLocal(SparkAnalyticsExecutor.java:710) >> at >> org.wso2.carbon.analytics.spark.core.internal.SparkAnalyticsExecutor.executeQuery(SparkAnalyticsExecutor.java:692) >> at >> org.wso2.carbon.analytics.spark.core.CarbonAnalyticsProcessorService.executeQuery(CarbonAnalyticsProcessorService.java:199) >> at >> org.wso2.carbon.analytics.spark.core.CarbonAnalyticsProcessorService.executeScript(CarbonAnalyticsProcessorService.java:149) >> at >> org.wso2.carbon.analytics.spark.core.AnalyticsTask.execute(AnalyticsTask.java:57) >> at >> org.wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter.execute(TaskQuartzJobAdapter.java:67) >> at org.quartz.core.JobRunShell.run(JobRunShell.java:213) >> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) >> at java.util.concurrent.FutureTask.run(FutureTask.java:266) >> at >> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) >> at >> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) >> at java.lang.Thread.run(Thread.java:745) >> >> >> [1] https://docs.wso2.com/display/DAS300/Analyzing+HTTPD+Logs >> >> -- >> Roshan Wijesena. >> Senior Software Engineer-WSO2 Inc. >> Mobile: *+94719154640 <%2B94719154640>* >> Email: ros...@wso2.com >> *WSO2, Inc. :** wso2.com <http://wso2.com/>* >> lean.enterprise.middleware. >> > > > > -- > Roshan Wijesena. > Senior Software Engineer-WSO2 Inc. > Mobile: *+94719154640 <%2B94719154640>* > Email: ros...@wso2.com > *WSO2, Inc. :** wso2.com <http://wso2.com/>* > lean.enterprise.middleware. > -- Roshan Wijesena. Senior Software Engineer-WSO2 Inc. Mobile: *+94719154640* Email: ros...@wso2.com *WSO2, Inc. :** wso2.com <http://wso2.com/>* lean.enterprise.middleware.
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev