在ajax.py中，我有这样一个导入语句：
import components.db_init as db
在components/db_init.py中，我有这样的import语句：
# import locals from ORM (Storm)
from storm.locals import *
在components/storm/locals.py中，它具有以下内容：
from storm.properties import Bool, Int, Float, RawStr, Chars, Unicode, Pickle
from storm.properties import Li
浏览 2提问于2009-07-17得票数 0
回答已采纳
首先，我要道歉，因为我的SQL知识水平仍然很低。基本上问题是:我有两个不同的表，它们之间没有直接关系，但是它们共享两个列: storm_id和userid。
基本上，我想查询来自storm_id的所有帖子，这些帖子不是来自被禁止的用户和一些额外的过滤器。
以下是模型：
帖子
class Post(db.Model):
id = db.Column(db.Integer, primary_key = True)
...
userid = db.Column(db.String(100))
...
storm_id = db.Column(db.Intege
浏览 1提问于2017-05-20得票数 11
回答已采纳
我已经设置了一个单节点集群，并尝试将我的示例拓扑部署到其中。
我相信要将我的拓扑部署到集群，我必须将包含所有依赖项的jar提交到集群。
为此，我创建了一个示例项目，并向其中添加了一个简单的拓扑。
在使用gradle生成fat jar时，我看到以下错误
gradle fatjar给出以下错误
Could not expand ZIP '/Users/agarg/.gradle/caches/modules-2/files-
2.1/org.apache.storm/storm-
core/0.9.5/d2bf27db853347dcf66990b4514db20a7897303e/sto
浏览 0提问于2015-10-14得票数 0
我想知道如何使用Node和mongojs模块单独获取嵌入式文档。下面是我的一些代码以供参考：
//Gets by ID
router.get('storm/:id',function(req,res,next){
db.storms.findOne({_id:mongojs.ObjectId(req.params.id)},function(err,storm){
if (err){
res.send(err);
}
else {
res.json(storm);
浏览 10提问于2016-12-19得票数 0
我有一个风暴拓扑，我有：setNumWorkers(1);
当我查看这个正在运行的拓扑上的storm报告时，我看到Num工作者被设置为1。
但是，当我登录到运行监控器的节点时，我会看到两个进程的-Dworker.id和-Dworker.port设置相同。
我将包括ps为下面这两个进程显示的输出。
我的问题是:如果我只请求一个进程，为什么会有两个进程被配置为辅助进程(注意: Storm确认我只有一个工作人员)。
这对我来说很重要，因为当我对拓扑所消耗的资源进行任何分析或分析时，我想知道应该集中在哪个进程上。
ps输出
root 787 20.0 0.6 5858228 78
浏览 2提问于2017-02-22得票数 1
回答已采纳
我有一个Storm拓扑(hortonworks发行版，版本1.1.0.2.6.2)，它使用JdbcInsertBolt类写入凤凰(Version4.7.0.2.6.2) db。我已经成功地写入了标准列(例如: varchar和int )，但是需要写入数组列，并且遇到了以下情况：
java.lang.RuntimeException: We do not support tables with SqlType: ARRAY
at org.apache.storm.jdbc.common.Util.getJavaType(Util.java:72) ~[stormjar.jar:?]
浏览 0提问于2018-12-10得票数 0
回答已采纳
提交一个简单的第一个Storm Topology让我抓狂。首先，当我试图在安装storm的远程VM上运行它时，连接被拒绝。我明白，我必须在本地集群上运行它。 下面是我的几行代码： public void execTopology_alt() throws Exception {
final TopologyBuilder tp = new TopologyBuilder();
tp.setSpout("kafka_spout", new KafkaSpout<>(KafkaSpoutConfig.builder(this.bootstrap
浏览 14提问于2019-06-16得票数 1
回答已采纳
1回答
我们正在尝试用Apache Spark streaming替换Apache Storm。在storm中；我们根据“客户ID”对流进行分区，以便具有“客户ID”范围的消息将被路由到相同的螺栓(工人)。我们这样做是因为每个worker都会缓存客户详细信息(来自DB)。因此，我们分成4个分区，每个螺栓(工人)将拥有整个范围的1/4。
我确实看到了Spark和Storm的比较；这是对Spark的限制。我希望我们在Spark Streaming中有一个解决方案
浏览 1提问于2015-06-06得票数 1
1回答
我有一个Golang项目，我使用Bolt作为我的数据库。我发现并开始使用来处理数据库上的连接和操作。我目前的问题是，我不能按一个字段进行搜索，只能得到一个结果。
我在Golang的结构定义是：
type Component struct {
ID int `storm:"increment"`
Name string `storm:"id,unique"` // primary key
Cars []string `storm:"index"` // this
浏览 2提问于2017-07-11得票数 0
回答已采纳
我已经在Proxmox中运行的一个新的18.04LXC容器上安装了GeorgeServer19.10(快速启动)。安装没有问题，web运行良好，我能够将客户端计算机连接到服务器。
不幸的是，我在web的通知窗格中注意到，脚本update_security_db.sh每次运行时都会反复失败(它每小时都会这样做，就像/etc/cron.d/ notifications那样)。
📷
检查update-security-db.log并手动运行脚本将导致以下错误：
Dec 19 16:40:36 update-security-db ERR Traceback (most recent call la
浏览 0提问于2020-12-19得票数 2
回答已采纳
我正在尝试将风暴数据插入宇宙数据库- Mongo中。
MongoClient mongoClient = null;
mongoClient = new MongoClient(new MongoClientURI("mongodb uri from azure portal"));
// Get database
MongoDatabase database = mongoClient.getDatabase("toystore");
// Get collection
MongoCollection<Doc
浏览 3提问于2017-12-05得票数 0
回答已采纳
我试图将Storm计数程序的输出写入mongoDB.This，这是我在执行program.Though时遇到的错误，当我试图编写输出时，我能够成功地打印reusult.Problem启动。
生成的错误:
Jun 01, 2015 3:24:23 PM com.mongodb.DBTCPConnector fetchMaxBsonObjectSize
WARNING: Exception determining maxBSON size using0
java.io.IOException: couldn't connect to [Ritesh-RM/127.0.1.1:27017]
浏览 2提问于2015-06-01得票数 0
回答已采纳
1回答
我有两个表，一个用于主机，另一个用于用户。
主机：
{
"host": "server1",
"address": "192.168.1.22", 'users': ["Magneto", "Professor Xavier", "Storm"]
},
{
"host": "server2",
"address": "192.168.
浏览 1提问于2014-09-30得票数 0
我必须创建一个程序来读取Storm.dat文件(包含海洋风暴并生成简短的报告)。我已经制作了必要的文件，但是我在Makefile中遇到了一些问题。
下面是我的代码：
storm.h
#ifndef STORMS_H
#define STORMS_H
class Storm
{
private:
char where; // A, E, C
char name[11]; // recall '\0'
int seq; // sequence num 1...
int year;
int max_wind; // knots
int
浏览 1提问于2015-10-07得票数 1
回答已采纳
1回答
在使用临时映像进行测试和在models.py中压缩图像时，我遇到了一个奇怪的问题。权限似乎存在问题：
ERROR: test_has_light_images (realestate.tests.test_view_listing.RealestateListingViewTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File "C:\Users\Storm\Envs\btre\lib\site-packa
浏览 1提问于2019-11-01得票数 4
3回答
无法安装storm时收到以下错误。
安装的pip版本如下：
pip 19.2.3
pip install storm
Using cached https://files.pythonhosted.org/packages/a7/4c/e5dbc818c432cd80d2e1aa1576f911eda49a3c206c6697db4070f402cda9/storm-0.20.tar.bz2
ERROR: Command errored out with exit status 1:
command: /usr/local/opt/python/bin/python3.7
浏览 4提问于2019-09-17得票数 1
当我试图使用()方法和kundera框架将表保存到cassandra时，我会收到以下错误：
28462 [Thread-15-localhostAMQPbolt0-executor[2 2]] INFO d.d.pieceDAOImpl - start to insert data
28513 [Thread-15-localhostAMQPbolt0-executor[2 2]] INFO c.i.c.c.CassandraClientBase - Returning cql query INSERT INTO "pieces"("width","
浏览 3提问于2016-05-11得票数 1
回答已采纳
当我试图保存一个OrientGraph数据库时，我会得到以下异常。
下面是我实现提交的代码。
代码：
OrientGraph orientGraph = null;
String source = enrichData.getSource();
orientGraph = orientConfiguration.open();
LocationDocument location = enrichData.getGeoLocation();
Vertex locationVertex = null;
Vertex contentVertex
浏览 2提问于2014-09-01得票数 1
我在跟踪。我在我的VMWare上使用Ubuntu14.04LTS。
我可以顺利地在/home/user/storm/examples/storm-starter目录中运行java:java: storm.topology=storm.starter.RollingTopWords，没有问题。但是，我不能在Apache中运行它。
我的/home/user/storm/examples/storm-starter目录中有starter拓扑-0.9.3.jar。我还在我的_storm-starter-0.9.3-jar-with-dependencies.jar目录中包含了starter 0.9.3
浏览 3提问于2015-04-28得票数 1
回答已采纳
我在“阿帕奇风暴”中面临一个问题
问题场景：
当小数据被发送到Storm时，数据会被拓扑(只有一个工作线程)正确地处理，并在MongoDB中继续保持下去。
但是当数据很大时，它会处理数据并在DB中持久化，但不管数据是大还是小，以后都不会接受任何其他数据。
当前的解决方案
我们从Storm重新启动工人。
问题
我们能以编程方式重新启动拓扑工作者吗？
浏览 1提问于2018-10-13得票数 0
1回答
Supervisor.log中的错误消息:风暴监控器猫不能同时创建stormClusterState，它在zk.The nimbus进程的/zk.The/zk.The目录中是空的，但是监督者不能start.why？
org.apache.storm.utils.Utils.handleUncaughtException(Utils.java:663)~storm-client-2.3.0.jar:2.3.0 at org.apache.storm.utils.Utils.handleUncaughtException(Utils.java:667)~storm-client-2.3.0.jar
浏览 12提问于2022-02-15得票数 0
1回答
我有一个像这样的收藏品：
{
"_id" : ObjectId("558c108b209c022c947b0055"),
"term" : "aero storm tour",
"year" : "2015",
"month" : "06",
"day" : "01",
"hour" : "17",
"dayofyear" : "184",
"weekofyear&
浏览 2提问于2015-07-01得票数 0
回答已采纳
在初始化Apache的Storm JdbcInsertBolt时，我得到一个错误
java.lang.ClassCastException:
Cannot cast org.apache.phoenix.jdbc.PhoenixDriver to javax.sql.DataSource
at com.zaxxer.hikari.util.UtilityElf.createInstance(UtilityElf.java:90)
at com.zaxxer.hikari.pool.PoolBase.initializeDataSource(PoolBase.java:292)
at co
浏览 0提问于2018-10-11得票数 0
我检查了Java版本、CLASSPATH、Java构建路径和属性> Run/Debug设置
但是我不能解决这个错误，Could not find or load main class，我需要什么信息来解决这个问题？
这是错误和我的电脑信息
#storm jar tims-0.0.1-SNAPSHOT.jar com.clunix.tims.TIMSTopology TIMSTopology
Running: /usr/local/jdk1.8.0_151/bin/java -client -Ddaemon.name= -Dstorm.options= -Dstorm.home=/stor
浏览 3提问于2017-12-01得票数 0
回答已采纳
当我试图使用()方法和kundera框架将表保存到cassandra时，我会收到以下错误：
18976 [Thread-15-localhostAMQPbolt0-executor[2 2]] INFO c.i.c.c.CassandraClientBase - Returning cql query INSERT INTO "pieces"("width","depth","height","idpiece") VALUES(10.0,12.0,11.0,'1') .
18998 [T
浏览 9提问于2016-05-11得票数 0
回答已采纳
1回答
我有我的拓扑运行，每一个螺栓工作，除了红螺栓。我只是想把信息写到一个redis数据库中，我已经在网上找到了一个例子。但是，当DB螺栓执行时，拓扑工作会显示以下错误：
3594 [Thread-18-print] INFO b.s.d.executor - Processing received message FOR 22 TUPLE: source: meal:20, stream: default, id: {}, [2009 +1.2815365e-01 :-) :-)]
source: meal:20, stream: default, id: {}, [2009 +1.2815
浏览 3提问于2016-01-28得票数 0
回答已采纳
以下是我的网站__init__.py中的相关代码
from site.models import initialise_sql
def main(global_config, **settings):
""" This function returns a Pyramid WSGI application """
initialise_sql(settings['database.url'])
return config.make_wsgi_app()
这是我的models/__init__.py
f
浏览 0提问于2011-07-16得票数 0
在storm中运行拓扑时，我们会遇到这样的错误，
8983 [Thread-6] INFO com.netflix.curator.framework.imps.CuratorFrameworkImpl -
Starting
9144 [main] INFO **backtype.storm.daemon.nimbus** - Shutting down master
9199 [Thread-6-EventThread] INFO backtype.storm.zookeeper - Zookeeper state upd
ate: :connected:none
9241 [main
浏览 1提问于2014-01-20得票数 0
这是我第一次和码头工人在一起，我花了两天时间来解决这个问题，这会让我很高兴找到一个解决方案。
我正在运行带有"docker-compose“的docker-compose.yml文件：
version: '3.3'
services:
base:
networks:
- brain_storm-network
volumes:
- brain_storm-storage:/usr/src/brain_storm
build: "./brain_storm"
data_base:
ima
浏览 2提问于2020-05-22得票数 0
回答已采纳
1回答
~/src/storm-0.8.1/bin/storm jar /root/src/storm-starter/target/storm-starter-0.0.1-SNAPSHOT-jar-with-dependencies.jar storm.starter.ExclamationTopology演示
我试着运行它，它说问题在于nimbus连接，但是我的暴风客户端(同时也是主管)连接到了我的(在Strom中显示)。
运行: java -client -Dstorm.options= -Dstorm.home=/root/src/storm-0.8.1 -cp -Dstorm.options
浏览 2提问于2014-04-24得票数 0
回答已采纳
4回答
风暴地形未提交
、、、、
我已经配置了我的机器动物园管理员，尼姆总线，监控器运行正常，我的拓扑工作在LocalCluster中。
LocalCluster cluster = new LocalCluster();
cluster.submitTopology("SendPost", conf, builder.createTopology());
Utils.sleep(10000000000l);
cluster.killTopology("SendPost");
cluster.shutdown();
现在我想尝试提交我的拓扑，但它不工作吗？
/usr/local/storm/bi
浏览 1提问于2014-02-07得票数 4
回答已采纳
我正试着开始学习Storm。我设置了一个托管集群。我按照here列出的所有步骤开始。它运行良好，直到提交： storm jar target/storm-starter-*.jar org.apache.storm.starter.RollingTopWords production-topology失败，错误为 Running: java -client -Ddaemon.name= -Dstorm.options= -Dstorm.home=/usr/local/Cellar/storm/1.2.2/libexec -Dstorm.log.dir=/usr/local/Cellar/st
浏览 11提问于2019-05-22得票数 1
我是c++新手，我一直在练习将我的旧Java代码翻译成C++。我遇到了太多的错误，我几乎放弃了希望。我还试图修复主文件中的错误，我试图调用主文件中的函数，但我得到了疯狂的语法错误，我不知道哪里错了。几个星期以来，我一直在尝试用谷歌搜索如何修复main.cpp中的这些错误。如果可以的话，我很感谢你的帮助。
// NamedStorm.cpp
// CPP=> Function definition
#include <iostream>
#include <string>
#include "NamedStorm.h"
using namespa
浏览 3提问于2013-06-20得票数 0
首先，我已经提到了很多类似的问题，但仍然无法解决。我已经正确地安装了尼姆和监控器，而且没有出现错误，即使是maven清洁安装和编译也没有错误，即使我的0qm也是用jzmq正确设置的，我也通过./storm启动了尼姆，启动了我的主管。
./风暴jar ~/ccbd-work/storm2/examples/target/storm-starter-topologies-0.10.0.jar org.apache.storm.starter.ExclamationTopology
我得到以下错误
运行:/usr/lib/jvm/java-7-OpenJDK-AMD 64/bin/java
浏览 2提问于2016-02-20得票数 0
回答已采纳
我使用R螺栓来处理我的数据，我想将处理后的数据从R螺栓发送到我的下一个螺栓，即当从R螺栓发出CountBolt.But时，不能将java.lang.String转换为java.util.List错误。
ERROR o.a.s.t.ShellBolt - Halting process: ShellBolt died. Command: [Rscript, permute.R], ProcessInfo pid:7169, name:python-split-sentence exitCode:-1, errorString:
java.lang.ClassCastException: ja
浏览 0提问于2019-04-08得票数 0
3回答
因此，我有以下数据，比方说称为"my_data"：
Storm.Type
TYPHOON
SEVERE STORM
TROPICAL STORM
SNOWSTORM AND HIGH WINDS
我想要的是对my_data$Storm.Type中的每个元素是否是风暴进行分类，但我不想把热带风暴作为风暴(我要将它们分开分类)，这样我就有了
Storm.Type Is.Storm
TYPHOON 0
SEVERE STORM 1
TROPICAL STORM
浏览 7提问于2013-11-22得票数 13
回答已采纳
2回答
我正在设置一个Apache系统，但在使程序持续运行方面遇到了问题。我已经在三台服务器上设置了风暴，但它只在一台服务器上持续工作。我认为问题就在指挥的道路上。
我一直在使用风暴起动器来设置程序，并在本地使用RollingTopWords进行了测试。当我运行以下命令$ storm jar storm-starter-*.jar storm.starter.RollingTopWords时，计算机暂停一秒钟，然后得到以下错误：
无法找到或加载主类storm.starter.RollingTopWords
jar存储在目录/apache/storm/examples/starter/targe
浏览 3提问于2015-06-01得票数 1
我已经在本地设置了一个Apache集群，并提交了一个在Storm UI中可见的拓扑。一旦一切都启动并运行，我将在ui.log文件中获得以下异常。这个错误在某种程度上与storm-kafka-monitor有关，这是一个bash脚本，我正在windows上运行这个脚本。
任何帮助都将不胜感激。(预先谢谢:)
2018-06-05 11:26:20.293 o.a.s.u.TopologySpoutLag qtp1185188034-26 [WARN] Exception thrown while getting lag for spout id: kafka-spout and spout cl
浏览 2提问于2018-06-05得票数 0
回答已采纳
1回答
我试图以守护进程的形式运行一个进程，并在pidfile中编写它的PID。但是当我运行它时，它会给我一个错误：
daemon: fatal: failed to tell if /home/ubuntu/storm/storm-0.8.2/bin/storm supervisor > /dev/null && echo $! > /var/run/supervisor-storm.pid is safe: No such file or directory
以下是代码：
PID_FILE=/var/run/supervisor-storm.pid
STORM_BIN=
浏览 3提问于2013-08-27得票数 0
回答已采纳
当我在运行风暴拓扑的机器上运行ps aux | grep java时，我可以看到2个Java进程正在运行。
ps -ef | grep java | grep "storm"
UID PID PPID C STIME TTY TIME CMD
test-3p-s+ 10857 10661 0 Apr12 ? 1-02:21:25 java -server -Ddaemon.name=supervisor -Dstorm.options= -Dstorm.home=/usr/share/apache-storm -Dstorm.
浏览 8提问于2022-10-31得票数 0
这是一个默认配置，就像在示例中一样，没有任何更改。我只是想让这个基本的例子起作用。
我正在尝试运行Storm 1.2.2中的示例。我构建了storm-starter项目，并尝试使用以下命令行执行：
storm jar target/storm-starter-1.2.2.jar org.apache.storm.starter.ExclamationTopology -local
但是，我得到了以下异常：
apara:storm-starter aparansky$ storm jar target/storm-starter-1.2.2.jar org.apache.storm.starte
浏览 3提问于2018-06-15得票数 0
也许这里也在做同样的事情：，但我将添加一个完整的堆栈跟踪和一些更多的上下文。
storm版本- 9.3
storm-kafka版本- 9.3
kafka版本-0.8.2-测试版
我也在使用三叉树，尽管我认为这个错误发生在storm级别。
堆栈跟踪：
java.lang.RuntimeException: java.nio.BufferUnderflowException
at backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:128) ~[storm-core- 0.9.3.ja
浏览 5提问于2015-01-15得票数 2
我正在使用storm 2.2.0，我的配置文件是：
#storm.yaml
storm.local.hostname: "10.100.7.109"
storm.zookeeper.servers:
- "10.100.242.107"
nimbus.seeds: ["localhost"]
supervisor.slots.ports:
- 6701
- 6702
- 6703
- 6704
- 6705
- 6706
- 6707
- 6708
-
浏览 25提问于2020-07-16得票数 0
在向集群提交风暴拓扑时，我收到此错误。
6653 [main] INFO backtype.storm.daemon.supervisor - Starting supervisor with id 8ee90770-957a-40c7-a70b-fd7399cab6a1 at host Ritesh-RM
6706 [main] INFO backtype.storm.StormSubmitter - Jar not uploaded to master yet. Submitting jar...
6711 [main] INFO backtype.storm.StormSubmit
浏览 2提问于2015-09-15得票数 3
我们有一个三叉树拓扑，使用kafka-storm OpaqueTridentKafkaSpout和TridentKafkaState从kafka消费和生产到kafka。在我们的产品storm集群上运行时一切正常，但在本地模式下运行时，我们经常收到以下错误：
java.lang.RuntimeException: java.lang.RuntimeException: Received unexpected tuple source: $mastercoord-bg1:2, stream: $commit, id: {-4957901903366351898=636438893184339370
浏览 6提问于2015-03-17得票数 4
在阅读问题说明后，欢迎任何想法。
背景:使用Apache发布消息: Kafka正在运行。卡夫卡制作者是创造信息并将其发布给卡夫卡经纪人供进一步消费的应用程序。因此，卡夫卡消费者要想消费数据，就需要在卡夫卡生产者和消费者开始发布信息和消费信息之前创建卡夫卡主题。
卡夫卡测试成功，因为卡夫卡消费者能够消费数据从卡夫卡主题和显示结果。
在启动Storm拓扑之前，停止Kafka用户，以便Storm Spout能够处理kafka主题中的数据流源。
使用Apache实时处理数据:随着Storm拓扑的创建，Storm将处理数据流源，这意味着Spout将从kafka主题中读取数据。在另一端，Spout将数据流
浏览 5提问于2015-05-20得票数 1
我已经使用多个资源建立了一个Storm开发集群，比如Storm实时处理Cookbook，通过在OSX上设置Storm，当然还有来自Nathan的所有内容。目前，我已经使用“木偶”和“Vagrant”在一台机器上设置了一个集群，该机器具有用于Nimbus、和两个监督员的VM。本地机器本身就是主宰者。我似乎可以从starter 提交示例拓扑并让它们运行，但是我在通过Storm运行各种工具或验证集群是否真的工作时遇到了一些问题！
following :每当我从它的垃圾箱中运行任何Storm工具(比如storm或风暴日志查看器)时，控制台都会立即发出以下内容，并通常挂起：
Running: java
浏览 0提问于2014-03-20得票数 0
2回答
我已经搜索了这个论坛和谷歌的许多其他，但，无法找到解决我的问题。请帮帮忙。
问题是：
我使用的是apache-storm-0.9.3，动物园管理员-3.4.6和kafka_2.8.0-0.8.1.1
我把所有东西都放在我的本地机器上。
我的主管一开始就抛出错误并抛出msg -->>杀死:没有这样的过程.
下面是我在屏幕上发现的..。
> storm supervisor
Running: /usr/local/jdk1.8.0_05/bin/java -server -Dstorm.options= -Dstorm.home=/usr/local/apache-storm
浏览 1提问于2015-02-17得票数 2
回答已采纳
我正在使用Parse.ly/streamparse ()编写一个风暴拓扑，其中包含一个从json文档发出的元组，该元组将针对指定字段进行解析，并保存每个指定字段中实例的运行总数，以及每个字段中最常见的十个实例。它工作得很好，除了进程在读完输入json之前被终止。我对此仍然是个新手，所以我的第一个方法是简单地检查我的storm拓扑中的每个文件，看起来是否有可能导致进程提前终止的代码，但我找不到这样的代码。谷歌也一直让我失望。
一些我觉得可能相关的文件(拓扑中的文件太多了，我几乎不能发布)
喷嘴：
from __future__ import absolute_import, print_func
浏览 1提问于2015-05-19得票数 2
我正在运行以下Storm安装程序(在Ubuntu 16.4 64位上)。
风暴: 0.10.1
Hadoop: 2.5.2 (本地伪集群)
Hbase: 1.1.5 (本地伪集群)
jar的编译器: maven
通过导入函数使用默认的hbase风暴支持类: org.apache.storm.hbase.bolt.HbaseBolt和mapper.SimpleHBaseMapper。
我试图用一个" Hbase“螺栓写到Hbase DB。在此过程中，我得到以下错误：
016-07-30 21:06:14.874 b.s.util [ERROR] Async l
浏览 1提问于2016-07-30得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
