Hi, Issue was fixed by keeping the port in WSO2BAM_CASSANDRA_DATASOURCE as 9160. Previously it was set to 9161.
Referred [1], [2]. [1] - https://wso2.org/jira/browse/BAM-1624 [2] - https://wso2.org/jira/browse/BAM-1476 Thanks. On Fri, Feb 13, 2015 at 2:56 PM, Jagath Sisirakumara Ariyarathne < [email protected]> wrote: > Hi Hasanthi, > > Thanks for the update. > > It seems to be a connectivity issue. Below errors also there in the > console. > > [2015-02-13 14:34:03,268] ERROR {org.apache.cassandra.hadoop.ConfigHelper} > - failed to connect to any initial addresses > [2015-02-13 14:34:03,269] ERROR {org.apache.cassandra.hadoop.ConfigHelper} > - > java.io.IOException: Unable to connect to server localhost:9162 > at > org.apache.cassandra.hadoop.ConfigHelper.createConnection(ConfigHelper.java:577) > ------------ > Job Submission failed with exception 'java.io.IOException(Unable to > connect to server localhost:9162)' > [2015-02-13 14:40:03,057] ERROR > {org.apache.hadoop.hive.ql.exec.ExecDriver} - Job Submission failed with > exception 'java.io.IOException(Unable to connect to server localhost:9162)' > java.io.IOException: Unable to connect to server localhost:9162 > > > I could not find any configurations where we have set port 9162 (checked > in bam-datasources.xml and master-datasources.xml). > > However, the functionality of the sample worked fine. > > Thanks. > > On Fri, Feb 13, 2015 at 11:34 AM, Hasanthi Purnima Dissanayake < > [email protected]> wrote: > >> Hi Jagath, >> you have to drop the related table. Please refer to [1]. >> >> http://stackoverflow.com/questions/22968243/wso2-bam-documentation >> >> Hasanthi Dissanayake >> >> Software Engineer | WSO2 >> >> E: [email protected] <[email protected]> >> M :0718407133| http://wso2.com <http://wso2.com/> >> >> On Fri, Feb 13, 2015 at 11:31 AM, Jagath Sisirakumara Ariyarathne < >> [email protected]> wrote: >> >>> Hi Hasanthi, >>> >>> I changed the offset as the first step. But let me try with that. >>> >>> What is the location of the script i should edit? >>> >>> Thanks. >>> >>> On Fri, Feb 13, 2015 at 11:25 AM, Hasanthi Purnima Dissanayake < >>> [email protected]> wrote: >>> >>>> Hi Jagath, >>>> Did you follow the below step? >>>> >>>> "If you run the Hive scripts before changing the default Cassandra port >>>> according to the BAM port offset, you keep getting an exception. To >>>> overcome this, add the following line at the beginning of the Hive script >>>> and rerun. >>>> drop table <hive_cassandra_table_name>" >>>> >>>> Thanks and Regards, >>>> >>>> Hasanthi Dissanayake >>>> >>>> Software Engineer | WSO2 >>>> >>>> E: [email protected] <[email protected]> >>>> M :0718407133| http://wso2.com <http://wso2.com/> >>>> >>>> On Fri, Feb 13, 2015 at 10:59 AM, Jagath Sisirakumara Ariyarathne < >>>> [email protected]> wrote: >>>> >>>>> Hi, >>>>> >>>>> BAM console gives below error when I started BAM for the sample [1]. >>>>> >>>>> FAILED: Execution Error, return code 2 from >>>>> org.apache.hadoop.hive.ql.exec.MapRedTask >>>>> [2015-02-13 10:35:03,733] ERROR {org.apache.hadoop.hive.ql.Driver} - >>>>> FAILED: Execution Error, return code 2 from >>>>> org.apache.hadoop.hive.ql.exec.MapRedTask >>>>> [2015-02-13 10:35:03,734] ERROR >>>>> {org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl} - Error >>>>> executing query: Query returned non-zero code: 9, cause: FAILED: Execution >>>>> Error, return code 2 from org.apache.hadoop.hive.ql.exec.MapRedTask >>>>> java.sql.SQLException: Query returned non-zero code: 9, cause: FAILED: >>>>> Execution Error, return code 2 from >>>>> org.apache.hadoop.hive.ql.exec.MapRedTask >>>>> at >>>>> org.apache.hadoop.hive.jdbc.HiveStatement.executeQuery(HiveStatement.java:189) >>>>> at >>>>> org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.executeHiveQuery(HiveExecutorServiceImpl.java:599) >>>>> at >>>>> org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.call(HiveExecutorServiceImpl.java:304) >>>>> at >>>>> org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.call(HiveExecutorServiceImpl.java:192) >>>>> at java.util.concurrent.FutureTask.run(FutureTask.java:262) >>>>> at >>>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) >>>>> at >>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) >>>>> at java.lang.Thread.run(Thread.java:745) >>>>> [2015-02-13 10:35:03,735] ERROR >>>>> {org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl} - Error >>>>> while executing Hive script. >>>>> Query returned non-zero code: 9, cause: FAILED: Execution Error, >>>>> return code 2 from org.apache.hadoop.hive.ql.exec.MapRedTask >>>>> java.sql.SQLException: Query returned non-zero code: 9, cause: FAILED: >>>>> Execution Error, return code 2 from >>>>> org.apache.hadoop.hive.ql.exec.MapRedTask >>>>> at >>>>> org.apache.hadoop.hive.jdbc.HiveStatement.executeQuery(HiveStatement.java:189) >>>>> at >>>>> org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.executeHiveQuery(HiveExecutorServiceImpl.java:599) >>>>> at >>>>> org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.call(HiveExecutorServiceImpl.java:304) >>>>> at >>>>> org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.call(HiveExecutorServiceImpl.java:192) >>>>> at java.util.concurrent.FutureTask.run(FutureTask.java:262) >>>>> at >>>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) >>>>> at >>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) >>>>> at java.lang.Thread.run(Thread.java:745) >>>>> [2015-02-13 10:35:03,735] ERROR >>>>> {org.wso2.carbon.analytics.hive.task.HiveScriptExecutorTask} - Error >>>>> while >>>>> executing script : phone_retail_store_script >>>>> org.wso2.carbon.analytics.hive.exception.HiveExecutionException: Error >>>>> while executing Hive script.Query returned non-zero code: 9, cause: >>>>> FAILED: >>>>> Execution Error, return code 2 from >>>>> org.apache.hadoop.hive.ql.exec.MapRedTask >>>>> at >>>>> org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl.execute(HiveExecutorServiceImpl.java:117) >>>>> at >>>>> org.wso2.carbon.analytics.hive.task.HiveScriptExecutorTask.execute(HiveScriptExecutorTask.java:70) >>>>> 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:471) >>>>> at java.util.concurrent.FutureTask.run(FutureTask.java:262) >>>>> at >>>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) >>>>> at >>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) >>>>> at java.lang.Thread.run(Thread.java:745) >>>>> >>>>> Is there any missing configuration or script which cause this error? >>>>> >>>>> [1] - https://docs.wso2.com/display/AM180/Generating+Billing+Data >>>>> >>>>> -- >>>>> Jagath Ariyarathne >>>>> Technical Lead >>>>> WSO2 Inc. http://wso2.com/ >>>>> Email: [email protected] >>>>> Mob : +94 77 386 7048 >>>>> >>>>> >>>>> _______________________________________________ >>>>> Dev mailing list >>>>> [email protected] >>>>> http://wso2.org/cgi-bin/mailman/listinfo/dev >>>>> >>>>> >>>> >>> >>> >>> -- >>> Jagath Ariyarathne >>> Technical Lead >>> WSO2 Inc. http://wso2.com/ >>> Email: [email protected] >>> Mob : +94 77 386 7048 >>> >>> >> > > > -- > Jagath Ariyarathne > Technical Lead > WSO2 Inc. http://wso2.com/ > Email: [email protected] > Mob : +94 77 386 7048 > > -- Jagath Ariyarathne Technical Lead WSO2 Inc. http://wso2.com/ Email: [email protected] Mob : +94 77 386 7048
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
