incubator-heron
incubator-heron copied to clipboard
apache
Apache Heron (Incubating) is a realtime, distributed, fault-tolerant stream processing engine from Twitter
The related design doc can be found here: https://docs.google.com/document/d/1CaDVVifcWqViRO96tmePK5dwhOhYnhwjhMRuImg-aOs/edit#heading=h.rfm62inflf7w
The function loadConfigFromYaml() is responsible for loading topology and component configs from a yaml file. TopologyBuilder should maintain an internal config object for topology configs. Component configs should be set...
my understanding is that today heron clients dont allow the log level to be specified at run time and this is prebaked in compile time. can we consider a PR...
Hi maintainers, migrating an existing Storm project that relies on [storm-eventhubs](https://github.com/apache/storm/tree/master/external/storm-eventhubs) to use the Streamlet API fails as the interfaces (i.e. `IRichBolt`, `IRichSpout`, etc.) are not compatible. It would be...
Some metrics when exported to prometheus have the instance id in the metric name. This should be a label. Examples: heron_client_stmgr_100_hello_messages_to_stmgrs heron_client_stmgr_1_hello_messages_to_stmgrs heron_execute_count_word_spout_default heron_execute_time_ns_word_default heron_fail_latency_word_default heron_execute_latency_word_default
**To keep work from being duplicated check off a section you would like to do and create one pull request per task please.** Below are a list of things that...
I use heron kubernetes deployment. My application requires an environment variable set in the task container. I can't find a way to do that.
This PR updates Heron to allow for ack and fail behaviour with the Streamlet API. Would request feedback, especially as to the caching of id's and tuples. These updates have...
Currently the release verification is manual and not efficient. A release_check script could be helpful to make the release check much easier to users and improve the turn around time....