https://github.com/twitter/heron

sort by:
Revision Author Date Message Commit Date
8b9bbe9 moved mempool to basics 27 May 2017, 15:21:13 UTC
b65f2b9 Merge branch 'master' into sanjeevk/ext1_protopool 27 May 2017, 04:01:03 UTC
990ae5e Added helper methods to physial plan helper (#1905) 27 May 2017, 03:56:23 UTC
9fd3da2 Add API support for backpressure metric (instance level) & display backpressure (instance level) in Heron UI (#1791) 27 May 2017, 00:45:05 UTC
6858133 Removes the last 2 instances of Thread.sleep() from the tests (#1911) * refactor metrics manager tests to not use THread.sleep * Also refactoring MetricsCacheSinkTest * Remove the last 2 instances of Thread.sleep() * fix javadocs * merge from master 26 May 2017, 23:14:18 UTC
6d81d8c Refactor BoltInstanceTest and SpoutInstanceTest to not use Thread.sleep() (#1900) * Add SlaveTester to centralize duplicate slave, looper, communicator test logic * Decoupled CommunicatorTester from SlaveTester * consolidate duplicate initialization logic * Removing sleeps from bolt/spout tests, clean up communicator * Moving field into Constants and removing unused Constant values * Update AbstractNetworkTest to use the new CommunicatorTester constructor * Move countdown latch past the static increment logic * Make expectedTuples final 26 May 2017, 20:52:01 UTC
f64afa0 Merge pull request #1865 from huijunwu/order_unittest improve order_unittest 26 May 2017, 17:55:56 UTC
093278e Merge branch 'master' of https://github.com/twitter/heron into order_unittest 26 May 2017, 17:50:36 UTC
07067e6 fix unit test (#1906) 26 May 2017, 17:46:49 UTC
c82cef3 Removed per client/server specific acquire/release and consolidated it in one place 26 May 2017, 17:30:16 UTC
cc5a5b9 add ckptmgr client in tmaster (#1901) 26 May 2017, 00:59:10 UTC
f71ada3 add ckptmgr client in stmgr (#1902) 26 May 2017, 00:58:49 UTC
a9cf457 Added helper methods for stateful operations (#1898) * Added helper methods for stateful operations * Took feedback into consideration * Use common method to elminate repetive code 26 May 2017, 00:24:47 UTC
233b54f replace 5 seconds to const val 26 May 2017, 00:24:05 UTC
595e709 Refactor common netwrok test code into a superclass (#1899) * Add SlaveTester to centralize duplicate slave, looper, communicator test logic * Decoupled CommunicatorTester from SlaveTester * Refactoring out duplicate code in network tests * consolidate duplicate initialization logic * fix typo * clean-up per feedback 26 May 2017, 00:12:28 UTC
d60c52c cleanup stateful configs and statefulstorage package (#1903) 25 May 2017, 23:23:57 UTC
9ea9e85 Add SlaveTester to centralize duplicate slave, looper, communicator test logic (#1893) * Add SlaveTester to centralize duplicate slave, looper, communicator test logic * Decoupled CommunicatorTester from SlaveTester * consolidate duplicate initialization logic 25 May 2017, 19:53:21 UTC
a4b9da2 refactor metrics manager tests to not use Thread.sleep (#1887) * refactor metrics manager tests to not use THread.sleep * Also refactoring MetricsCacheSinkTest 25 May 2017, 19:08:30 UTC
f8a5cf9 Another attempt to fix flakey HeronServerTest (#1897) 25 May 2017, 18:04:24 UTC
4bdaab3 Added config variable/helper function that govern the amount of (#1896) data stmgr can buffer waiting for checkpoint markers before giving up 25 May 2017, 17:43:28 UTC
6903a6f Fix flakey HeronServerTest test (#1895) 24 May 2017, 23:08:45 UTC
f4ffebe delete latch 24 May 2017, 21:46:56 UTC
5a41479 Merge branch 'master' of https://github.com/twitter/heron into order_unittest 24 May 2017, 21:42:04 UTC
1921c19 Merge pull request #1847 from huijunwu/bind0 use bind port 0 to solve port conflict in switch_unittest.cpp 24 May 2017, 21:34:52 UTC
7c369dc start ckptmgr in heron_executor if topology is stateful (#1885) 24 May 2017, 20:10:31 UTC
085ef61 delete latch 24 May 2017, 18:14:09 UTC
3733547 Check intermediate result of metricsMgrTmasterLatch in stmgr unit test (#1832) 24 May 2017, 02:22:08 UTC
9c962ca Refactor ActivateDeactivateTest to not use Thread.sleep() (#1892) 23 May 2017, 23:35:50 UTC
087044e Refactor CacheCoreTest to not use Thread.sleep() (#1890) 23 May 2017, 23:29:27 UTC
5ebe82d Refactor WebSionkTest to not use Thread.sleep() (#1889) 23 May 2017, 22:12:14 UTC
404e4ab Update HeronServerTest to use HeronServerTester (#1886) 23 May 2017, 16:47:49 UTC
6dbfb8b Further improve heron-shell (#1882) 22 May 2017, 23:09:53 UTC
b81446d addd integration-test to eclipse setup (#1883) 22 May 2017, 23:06:33 UTC
bc20dba Update EchoTest to use HeronServerTester (#1884) 22 May 2017, 21:45:20 UTC
053c77c update stateful related configs (#1881) update stateful related configs 22 May 2017, 17:57:26 UTC
514705c Add support for emit direct (#1855) * Adding support for direct grouping * remove mistaken commit * Renamed variables to emitDirectTaskId to be more explicit 22 May 2017, 16:55:53 UTC
4e6c5ba Clean up SinkExecutorTest (#1878) 22 May 2017, 16:54:32 UTC
1fe1d5a add stateful config and util methods (#1873) * add stateful config file and methods * add local and aurora stateful config * add dummy stateful.yaml for other schedulers * add stateful.yaml and fix test * update method name * address comment 19 May 2017, 18:18:59 UTC
a8ffec3 Update CheckpointManagerServerTest to nto use HeronServerTester (#1877) 19 May 2017, 16:01:05 UTC
191af53 Remove Thread.sleep() from SinkExecutorTest (#1876) * Remove Thread.sleep() from SinkExecutorTest * Remove Thread.sleep() from SinkExecutorTest 19 May 2017, 15:59:48 UTC
cafbac3 Adding new HeronServerTester to simplify testing servers (#1870) * Adding new HeronServerTester to simplify testing servers * Adding more javadocs * Adding more common functionality required for other HeronServer test classes * Moving inner classes out of HeronServerTester 18 May 2017, 23:59:26 UTC
9fabe0a Label the different ports so that it is easier to see which port maps (#1875) to which functionality 18 May 2017, 23:49:30 UTC
eb7d472 Marathon does not allow upper case applications (#1874) 18 May 2017, 23:31:37 UTC
8a27705 add tmaster zk watch on tmaster location (#1872) 18 May 2017, 22:02:38 UTC
e3f317b Fix heron/common targets to be mutually exclusive (#1867) 17 May 2017, 23:09:34 UTC
d66f453 add stateful checkpoints support in cpp statemgr (#1861) 17 May 2017, 22:18:20 UTC
6f5ee97 package ckptmgr and statefulstorages into heron-core (#1866) 17 May 2017, 21:53:13 UTC
27971da add trace for potential timeout checking 17 May 2017, 20:34:51 UTC
96ef8e7 bind port 0; replace join with async 17 May 2017, 20:18:16 UTC
a905add Use Duration to represent durations of time instead of primatives (#1863) * Change SystemConfig and HeronSocketOptions to use ByteAmount * Remove unused imports * Update ckptmgr code * remove import * Use Duration to represent durations of time instead of longs * Changing CheckpointManagerConfigs to also use Duration 17 May 2017, 18:43:46 UTC
7b90604 add stateful checkpoints support for java statemgrs (#1862) * add stateful checkpoints support for java statemgrs * refactor code * update method names 17 May 2017, 17:57:30 UTC
e9c1488 heron-shell refactor (#1864) 17 May 2017, 16:39:17 UTC
53311d5 Change SystemConfig and HeronSocketOptions to use ByteAmount (#1860) * Change SystemConfig and HeronSocketOptions to use ByteAmount * Remove unused imports * Update ckptmgr code * remove import 16 May 2017, 19:05:50 UTC
52e3ec6 fix the flaky ckptmgr server test (#1858) 15 May 2017, 21:59:09 UTC
b1ff278 Added Checkpoint Manager for stateful topologies (#1831) * Added Checkpoint Manager for stateful topologies 14 May 2017, 17:09:00 UTC
3fb4350 Added docs for marathon / dcos deployments (#1851) 11 May 2017, 18:29:25 UTC
988be93 add port==0 in if checking 10 May 2017, 22:22:19 UTC
9e4067f fix aurora to use maximum resources to start containers (#1850) * use scheduled resource to start aurora job 10 May 2017, 18:02:42 UTC
050d3e8 add comments; replace global var 09 May 2017, 21:44:53 UTC
52855f6 Make storm.Config don't extend heron.api.Config (#1842) * make storm.Config don't extend heron.api.Config 08 May 2017, 23:39:39 UTC
98568c4 add 1 more check 08 May 2017, 22:58:33 UTC
5367fc0 add header 08 May 2017, 22:49:03 UTC
f124e44 sync for port transfer between threads 08 May 2017, 22:45:14 UTC
aeebc81 replace hard coded port to bind0 08 May 2017, 22:34:59 UTC
de06fac update port after bind/listen 08 May 2017, 22:30:01 UTC
9f4a914 Stream subprocess stdout and stderr in heron-executor (#1840) 08 May 2017, 17:29:54 UTC
a037526 Fail Heron-instance fast for errors (#1839) 05 May 2017, 21:15:13 UTC
f1c7f17 create containerResource with updatedPackingPlan (#1836) 05 May 2017, 02:30:55 UTC
c9c7ffa Use Full Metrics in spout and bolt by default (#1834) Basic SpoutMetrics and BoltMetrics are optimized for performance rather than for debugging. Enable Full Metrics by default can provide more insights during debugging. It is also pushed from Product-Safety team from Twitter, which requires more debugging info. The performance hurt will be negligible for production topology compared with actual workload: it will add only a few java hashmap accessing on every execute(). Test on LocalScheduler. 05 May 2017, 00:26:36 UTC
e13d17a turn on IntegrationTest_OneSpoutBoltMultiTasks (#1830) 04 May 2017, 01:00:04 UTC
fb91935 Added proto files declaring all the messages transmitted across (#1829) * Added proto files declaring all the messages transmitted across all different heron components for stateful processing and exactly once semantics * Made changes to the proto structures based on feedback * Seperated out inner message to top * Added description of all the messages. Changed field names as per feedback * Space before { * Fixed comments * Fixed comments * fixed comments 03 May 2017, 23:38:08 UTC
dd5e19f check server start() return value in stmgr unit test (#1827) * check server start return * Update stmgr_unittest.cpp * update duplicated ports * add more desc log 03 May 2017, 19:50:12 UTC
bedb3ad Merge pull request #1648 from jrcrawfo/dcos-support DC/OS Support + Docker-based executors via Marathon 03 May 2017, 05:23:22 UTC
5e33ec5 Added Stateful spout/bolt interfaces and State interface for exactly once (#1820) * Added Stateful spout/bolt interfaces and State interface for exactly once. The design doc is at https://docs.google.com/document/d/1pNuE77diSrYHb7vHPuPO3DZqYdcxrhywH_f7loVryCI/edit# 02 May 2017, 20:37:59 UTC
c7deef5 rename heron/common/src/cpp/config/config.h (#1824) * update the BUILD to change config.h to allconfig.h 02 May 2017, 18:46:20 UTC
94a998e Bump version number on website/config.yaml. (#1822) 27 April 2017, 19:00:54 UTC
0ba7bc4 Refactor output collectors to remove duplicate code (#1821) * Remove duplicate output committer code * not deleting FullBoltMetrics and FullSpoutMetrics * Remove more dup code from similator OutgoingTupleCollection 27 April 2017, 18:12:04 UTC
427719b Making CustomGroupingTest extend an abstract superclass (#1818) * Making CustomGroupingTest extend an abstract superclass * remove bad javadoc character * Fix order of assertEquals values * scrubbing email 26 April 2017, 23:22:25 UTC
3f7933d Fix idea copywrite to match checkstyle checks (#1819) 26 April 2017, 00:14:39 UTC
15f10d1 Better POM. (#1817) 25 April 2017, 21:36:24 UTC
382d4eb Clean up CustomGroupingTest (#1813) * Clean up CustomGroupingTest * Refactored more to set up for extensibility 25 April 2017, 21:30:15 UTC
453acf2 Fix flaky test IntegrationTest_MultiSpoutsMultiTasks (#1815) * fix flaky integration test MultiSpoutsMultiTasks * re-enable IntegrationTest_MultiSpoutsMultiTasks 25 April 2017, 21:00:48 UTC
02c6178 Rename pom file. (#1816) 25 April 2017, 17:50:49 UTC
52a476e Merge pull request #1814 from Detoo/1479-metricsmgr-response-not-ok Fix unexpected non-OK response in metricsmgr_client.py 25 April 2017, 16:04:35 UTC
535c607 Not checking for HOST env variable in executor test 25 April 2017, 05:46:09 UTC
56ed886 Bug fix for marathon scheduler 25 April 2017, 05:42:07 UTC
744d7ac Performing a check to determine if in docker environment 25 April 2017, 05:41:45 UTC
88c578f Properly shade + POM heron-api.jar and heron-storm.jar (#1811) 25 April 2017, 03:52:18 UTC
25c9e95 Fix unexpected non-OK response in metricsmgr_client.py 25 April 2017, 02:58:56 UTC
67f3b9e Fixed a route for the UI with base url 25 April 2017, 02:50:04 UTC
5f67004 Added needed host for tests 23 April 2017, 14:14:38 UTC
78b14be UpdateTopologyManager test should not assert re-activation withg mocks (#1812) 21 April 2017, 19:03:19 UTC
0a47fef Style fix 21 April 2017, 12:05:16 UTC
c3333da Merged in master 21 April 2017, 05:08:55 UTC
4e85f2f Accessing config via class variable. Fix for test 21 April 2017, 04:00:04 UTC
21c7bd2 Refactor to centralize duplicate TopologyAPI.Config logic (#1808) * Refactor to centralize duplicate TopologyAPI.Config logic * Fetching value after checking key * fix bad logger 13 April 2017, 23:27:27 UTC
47575ee Throttle the amount of 'Stop reading due to not yet connected to Stream Manager' log messages emitted (#1806) * Throttle the amount of 'Stop reading due to not yet connected to Stream Manager' log messages emitted * fix typo 11 April 2017, 17:05:33 UTC
73519a3 One-liner to fix Heron Tracker code (#1805) 10 April 2017, 19:13:11 UTC
b31009f Merge pull request #1802 from twitter/karthik/kafka-spout Fixes Kafka spout to use the Storm 1.0+ api change 07 April 2017, 18:31:46 UTC
f236bd5 Merge pull request #1803 from twitter/karthik/libtool include a check to see if glibtool in mac or libtool exists 07 April 2017, 18:20:40 UTC
back to top