Skip to content
This repository has been archived by the owner on Jan 20, 2022. It is now read-only.

Feature/storm new planner #250

Merged
merged 14 commits into from
Sep 26, 2013
Merged

Feature/storm new planner #250

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
14 commits
Select commit Hold shift + click to select a range
ffed864
Fix building warnings
ianoc Sep 23, 2013
81dccc9
Use new storm planner for building storm topologies
ianoc Sep 23, 2013
eb3c911
Extend .gitignore for eclipse files
ianoc Sep 23, 2013
59dcf8b
Rename the StormNodes to just Nodes. Clean up a bit more, remove the …
ianoc Sep 23, 2013
71b28d2
Name nodes better, include child producer info
ianoc Sep 24, 2013
68a8b2d
Fixed bug introduced by rename
ianoc Sep 24, 2013
13d4f1e
Merge remote-tracking branch 'origin/feature/use_arbitrary_in_tests' …
ianoc Sep 24, 2013
9253c2c
Look up the config in the first found transitive dependency NamedProd…
ianoc Sep 24, 2013
0b48de9
Add named producer to test cases and code to handle
ianoc Sep 24, 2013
1d5284f
Address comments, make the IdentityOperation a sub class
ianoc Sep 24, 2013
ec3128b
Address naming issues to avoid confusion
ianoc Sep 26, 2013
0281d52
Fix tests to match
ianoc Sep 26, 2013
56b0b25
Fix platform bugs
ianoc Sep 26, 2013
a056915
Add information about how we map between clusters to the output graph
ianoc Sep 26, 2013
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
Fix building warnings
  • Loading branch information
@ianoc
ianoc committed Sep 23, 2013
commit ffed86444e9b586d9e01d368b2e4e0daa9951be6
2 changes: 1 addition & 1 deletion summingbird-client/src/test/scala/com/twitter/summingbird/store/ClientStoreLaws.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ class ClientStoreLaws extends Specification {
val retMap = clientStore.multiGet(keys)

def assertPresent[T](f: Future[T], comparison: T) {
assert(f.isReturn && f.get == comparison)
assert(f.isReturn && Await.result(f) == comparison)
}

"ClientStore should return a map from multiGet of the same size as the input request" in {
Expand Down
1 change: 1 addition & 0 deletions summingbird-storm/src/main/java/com/twitter/summingbird/storm/spout/FixedTupleSpout.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,7 @@ public static void clear(String stormId) {
private List<FixedTuple> _tuples;
private SpoutOutputCollector _collector;

@SuppressWarnings("unused")
private TopologyContext _context;
private List<FixedTuple> _serveTuples;
private Map<String, FixedTuple> _pending;
Expand Down