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

    http://stackoverflow.com/questions/30097433/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教程

    http://www.cnblogs.com/jinhong-lu/p/4634912.html
    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

    http://stackoverflow.com/questions/27469933/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?

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

    http://stackoverflow.com/questions/33324905/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

    http://stackoverflow.com/questions/32890642/storm-cannot-fetch-message-from-kafka-with-the-message-got-fetch-request-with-o
    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?

    http://stackoverflow.com/questions/34805527/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

    http://stackoverflow.com/questions/32172686/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

    http://stackoverflow.com/questions/29672946/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?

    http://stackoverflow.com/questions/35864128/how-to-set-storm-workers-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