Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / salesforce/storm-dynamic-spout issues and pull requests

#135 - Bump guava from 25.1-jre to 29.0-jre

Pull Request - State: open - Opened by dependabot[bot] over 3 years ago
Labels: dependencies

#134 - Upgrade guava

Pull Request - State: open - Opened by stanlemon about 4 years ago
Labels: cla:signed

#133 - [Snyk] Security upgrade com.google.guava:guava from 25.1-jre to 30.0-android

Pull Request - State: open - Opened by snyk-bot about 4 years ago
Labels: cla:signed

#132 - Bump checkstyle from 8.26 to 8.29

Pull Request - State: closed - Opened by dependabot[bot] almost 5 years ago
Labels: dependencies

#131 - Updated Documentation

Pull Request - State: closed - Opened by stanlemon about 5 years ago - 1 comment

#130 - Remove FilterChainBuilder and serialize the steps directly

Pull Request - State: closed - Opened by stanlemon about 5 years ago
Labels: cla:signed

#129 - 0.9.5 Bump Storm & Curator

Pull Request - State: closed - Opened by stanlemon about 5 years ago

#128 - Bump checkstyle from 8.11 to 8.18

Pull Request - State: closed - Opened by dependabot[bot] about 5 years ago
Labels: dependencies

#127 - Switch to OpenJDK

Pull Request - State: closed - Opened by stanlemon over 5 years ago - 1 comment
Labels: cla:signed

#126 - [Snyk] Fix for 1 vulnerable dependencies

Pull Request - State: closed - Opened by snyk-bot over 5 years ago - 1 comment
Labels: cla:missing

#124 - [Snyk] Fix for 1 vulnerable dependencies

Pull Request - State: closed - Opened by snyk-bot over 5 years ago - 1 comment
Labels: cla:missing

#123 - Implement helper for handling trigger events

Pull Request - State: closed - Opened by stanlemon almost 6 years ago
Labels: cla:signed

#122 - Fix sideline zk configuration

Pull Request - State: closed - Opened by stanlemon almost 6 years ago - 1 comment

#121 - Store sideline filters as JSON

Pull Request - State: closed - Opened by stanlemon almost 6 years ago
Labels: cla:signed

#120 - Zookeeper reference implementation cleanup

Pull Request - State: closed - Opened by stanlemon over 6 years ago

#119 - Add DropwizardRecorder implementation of MetricsRecorder for use with Storm 1.2

Pull Request - State: closed - Opened by stanlemon over 6 years ago - 2 comments

#118 - Metrics Refactoring

Pull Request - State: closed - Opened by stanlemon over 6 years ago - 1 comment

#117 - Upgrade to Storm 1.2 metrics methods

Issue - State: closed - Opened by stanlemon over 6 years ago - 2 comments

#116 - 0.10.x Integration - DO NOT MERGE

Pull Request - State: closed - Opened by stanlemon over 6 years ago

#115 - Upgrade curator

Pull Request - State: closed - Opened by stanlemon over 6 years ago - 1 comment
Labels: cla:signed

#114 - Rename DefaultRetryManager to ExponentialRetryManager

Pull Request - State: closed - Opened by stanlemon over 6 years ago - 3 comments
Labels: cla:signed

#113 - Rename examples to recipes

Pull Request - State: closed - Opened by stanlemon over 6 years ago

#112 - Cleanup dependencies

Pull Request - State: closed - Opened by stanlemon over 6 years ago

#111 - Update dependencies and cleanup

Pull Request - State: closed - Opened by stanlemon over 6 years ago - 2 comments

#110 - Change the default retry delay to have exponential growth

Pull Request - State: closed - Opened by mmoldavan over 6 years ago - 6 comments
Labels: cla:signed

#109 - Update Kafka dependency, update Kafka-JUnit dependency

Pull Request - State: closed - Opened by Crim over 6 years ago - 1 comment

#108 - Fix typos

Pull Request - State: closed - Opened by ryanguest over 6 years ago - 1 comment
Labels: cla:signed

#107 - Backporting fail stream to 0.9

Pull Request - State: closed - Opened by stanlemon over 6 years ago - 5 comments
Labels: cla:signed

#106 - Backport fail stream to 0.9

Pull Request - State: closed - Opened by stanlemon over 6 years ago

#104 - Swap around code in try block

Pull Request - State: closed - Opened by Crim almost 7 years ago - 4 comments

#102 - Test / Verify what happens when Kafka Brokers become unavailable

Issue - State: open - Opened by Crim almost 7 years ago

#101 - [ISSUE-100] - Fix NPE in RatioMessageBuffer on spout deploy

Pull Request - State: closed - Opened by Crim almost 7 years ago

#100 - RatioMessageBuffer NPEs on Spout deploy

Issue - State: closed - Opened by Crim almost 7 years ago

#99 - Do not pass empty ending state when loading sidelines

Pull Request - State: closed - Opened by stanlemon almost 7 years ago

#98 - Allow null keys in the Utf8Deserializer

Pull Request - State: closed - Opened by stanlemon almost 7 years ago - 1 comment

#97 - Set sideline defaults when loading config

Pull Request - State: closed - Opened by stanlemon almost 7 years ago - 1 comment

#96 - Switching test to use the in memory persistence adapters

Pull Request - State: closed - Opened by stanlemon almost 7 years ago - 3 comments

#95 - Remove references to sideline from DynamicSpout tests

Pull Request - State: closed - Opened by Crim almost 7 years ago

#94 - Catch and swallow no-node exceptions (#93)

Pull Request - State: closed - Opened by Crim almost 7 years ago - 1 comment

#93 - Catch and swallow no-node exceptions

Pull Request - State: closed - Opened by Crim almost 7 years ago - 1 comment

#92 - Race condition on VirtualSpout close cleaning up consumer state

Issue - State: closed - Opened by Crim almost 7 years ago - 2 comments
Labels: bug, Dynamic Spout

#91 - Minor tweaks relating to our Metric refactor

Pull Request - State: closed - Opened by Crim almost 7 years ago

#90 - First pass at a permanently failed output stream from the spout.

Pull Request - State: closed - Opened by Crim almost 7 years ago

#89 - Fix failed message leak. the message was never removed from trackedMap in certain scenarios

Pull Request - State: closed - Opened by Crim almost 7 years ago - 2 comments

#88 - Check for nulls and log accordingly, skip as appropriately

Pull Request - State: closed - Opened by stanlemon almost 7 years ago - 2 comments

#87 - More fair partition distribution with weird number of partitions

Pull Request - State: closed - Opened by stanlemon almost 7 years ago - 4 comments

#86 - Check for nulls and log accordingly

Pull Request - State: closed - Opened by stanlemon almost 7 years ago - 4 comments

#85 - Fix ordering bug in DefaultRetryManager.

Pull Request - State: closed - Opened by Crim almost 7 years ago

#84 - Inconsistent default config values

Issue - State: closed - Opened by daniel-dara almost 7 years ago - 1 comment

#83 - Null Pointer Exceptions in SidelineSpoutHandler and Consumer

Issue - State: closed - Opened by daniel-dara almost 7 years ago - 3 comments

#82 - first pass at creating a concrete SpoutConfig class, lots of refactor…

Pull Request - State: closed - Opened by Crim almost 7 years ago - 3 comments

#81 - Remove un-used method from Consumer interface

Pull Request - State: closed - Opened by Crim almost 7 years ago

#80 - Define Concrete Config classes for DynamicSpout, Sideline, and KafkaConsumer

Issue - State: open - Opened by Crim almost 7 years ago - 1 comment

#79 - Add support for resume state in sidelining

Pull Request - State: closed - Opened by stanlemon almost 7 years ago - 2 comments

#78 - Add getFilterChain() to DelegateSpout

Pull Request - State: closed - Opened by stanlemon almost 7 years ago

#77 - Test fixes

Pull Request - State: closed - Opened by stanlemon almost 7 years ago

#76 - Remove TopologyContext from VirtualSpout

Pull Request - State: closed - Opened by stanlemon almost 7 years ago - 4 comments

#74 - Deserialize JSON directly to SidelinePayload

Pull Request - State: closed - Opened by stanlemon almost 7 years ago

#73 - Fix logic around re-adding the firehose

Pull Request - State: closed - Opened by stanlemon almost 7 years ago

#72 - Switch to using ConsumerPartition for sideline persistence

Pull Request - State: closed - Opened by stanlemon almost 7 years ago

#71 - Use a factory to create VirtualSpout instances

Pull Request - State: closed - Opened by stanlemon almost 7 years ago

#70 - Reconcile DelegateSpout & VirtualSpout nomenclature

Issue - State: open - Opened by stanlemon almost 7 years ago - 3 comments

#69 - Allow ending state to be set after a VirtualSpout has been created

Pull Request - State: closed - Opened by stanlemon almost 7 years ago

#68 - Dropping requestStop() from the DelegateSpout

Pull Request - State: closed - Opened by stanlemon almost 7 years ago - 7 comments

#67 - Remove metric from VirtualSpout API

Pull Request - State: closed - Opened by stanlemon almost 7 years ago - 1 comment

#66 - Breaking up Integration tests

Pull Request - State: closed - Opened by Crim almost 7 years ago - 1 comment

#65 - Documentation re-arrangement

Pull Request - State: closed - Opened by Crim almost 7 years ago - 1 comment

#64 - SidelineSpoutHandler::loadSidelines fails to relaunch the Firehose VirtualSpout

Issue - State: closed - Opened by Crim almost 7 years ago - 3 comments
Labels: bug

#63 - Add missing close implementation, better naming of threads

Pull Request - State: closed - Opened by Crim almost 7 years ago - 1 comment

#62 - Fix failing tests from bad merge.

Pull Request - State: closed - Opened by Crim almost 7 years ago

#61 - fix bad merge

Pull Request - State: closed - Opened by Crim almost 7 years ago

#60 - Call close() to ensure background threads are stopped

Pull Request - State: closed - Opened by Crim almost 7 years ago - 1 comment

#59 - Provide mechanism for defining metrics

Pull Request - State: closed - Opened by Crim almost 7 years ago - 3 comments

#58 - No longer start virtualspouts from a background thread

Pull Request - State: closed - Opened by Crim almost 7 years ago

#56 - Just compares the differences between CoordinatorFacades <--> CoordinatorRefactor branches

Pull Request - State: closed - Opened by Crim almost 7 years ago - 1 comment

#55 - Coordinator Refactor

Pull Request - State: closed - Opened by Crim almost 7 years ago - 1 comment

#54 - retrieveSidelineRequest() should deserialize directly to SidelinePayload

Issue - State: closed - Opened by stanlemon almost 7 years ago
Labels: enhancement

#53 - MessageBus / Coordinator Abstraction

Pull Request - State: closed - Opened by Crim almost 7 years ago
Labels: enhancement

#52 - Refactor to use kafka-junit external dependency

Pull Request - State: closed - Opened by Crim almost 7 years ago

#51 - Remove Kafka-Test-Server from this project, and make into its own project

Issue - State: closed - Opened by Crim almost 7 years ago
Labels: enhancement

#50 - Slightly tweak how the metrics are calculated, condense into a single loop

Pull Request - State: closed - Opened by Crim almost 7 years ago - 2 comments

#49 - Investigate long running tests

Issue - State: open - Opened by stanlemon about 7 years ago - 1 comment

#48 - Add a reference implementation of a SidelineTrigger using Zookeeper watches

Pull Request - State: closed - Opened by stanlemon about 7 years ago - 8 comments
Labels: enhancement

#47 - SidelineSpoutHandler should periodically check its state and recover

Pull Request - State: closed - Opened by stanlemon about 7 years ago - 3 comments
Labels: enhancement

#46 - [SIDELINE] Trigger reference implementation

Issue - State: closed - Opened by stanlemon about 7 years ago - 3 comments
Labels: enhancement

#45 - Drop VirtualSpout.getMaxLag() and pass the MetricsRecorder to Consumer

Pull Request - State: closed - Opened by stanlemon about 7 years ago - 13 comments
Labels: enhancement

#44 - Add consumer id to the Record object

Pull Request - State: closed - Opened by stanlemon about 7 years ago - 5 comments

#43 - Limit the recursion in fillBuffer()

Pull Request - State: closed - Opened by stanlemon about 7 years ago - 2 comments

#42 - [KAFKA] Limit the number of times fillBuffer() can be called recursively

Issue - State: closed - Opened by stanlemon about 7 years ago
Labels: bug

#41 - Add consumer id to consumer record

Issue - State: closed - Opened by daniel-dara about 7 years ago - 2 comments
Labels: enhancement

#40 - Metrics cleanup

Pull Request - State: closed - Opened by stanlemon about 7 years ago - 5 comments
Labels: enhancement

#27 - [SIDELINE] Monitor and manage sideline spouts in the SpoutCoordinator

Issue - State: closed - Opened by stanlemon about 7 years ago - 3 comments
Labels: enhancement, Sideline

#22 - [KAFKA] On Consumer offset out of range, number of processed messages stat becomes incorrect

Issue - State: open - Opened by Crim about 7 years ago - 1 comment
Labels: bug, monitoring, Kafka Consumer

#21 - [SIDELINE] Better checking for bad filter chain steps

Issue - State: closed - Opened by stanlemon about 7 years ago - 4 comments
Labels: bug, Sideline

#19 - Break DynamicSpout, KafkaConsumer, and SidelineSpout into separate modules

Issue - State: open - Opened by Crim about 7 years ago - 2 comments
Labels: enhancement

#8 - README needs overhaul.

Issue - State: closed - Opened by Crim about 7 years ago - 2 comments
Labels: enhancement