Questions tagged [heron]

Heron is Twitter's 2nd generation real-time analytics platform that is fully API-compatible with Storm.

Heron is a general-purpose stream processing engine designed for speedy performance, low latency, isolation, reliability, and ease of use for developers and administrators alike. Heron was open sourced by Twitter in May 2016.

Heron's Design Goals

From the beginning, Heron was envisioned as a new kind of stream processing system, built to meet the most demanding of technological requirements, to handle even the most massive of workloads, and to meet the needs of organizations of all sizes and degrees of complexity. Amongst these requirements:

The ability to process billions of events per minute Extremely low end-to-end latency Predictable behavior regardless of scale and in the face of issue like extreme traffic spikes and pipeline congestion Simple administration, including: The ability to deploy on shared infrastructure Powerful monitoring capabilities Fine-grained configurability Easy debuggability To meet these requirements, a few core design goals have guided—and continue to guide—Heron’s development:

  • Modularity
  • Extensibility
  • Isolation
  • Constrained resource usage
  • Apache Storm compatibility
  • Backpressure handling
  • Multiple delivery semantics

Resources

Heron Resources includes:

Videos

Official Blog Posts

Community Blog Posts

Slides

Press

Documentation

GitHub

User Group

42 questions
11
votes
2 answers

Apache Flink vs Twitter Heron?

There are a lot of questions comparing Flink vs Spark Streaming, Flink vs Storm and Storm vs Heron. The origin of this question is from the fact that both Apache Flink and Twitter Heron are true stream processing frameworks (not micro-batch, like…
experimenter
  • 878
  • 1
  • 11
  • 27
3
votes
1 answer

debugging apache heron sccheduler

Twitter claims that one of the greatest advantages of apache heron compared to apache storm is debug-ability and that is achieved by moving each spout/bolt task to one Heron Instance(a JVM Process) instead of bundling multiple tasks to one JMV(how…
Firouziam
  • 777
  • 1
  • 9
  • 31
2
votes
1 answer

Kafka Integration in Apache Heron

I am trying to integrate Kafka with a Heron Topology. However, I am not able to find any examples with the latest version of Heron (0.17.5). Is there any example that can be shared or any suggestions on how to implement a custom Kafka Spout and…
2
votes
2 answers

The exception java.lang.VerifyError: Bad type on operand stack happend in Heron

I tried to get the PhysicalPlan from zookeeper using the following codes: String stateMgrClass = Context.stateManagerClass(this.config); IStateManager stateManager = null; stateManager =…
Yitian Zhang
  • 314
  • 1
  • 3
  • 18
2
votes
2 answers

Can't deploy topology on Heron on Kubernetes

I have a kubernetes-cluster setup and running. I deployed Heron on my Kubernetes Cluster and I'm able to access the Heron UI. $ kubectl get services NAME TYPE CLUSTER-IP EXTERNAL-IP PORT(S) …
SebastienPattyn
  • 393
  • 4
  • 18
2
votes
2 answers

Maximum spout capacity

I'm using Heron for performing streaming analytics on IoT data. Currently in the architecture there is only one spout with parallelism factor 1. I'm trying to benchmark the stats on the amount of data Heron can hold in the queue which it internally…
tourist
  • 4,165
  • 6
  • 25
  • 47
2
votes
1 answer

Unable to clone the repository in git_repository in bazel with ubuntu 15.10

I am trying to compile the following heron branch https://github.com/twitter/heron/tree/karthik/pexbuild using bazel 0.3.1 in ubuntu 15.10. In the workspace, I refer to another repo containing the pex bazel rules…
Karthik
  • 132
  • 2
2
votes
2 answers

How to use Twitter Heron with Storm Flux

I am trying to migrate a project from apache-storm to twitter-heron. After a lot of struggle, I was able to get rid of most of the errors, such as use className: "org.apache.storm.kafka.ZkHosts" instead of className: "storm.kafka.ZkHosts". However,…
1
vote
1 answer

How to config the heron-core file in Heron 0.17.5 version?

When I used heron 0.17.1 version, I can config the heron-core file as following: # location of the core package heron.package.core.uri: "/heron/dist/heron-core.tar.gz" # Whether role/env is required to submit a topology.…
Yitian Zhang
  • 314
  • 1
  • 3
  • 18
1
vote
2 answers

Difference between Apache nifi and Apache Heron(Storm)

I'm working on a academic project which involves working on stream data from sensors. I've rounded on Heron(Successer of storm) and Nifi. Both have support for back pressure inbuilt which is crucial for my project. What are the main differences…
tourist
  • 4,165
  • 6
  • 25
  • 47
1
vote
1 answer

differences between classes in backtype.storm & org.apache.storm & com.twitter.heron packages

I want to write some custom schedulers for apache heron, and i'm diving a little deep into the source code. I noticed that in the heron source code there are couple of packages with similar classes. For example most of classes in backtype.storm &…
Firouziam
  • 777
  • 1
  • 9
  • 31
1
vote
2 answers

heron Topologies keep running after deactivating

I'm currently working on Heron & Apache Storm for some resource management and scheduling Research. I noticed that after submitting topologies to Heron, they start running and taking resources, but after deactivating them, it appears that they are…
0
votes
2 answers

Converting a Storm 1 Kafka Topology to Heron, have a few questions

Been experimenting with switching a Storm 1.0.6 topology to Heron. Taking a baby step by removing all but the Kafka spout to see how things go. Have a main method as follows (modified from the original Flux version): import…
0
votes
1 answer

Dhalion running on Heron by default?

I trying to figure out if Dhalion runs on Heron by Default in all of the versions of the heron incubator project. I see that there is Dhalion is merged in the Heron Repo, but it's not really clear from the documentation as to whether Dhalion is…
Vinay
  • 952
  • 2
  • 10
  • 27
0
votes
2 answers

How to access Backpressure Metrics in Heron (Json File)

I would like to have access to say a JSON file that holds all the details of all the heron instances in a topology (i.e. all the data shown in the heron-ui). I can't find a way to get these details. I am particularly looking for the backpressure…
Vinay
  • 952
  • 2
  • 10
  • 27
1
2 3