About 109 results
  1. stream - How to dispatch tuple to different blot in storm

    up vote 1 down vote favorite everyone.I want to do the job—— one spout emit numbers to blotA,and BlotA emit odd number to Blot_odd , BlotA emit even number to B
  2. storm教程

    2015年07月10日 - 二、安装部署   一、storm伪分布式安装 (一)环境准备 1、OS:debian 7 2、JDK 7.0 (二)安装zookeeper 1、下载zookeeper并解压  wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.6/zookeeper
  3. java - Add retry mechanism for bolt on Apache Storm

    up vote 0 down vote favorite I have a bolt (dispatcher) in my storm topology which open http request connection. I want to add retry mechanism in-case of failur
  4. 为什么选择Twitter Storm?

    Rationale 在过去的十年里,数据处理发生了革命性的变化。MapReduce,Hadoop,以及相关的技术使我们可以存储和处理以前不可想象规模的数据。很遗憾,这些数据处理系统都不是实时系统,命中注定也不是它们。根本没办法把Hadoop变成一个实时系统;实时数据处理和批处理的许多要求在根本上有很大不同。   然而,
  5. jar - converting storm topology to flink - "no entry class specified"?

    up vote 2 down vote favorite I'm working through these directions to convert an existing storm topology into a flink job. I have flink 1.0 (SNAPSHOT) installed
  6. Storm cannot fetch message from Kafka with the message: Got fetch request with offset out of range

    up vote 1 down vote favorite I'm newbie in Storm world. In my topology, I am consuming data from Kafka and I use SpoutConfig. With some tests, I got the followi
  7. parallel processing - Storm supports task or data parallelism?

    up vote 1 down vote favorite 1 I am trying to learn the parallelism and scalability features offered by Storm and read the following article http://storm.apache
  8. Apache Storm Tuple Replay Count

    up vote 0 down vote favorite I'm using Apache Storm for parallel processing. I'd like to detect when the tuple is on its last replay count so that if it fails a
  9. java - Storm Supervisor daemon dies: No space left on device exception

    up vote 1 down vote favorite I am running a storm cluster on a single node i.e. nimbus, supervisor all are running on the same node in distributed mode. The top
  10. java - How to set storm worker's JVM max heap size?

    up vote 3 down vote favorite I'm new to Storm programming and I've got a job to do a test on a custom grouping method to see if it's better or not. So I have to