Hi all.
I´m trying to connect AS with BAM with some issues like this one:
TID: [-1234] [WSO2 Business Activity Monitor] [2012-09-18 17:15:00,028]
INFO {org.wso2.carbon.analytics.hive.task.HiveScriptExecutorTask} - Running
script executor task for script service_stats_185. [Tue Sep 18 17:15:00 CDT
2012] {org.wso2.carbon.analytics.hive.task.HiveScriptExecutorTask}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:06,374] ERROR
{org.apache.cassandra.thrift.CustomTThreadPoolServer} - Error occurred
during processing of message.
{org.apache.cassandra.thrift.CustomTThreadPoolServer}
java.lang.IllegalArgumentException: Unknown table/cf pair
(EVENT_KS.bam_service_data_publisher)
at
org.apache.cassandra.db.Table.getColumnFamilyStore(Table.java:159)
at
org.apache.cassandra.service.StorageService.getSplits(StorageService.java:21
96)
at
org.apache.cassandra.thrift.CassandraServer.describe_splits(CassandraServer.
java:887)
at
org.apache.cassandra.thrift.Cassandra$Processor$describe_splits.getResult(Ca
ssandra.java:3390)
at
org.apache.cassandra.thrift.Cassandra$Processor$describe_splits.getResult(Ca
ssandra.java:3378)
at
org.apache.thrift.ProcessFunction.process(ProcessFunction.java:32)
at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34)
at
org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(Custom
TThreadPoolServer.java:186)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source)
at java.lang.Thread.run(Unknown Source)
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:06,374] ERROR
{org.apache.cassandra.thrift.CustomTThreadPoolServer} - Error occurred
during processing of message.
{org.apache.cassandra.thrift.CustomTThreadPoolServer}
java.lang.IllegalArgumentException: Unknown table/cf pair
(EVENT_KS.bam_service_data_publisher)
at
org.apache.cassandra.db.Table.getColumnFamilyStore(Table.java:159)
at
org.apache.cassandra.service.StorageService.getSplits(StorageService.java:21
96)
at
org.apache.cassandra.thrift.CassandraServer.describe_splits(CassandraServer.
java:887)
at
org.apache.cassandra.thrift.Cassandra$Processor$describe_splits.getResult(Ca
ssandra.java:3390)
at
org.apache.cassandra.thrift.Cassandra$Processor$describe_splits.getResult(Ca
ssandra.java:3378)
at
org.apache.thrift.ProcessFunction.process(ProcessFunction.java:32)
at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:34)
at
org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(Custom
TThreadPoolServer.java:186)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source)
at java.lang.Thread.run(Unknown Source)
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:06,386] ERROR
{org.apache.hadoop.hive.ql.exec.ExecDriver} - Job Submission failed with
exception 'java.io.IOException(Could not get input splits)'
java.io.IOException: Could not get input splits
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSplits(ColumnFamilyIn
putFormat.java:178)
at
org.apache.hadoop.hive.cassandra.input.HiveCassandraStandardColumnInputForma
t.getSplits(HiveCassandraStandardColumnInputFormat.java:221)
at
org.apache.hadoop.hive.cassandra.input.HiveCassandraStandardColumnInputForma
t.getSplits(HiveCassandraStandardColumnInputFormat.java:171)
at
org.apache.hadoop.hive.ql.io.HiveInputFormat.getSplits(HiveInputFormat.java:
292)
at
org.apache.hadoop.hive.ql.io.CombineHiveInputFormat.getSplits(CombineHiveInp
utFormat.java:292)
at
org.apache.hadoop.mapred.JobClient.writeOldSplits(JobClient.java:930)
at
org.apache.hadoop.mapred.JobClient.writeSplits(JobClient.java:922)
at org.apache.hadoop.mapred.JobClient.access$500(JobClient.java:170)
at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:839)
at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:792)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Unknown Source)
at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.ja
va:1123)
at
org.apache.hadoop.mapred.JobClient.submitJobInternal(JobClient.java:792)
at org.apache.hadoop.mapred.JobClient.submitJob(JobClient.java:766)
at
org.apache.hadoop.hive.ql.exec.ExecDriver.execute(ExecDriver.java:458)
at
org.apache.hadoop.hive.ql.exec.ExecDriver.main(ExecDriver.java:728)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.apache.hadoop.util.RunJar.main(RunJar.java:156)
Caused by: java.util.concurrent.ExecutionException:
java.lang.RuntimeException: org.apache.thrift.transport.TTransportException
at java.util.concurrent.FutureTask$Sync.innerGet(Unknown Source)
at java.util.concurrent.FutureTask.get(Unknown Source)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSplits(ColumnFamilyIn
putFormat.java:174)
... 21 more
Caused by: java.lang.RuntimeException:
org.apache.thrift.transport.TTransportException
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSubSplits(ColumnFamil
yInputFormat.java:265)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.access$200(ColumnFamilyI
nputFormat.java:77)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat$SplitCallable.call(Colum
nFamilyInputFormat.java:211)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat$SplitCallable.call(Colum
nFamilyInputFormat.java:196)
at java.util.concurrent.FutureTask$Sync.innerRun(Unknown Source)
at java.util.concurrent.FutureTask.run(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source)
at java.lang.Thread.run(Unknown Source)
Caused by: org.apache.thrift.transport.TTransportException
at
org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:
132)
at
org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
at
org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java
:129)
at
org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)
at
org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
at
org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378)
at
org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297)
at
org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.
java:204)
at
org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69)
at
org.apache.cassandra.thrift.Cassandra$Client.recv_describe_splits(Cassandra.
java:1201)
at
org.apache.cassandra.thrift.Cassandra$Client.describe_splits(Cassandra.java:
1185)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSubSplits(ColumnFamil
yInputFormat.java:257)
... 8 more
{org.apache.hadoop.hive.ql.exec.ExecDriver}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:06,386] ERROR
{org.apache.hadoop.hive.ql.exec.ExecDriver} - Job Submission failed with
exception 'java.io.IOException(Could not get input splits)'
java.io.IOException: Could not get input splits
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSplits(ColumnFamilyIn
putFormat.java:178)
at
org.apache.hadoop.hive.cassandra.input.HiveCassandraStandardColumnInputForma
t.getSplits(HiveCassandraStandardColumnInputFormat.java:221)
at
org.apache.hadoop.hive.cassandra.input.HiveCassandraStandardColumnInputForma
t.getSplits(HiveCassandraStandardColumnInputFormat.java:171)
at
org.apache.hadoop.hive.ql.io.HiveInputFormat.getSplits(HiveInputFormat.java:
292)
at
org.apache.hadoop.hive.ql.io.CombineHiveInputFormat.getSplits(CombineHiveInp
utFormat.java:292)
at
org.apache.hadoop.mapred.JobClient.writeOldSplits(JobClient.java:930)
at
org.apache.hadoop.mapred.JobClient.writeSplits(JobClient.java:922)
at org.apache.hadoop.mapred.JobClient.access$500(JobClient.java:170)
at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:839)
at org.apache.hadoop.mapred.JobClient$2.run(JobClient.java:792)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Unknown Source)
at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.ja
va:1123)
at
org.apache.hadoop.mapred.JobClient.submitJobInternal(JobClient.java:792)
at org.apache.hadoop.mapred.JobClient.submitJob(JobClient.java:766)
at
org.apache.hadoop.hive.ql.exec.ExecDriver.execute(ExecDriver.java:458)
at
org.apache.hadoop.hive.ql.exec.ExecDriver.main(ExecDriver.java:728)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.apache.hadoop.util.RunJar.main(RunJar.java:156)
Caused by: java.util.concurrent.ExecutionException:
java.lang.RuntimeException: org.apache.thrift.transport.TTransportException
at java.util.concurrent.FutureTask$Sync.innerGet(Unknown Source)
at java.util.concurrent.FutureTask.get(Unknown Source)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSplits(ColumnFamilyIn
putFormat.java:174)
... 21 more
Caused by: java.lang.RuntimeException:
org.apache.thrift.transport.TTransportException
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSubSplits(ColumnFamil
yInputFormat.java:265)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.access$200(ColumnFamilyI
nputFormat.java:77)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat$SplitCallable.call(Colum
nFamilyInputFormat.java:211)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat$SplitCallable.call(Colum
nFamilyInputFormat.java:196)
at java.util.concurrent.FutureTask$Sync.innerRun(Unknown Source)
at java.util.concurrent.FutureTask.run(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source)
at java.lang.Thread.run(Unknown Source)
Caused by: org.apache.thrift.transport.TTransportException
at
org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:
132)
at
org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
at
org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java
:129)
at
org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)
at
org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
at
org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378)
at
org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297)
at
org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.
java:204)
at
org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69)
at
org.apache.cassandra.thrift.Cassandra$Client.recv_describe_splits(Cassandra.
java:1201)
at
org.apache.cassandra.thrift.Cassandra$Client.describe_splits(Cassandra.java:
1185)
at
org.apache.cassandra.hadoop.ColumnFamilyInputFormat.getSubSplits(ColumnFamil
yInputFormat.java:257)
... 8 more
{org.apache.hadoop.hive.ql.exec.ExecDriver}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,640] ERROR
{org.apache.hadoop.hive.ql.exec.Task} - Execution failed with exit status:
2 {org.apache.hadoop.hive.ql.exec.Task}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,640] ERROR
{org.apache.hadoop.hive.ql.exec.Task} - Execution failed with exit status:
2 {org.apache.hadoop.hive.ql.exec.Task}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,641] ERROR
{org.apache.hadoop.hive.ql.exec.Task} - Obtaining error information
{org.apache.hadoop.hive.ql.exec.Task}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,641] ERROR
{org.apache.hadoop.hive.ql.exec.Task} - Obtaining error information
{org.apache.hadoop.hive.ql.exec.Task}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,642] ERROR
{org.apache.hadoop.hive.ql.exec.Task} -
Task failed!
Task ID:
Stage-0
Logs:
{org.apache.hadoop.hive.ql.exec.Task}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,642] ERROR
{org.apache.hadoop.hive.ql.exec.Task} -
Task failed!
Task ID:
Stage-0
Logs:
{org.apache.hadoop.hive.ql.exec.Task}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,643] ERROR
{org.apache.hadoop.hive.ql.exec.Task} -
/opt/wso2bam-2.0.0/repository/logs//wso2carbon.log
{org.apache.hadoop.hive.ql.exec.Task}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,643] ERROR
{org.apache.hadoop.hive.ql.exec.Task} -
/opt/wso2bam-2.0.0/repository/logs//wso2carbon.log
{org.apache.hadoop.hive.ql.exec.Task}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,643] ERROR
{org.apache.hadoop.hive.ql.exec.ExecDriver} - Execution failed with exit
status: 2 {org.apache.hadoop.hive.ql.exec.ExecDriver}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,643] ERROR
{org.apache.hadoop.hive.ql.exec.ExecDriver} - Execution failed with exit
status: 2 {org.apache.hadoop.hive.ql.exec.ExecDriver}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,645] ERROR
{org.apache.hadoop.hive.ql.Driver} - FAILED: Execution Error, return code 2
from org.apache.hadoop.hive.ql.exec.MapRedTask
{org.apache.hadoop.hive.ql.Driver}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,645] ERROR
{org.apache.hadoop.hive.ql.Driver} - FAILED: Execution Error, return code 2
from org.apache.hadoop.hive.ql.exec.MapRedTask
{org.apache.hadoop.hive.ql.Driver}
TID: [] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,648] 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
{org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl}
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:18
9)
at
org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.c
all(HiveExecutorServiceImpl.java:323)
at
org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.c
all(HiveExecutorServiceImpl.java:224)
at java.util.concurrent.FutureTask$Sync.innerRun(Unknown Source)
at java.util.concurrent.FutureTask.run(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown
Source)
at java.lang.Thread.run(Unknown Source)
TID: [-1234] [WSO2 Business Activity Monitor] [2012-09-18 17:15:07,651]
ERROR {org.wso2.carbon.analytics.hive.task.HiveScriptExecutorTask} - Error
while executing script : service_stats_185
{org.wso2.carbon.analytics.hive.task.HiveScriptExecutorTask}
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(HiveExec
utorServiceImpl.java:109)
at
org.wso2.carbon.analytics.hive.task.HiveScriptExecutorTask.execute(HiveScrip
tExecutorTask.java:60)
at
org.wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter.execute(TaskQuartzJobAd
apter.java:71)
at org.quartz.core.JobRunShell.run(JobRunShell.java:213)
at
org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:557
)
Saludos,
Ing. Jorge Infante Osorio.
J´Dpto Soluciones SOA.
CDAE.
Fac. 5.
UCI.
En un mundo perfecto las pizzas serían una comida saludable, las laptops se
cargarían desde una fuente de corriente inalámbrica y todos los JAR serían
bundles de OSGI
10mo. ANIVERSARIO DE LA CREACION DE LA UNIVERSIDAD DE LAS CIENCIAS
INFORMATICAS...
CONECTADOS AL FUTURO, CONECTADOS A LA REVOLUCION
http://www.uci.cu
http://www.facebook.com/universidad.uci
http://www.flickr.com/photos/universidad_uci
_______________________________________________
User mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/user
