merge changes from nathanmarz/storm master #17
Merged
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
* Added new metric type, 'StateMetric', to report direct metrics of anything that meets the IStatefulObject interface * Added methods for population, capacity, and read/write head positions to Disruptor Queue; gave it a getState() to make it IStatefulObject * Register the transfer queue and the send and receive queues for spouts and bolts (note: there is currently one metric per _task_, each documenting its executor's queue). We cheat and register the transfer queue in executor.clj because within a Java implementation of the bolt (specifically, the System bolt), we don't have access to the executor data -- we need a TopologyContext, which is only prepared for tasks. If there's a way to get this, please advise. Note that the code is (knowingly) not thread-safe: it's possible for the write position to move between getting the read and write head positions, but in practice it shouldn't change the actionable value. We do make sure to get the read and then the write so that it is never an under-estimate of the capacity (or negative).
Changed other schema tests not bubble up exceptions but only to report failure when a schema is invalid.
Fixes schema for isolation.scheduler.machines: Map
…bug where the same resource is returned more than once
unique URLs in findAndReadConfigFile to work around apparent sbt/nsc bug
make FixedTupleSpout implement IRichSpout so it can be used for tests
…without jar files. This fixes it by forcing lein to store jar in the same path it use to, target/... instead of target/profile-name/...
Fixes build_release.sh issue when using leiningen v2.3
Adding check to disallow topology submission if the topology name is blank. In one of the scenarios, we had pushed a topology with an empty name, and it showed up on the ui with only the uid. Also since it did not have any name we could not go into "Topology Details" to kill it, and hence had to clean up the state on the disk so that Nimbus kills the topology.
Corrected formatting
Update nimbus.clj
Wrapping all curator exceptions in RuntimeExceptions.
Ignoring a FileNotFound excpetion that can bring down a supervisor.
Disruptor queue metrics (patch for #613)
ui and log viewer send proper html pages
An extra space was being included before -Dstorm.jar when no JAR_JVM_OPTS was specified.. this was causing an exception from java for class not found
Fix for STORM_JAR_JVM_OPTS which is currently broken when STORM_JAR_JVM_OPTS is not specified
Fix local cluster mode RuntimeException
Use 'equals()' method to String comparison instead '=='
…y messaging, and set up some reasonable defaults for Netty.
Adds macro while-timout to avoid test hangs
Add in the ability to configure the number of worker threads for Netty...
Fixed negative netty sleep values.
Do the worker HB timeout check when HB's are updated
fix the issue that tick tuple cannot work with system bolt
anfeng
added a commit
that referenced
this pull request
Nov 3, 2013
merge changes from nathanmarz/storm master
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
No description provided.