问题标签 [wso2bam]

Can we plug into any other database other than Cassandra , as all published data goes into Cassandra ?

我正在使用仪表板，并希望使用仪表板显示自定义事件。是否可以使用它查看自定义事件？

有什么方法可以删除在 cassandra 中长时间积累的原始事件？

我与 BAM 合作了这么多天，突然间我什至无法做一个简单的示例（HTTPD 日志分析示例），如 BAM 2.0.1 文档中所示。我没有改变偏移量。

我正在采取的步骤是：

- 在 linux 中启动 BAM 服务器

- 从 $WSO2_BAM_HOME/samples/httpd-logs/resources 目录中读取 access.log

- 在管理控制台中安装“HTTPD 日志和分析”工具箱

现在在安装时我遇到了一个配置单元脚本错误::

“执行 Hive 脚本时出错。查询返回非零代码：9，原因：失败：执行错误，从 org.apache.hadoop.hive.ql.exec.DDLTask 返回代码 1”

你能告诉我哪里出错了吗？

后端的错误是

我们希望将 WSO2 BAM 2.0.1 连接到外部 hadoop 集群（完全分布式）。我按照此链接进行设置

配置 Apache Hive

但是，当我运行我的 Hive 脚本时，出现以下错误

java.sql.SQLException：查询返回非零代码：9，原因：FAILED：执行错误，从 org.apache.hadoop.hive.ql.exec.MapRedTask 返回代码 -101

此 Hive 脚本适用于本地 Hadoop 模式...

在使用外部 Hadoop 集群时，我是否还需要对 Hive 脚本进行任何更改。

这些是我在控制台中看到的错误..

TID：[0] [BAM] [2013-01-16 09:42:36,583] INFO {org.apache.hadoop.hive.ql.exec.Utilities} - 未缓存 hdfs://r4p8n0c:9000/ 的内容摘要用户/hive/warehouse_wso2-1234/aeanalyticstable_demo {org.apache.hadoop.hive.ql.exec.Utilities}
TID：[0] [BAM] [2013-01-16 09:42:36,583] 信息 {org.apache. hadoop.hive.ql.exec.Utilities} - 未缓存 hdfs://r4p8n0c:9000/user/hive/warehouse_wso2-1234/aeanalyticstable_demo {org.apache.hadoop.hive.ql.exec.Utilities}
TID 的内容摘要： [0] [BAM] [2013-01-16 09:42:36,590] INFO {org.apache.hadoop.hive.ql.exec.ExecDriver} - 添加非本地表 hdfs://r4p8n0c:9000/user /hive/warehouse_wso2-1234/aeanalyticstable_demo {org.apache.hadoop.hive.ql.exec.ExecDriver}
TID：[0] [BAM] [2013-01-16 09:42:36,590] INFO {org.apache.hadoop.hive.ql.exec.ExecDriver} - 添加非本机表 hdfs://r4p8n0c:9000 /user/hive/warehouse_wso2-1234/aeanalyticstable_demo {org.apache.hadoop.hive.ql.exec.ExecDriver}
TID：[0] [BAM] [2013-01-16 09:42:36,832] 错误 {org.apache .hadoop.hive.ql.Driver} - 失败：执行错误，从 org.apache.hadoop.hive.ql.exec.MapRedTask {org.apache.hadoop.hive.ql.Driver} 返回代码 -101
TID：[0 ] [BAM] [2013-01-16 09:42:36,832] 错误 {org.apache.hadoop.hive.ql.Driver} - 失败：执行错误，从 org.apache.hadoop.hive.ql 返回代码 -101 .exec.MapRedTask {org.apache.hadoop.hive.ql.Driver}
TID：[0] [BAM] [2013-01-16 09:42:36,833] INFO {org.apache.hadoop.hive.ql.Driver } - {org.apache.hadoop.hive.ql.Driver}
TID：[0] [BAM] [2013-01-16 09:42:36,833] 信息 {org.apache.hadoop.hive.ql.Driver} - {org.apache.hadoop.hive.ql.Driver}
TID： [0] [BAM] [2013-01-16 09:42:36,833] 信息 {org.apache.hadoop.hive.ql.Driver} - {org.apache.hadoop.hive.ql.Driver}
TID：[0 ] [BAM] [2013-01-16 09:42:36,833] 信息 {org.apache.hadoop.hive.ql.Driver} - {org.apache.hadoop.hive.ql.Driver}
TID：[0] [ BAM] [2013-01-16 09:42:36,834] 信息 {org.apache.hadoop.hive.ql.Driver} - {org.apache.hadoop.hive.ql.Driver}
TID：[0] [BAM] [2013-01-16 09:42:36,834] 信息 {org.apache.hadoop.hive.ql.Driver} - {org.apache.hadoop.hive.ql.Driver}
TID：[0] [BAM] [2013-01-16 09:42:36,834] 错误 {org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl} - 执行 Hive 脚本时出错。
查询返回非零代码：9，原因：FAILED：执行错误，从 org.apache.hadoop.hive.ql.exec.MapRedTask {org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl}
java返回代码 -101 .sql.SQLException：查询返回非零代码：9，原因：失败：执行错误，从 org.apache.hadoop.hive.jdbc
的 org.apache.hadoop.hive.ql.exec.MapRedTask 返回代码 -101。 HiveStatement.executeQuery(HiveStatement.java:189)
在 org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.call(HiveExecutorServiceImpl.java:325)
在 org.wso2.carbon.analytics.hive.impl.HiveExecutorServiceImpl$ScriptCallable.call(HiveExecutorServiceImpl.java:225)
在 java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
在 java.util.concurrent .FutureTask.run(FutureTask.java:138)
在 java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
在java.lang.Thread.run(Thread.java:662)
TID：[0] [BAM] [2013-01-16 09:42:36,848] 错误 {org.wso2.carbon.analytics.hive.ui.client.HiveExecutionClient} - 执行 Hive 脚本时出错。查询返回非零代码：9，原因：FAILED：执行错误，从 org.apache.hadoop.hive.ql.exec.MapRedTask {org.wso2.carbon.analytics.hive.ui.client.HiveExecutionClient} 返回代码 -101

org.wso2.carbon.analytics.hive.stub.HiveExecutionServiceHiveExecutionException：HiveExecutionServiceHiveExecutionException
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:39)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance (DelegatingConstructorAccessorImpl.java:27)
在 java.lang.reflect.Constructor.newInstance(Constructor.java:513)
在 java.lang.Class.newInstance0(Class.java:355)
在 java.lang.Class.newInstance(Class.爪哇：308）
在 org.wso2.carbon.analytics.hive.stub.HiveExecutionServiceStub.executeHiveScript(HiveExecutionServiceStub.java:215)
在 org.wso2.carbon.analytics.hive.ui.client.HiveExecutionClient.executeScript(HiveExecutionClient.java:66)
在 org .apache.jsp.hive_002dexplorer.queryresults_jsp._jspService(queryresults_jsp.java:90)
at org.apache.jasper.runtime.HttpJspBase.service(HttpJspBase.java:97)
at javax.servlet.http.HttpServlet.service(HttpServlet.java :722)
在 org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:332)
在 org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:314)
在 org.apache.jasper.servlet.JspServlet.service(JspServlet.java:264)
在 javax.servlet.http.HttpServlet.service(HttpServlet.java:722)
在 org.wso2.carbon.ui.JspServlet.service(JspServlet .java:161)
在 org.wso2.carbon.ui.TilesJspServlet.service(TilesJspServlet.java:80)
在 javax.servlet.http.HttpServlet.service(HttpServlet.java:722)
在 org.eclipse.equinox.http。 helper.ContextPathServletAdaptor.service(ContextPathServletAdaptor.java:36)
在 org.eclipse.equinox.http.servlet.internal.ServletRegistration.handleRequest(ServletRegistration.java:90)
在 org.eclipse.equinox.http.servlet.internal.ProxyServlet。进程别名（ProxyServlet.java:111）
在 org.eclipse.equinox.http.servlet.internal.ProxyServlet.service(ProxyServlet.java:67)
在 javax.servlet.http.HttpServlet.service(HttpServlet.java:722)
在 org.wso2.carbon.tomcat.ext .servlet.DelegationServlet.service(DelegationServlet.java:68)
在 org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:305)
在 org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210 ) )
在 org.apache.catalina.core.ApplicationDispatcher.doInclude(ApplicationDispatcher.java:599)
的 org.apache.catalina.core.ApplicationDispatcher.invoke(ApplicationDispatcher.java:690)

WSO2 CEP 或 BAM 如何进行负载平衡？使其处于集群模式（主动-主动）需要哪些配置更改。

发布者如何通过 Thrift 向此集群服务器发送事件，请提供示例。

我们在尝试按照手册将 BAM 配置文件添加到 ESB 时遇到问题：

http://docs.wso2.org/wiki/display/BAM201/Setting+up+BAM+Mediator#SettingupBAMMediator-ConfigureBAMServerProfilesandStreams

BAM 2.0.1（最新版本）

ESB 4.5.1（最新版本）

p2-repo 来自http://dist.wso2.org/p2/carbon/releases/p2-repo.zip (15-01-2013)

如果您在单个主机中使用两个 WSO2 服务器，它会起作用，但如果 ESB 和 BAM 在单独的主机中运行，则不会。未发现通过端口 7611 传出或传入的日志或流量。

BAM thrift 端口 7611 已打开并在 BAM 主机中侦听，并且可从 ESB 端口访问。

详情如下：

任何线索如何找到问题或从哪里开始解决它？提前致谢

我正在尝试将 WSO2 ESB 的 KPI 数据发送到 WSO2 BAM 以分析该 KPI

考虑在 WSo2 ESB 处理下面的消息，

作为 KPI，我需要发送数据

到 WSO2 BAM。

1. 我正在寻找将 WSO2 ESB 的 KPI 发送到 WSO2 BAM 的示例
2. 此外，如果在 WSO2 ESB 中安装中介数据代理并按照http://docs.wso2.org/wiki/display/BAM201/Setting+up+Mediation+Data+Agent中所述进行配置

我能否将 KPI 数据从 WSO2 ESB 发送到 WSO2 BAM？

我正在使用 WSO2 ESB 4.5.1 和 WSO2 BAM 2.0.0。在我的 Hive 脚本中，我试图获取一个值并将其分配给一个变量，以便以后可以在 SQL 语句中使用它。我可以使用 hiveconf 使用变量，但我不确定如何从结果集中将单个值分配给它。有任何想法吗？谢谢。

在 Cassandra Cluster EVENT_KS Key Space 中，我有一个 bookTicket1（流），它有列 payload_provider、payload_totalNoTickets。当我尝试如下新的分析脚本时，

它返回错误：

错误：执行 Hive 脚本时出错。查询返回非零代码：9，原因：失败：执行错误，从 org.apache.hadoop.hive.ql.exec.DDLTask 返回代码 1“