8b9bbe9 | Sanjeev Kulkarni | 27 May 2017, 15:21:13 UTC | moved mempool to basics | 27 May 2017, 15:21:13 UTC |
b65f2b9 | Sanjeev Kulkarni | 27 May 2017, 04:01:03 UTC | Merge branch 'master' into sanjeevk/ext1_protopool | 27 May 2017, 04:01:03 UTC |
990ae5e | Sanjeev Kulkarni | 27 May 2017, 03:56:23 UTC | Added helper methods to physial plan helper (#1905) | 27 May 2017, 03:56:23 UTC |
9fd3da2 | Kanishk Karanawat | 27 May 2017, 00:45:05 UTC | Add API support for backpressure metric (instance level) & display backpressure (instance level) in Heron UI (#1791) | 27 May 2017, 00:45:05 UTC |
6858133 | Bill Graham | 26 May 2017, 23:14:18 UTC | 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 | Bill Graham | 26 May 2017, 20:52:01 UTC | 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 | Huijun Wu | 26 May 2017, 17:55:56 UTC | Merge pull request #1865 from huijunwu/order_unittest improve order_unittest | 26 May 2017, 17:55:56 UTC |
093278e | Huijun Wu | 26 May 2017, 17:50:36 UTC | Merge branch 'master' of https://github.com/twitter/heron into order_unittest | 26 May 2017, 17:50:36 UTC |
07067e6 | Neng Lu | 26 May 2017, 17:46:49 UTC | fix unit test (#1906) | 26 May 2017, 17:46:49 UTC |
c82cef3 | Sanjeev Kulkarni | 26 May 2017, 17:30:16 UTC | Removed per client/server specific acquire/release and consolidated it in one place | 26 May 2017, 17:30:16 UTC |
cc5a5b9 | Neng Lu | 26 May 2017, 00:59:10 UTC | add ckptmgr client in tmaster (#1901) | 26 May 2017, 00:59:10 UTC |
f71ada3 | Neng Lu | 26 May 2017, 00:58:49 UTC | add ckptmgr client in stmgr (#1902) | 26 May 2017, 00:58:49 UTC |
a9cf457 | Sanjeev Kulkarni | 26 May 2017, 00:24:47 UTC | 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 | Huijun Wu | 26 May 2017, 00:24:05 UTC | replace 5 seconds to const val | 26 May 2017, 00:24:05 UTC |
595e709 | Bill Graham | 26 May 2017, 00:12:28 UTC | 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 | Neng Lu | 25 May 2017, 23:23:57 UTC | cleanup stateful configs and statefulstorage package (#1903) | 25 May 2017, 23:23:57 UTC |
9ea9e85 | Bill Graham | 25 May 2017, 19:53:21 UTC | 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 | Bill Graham | 25 May 2017, 19:08:30 UTC | 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 | Bill Graham | 25 May 2017, 18:04:24 UTC | Another attempt to fix flakey HeronServerTest (#1897) | 25 May 2017, 18:04:24 UTC |
4bdaab3 | Sanjeev Kulkarni | 25 May 2017, 17:43:28 UTC | 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 | Bill Graham | 24 May 2017, 23:08:45 UTC | Fix flakey HeronServerTest test (#1895) | 24 May 2017, 23:08:45 UTC |
f4ffebe | Huijun Wu | 24 May 2017, 21:46:56 UTC | delete latch | 24 May 2017, 21:46:56 UTC |
5a41479 | Huijun Wu | 24 May 2017, 21:42:04 UTC | Merge branch 'master' of https://github.com/twitter/heron into order_unittest | 24 May 2017, 21:42:04 UTC |
1921c19 | Huijun Wu | 24 May 2017, 21:34:52 UTC | 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 | Neng Lu | 24 May 2017, 20:10:31 UTC | start ckptmgr in heron_executor if topology is stateful (#1885) | 24 May 2017, 20:10:31 UTC |
085ef61 | Huijun Wu | 24 May 2017, 18:14:09 UTC | delete latch | 24 May 2017, 18:14:09 UTC |
3733547 | bed debug | 24 May 2017, 02:22:08 UTC | Check intermediate result of metricsMgrTmasterLatch in stmgr unit test (#1832) | 24 May 2017, 02:22:08 UTC |
9c962ca | Bill Graham | 23 May 2017, 23:35:50 UTC | Refactor ActivateDeactivateTest to not use Thread.sleep() (#1892) | 23 May 2017, 23:35:50 UTC |
087044e | Bill Graham | 23 May 2017, 23:29:27 UTC | Refactor CacheCoreTest to not use Thread.sleep() (#1890) | 23 May 2017, 23:29:27 UTC |
5ebe82d | Bill Graham | 23 May 2017, 22:12:14 UTC | Refactor WebSionkTest to not use Thread.sleep() (#1889) | 23 May 2017, 22:12:14 UTC |
404e4ab | Bill Graham | 23 May 2017, 16:47:49 UTC | Update HeronServerTest to use HeronServerTester (#1886) | 23 May 2017, 16:47:49 UTC |
6dbfb8b | Runhang Li | 22 May 2017, 23:09:53 UTC | Further improve heron-shell (#1882) | 22 May 2017, 23:09:53 UTC |
b81446d | bed debug | 22 May 2017, 23:06:33 UTC | addd integration-test to eclipse setup (#1883) | 22 May 2017, 23:06:33 UTC |
bc20dba | Bill Graham | 22 May 2017, 21:45:20 UTC | Update EchoTest to use HeronServerTester (#1884) | 22 May 2017, 21:45:20 UTC |
053c77c | Neng Lu | 22 May 2017, 17:57:26 UTC | update stateful related configs (#1881) update stateful related configs | 22 May 2017, 17:57:26 UTC |
514705c | Bill Graham | 22 May 2017, 16:55:53 UTC | 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 | Bill Graham | 22 May 2017, 16:54:32 UTC | Clean up SinkExecutorTest (#1878) | 22 May 2017, 16:54:32 UTC |
1fe1d5a | Neng Lu | 19 May 2017, 18:18:59 UTC | 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 | Bill Graham | 19 May 2017, 16:01:05 UTC | Update CheckpointManagerServerTest to nto use HeronServerTester (#1877) | 19 May 2017, 16:01:05 UTC |
191af53 | Bill Graham | 19 May 2017, 15:59:48 UTC | Remove Thread.sleep() from SinkExecutorTest (#1876) * Remove Thread.sleep() from SinkExecutorTest * Remove Thread.sleep() from SinkExecutorTest | 19 May 2017, 15:59:48 UTC |
cafbac3 | Bill Graham | 18 May 2017, 23:59:26 UTC | 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 | Sanjeev Kulkarni | 18 May 2017, 23:49:30 UTC | 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 | Sanjeev Kulkarni | 18 May 2017, 23:31:37 UTC | Marathon does not allow upper case applications (#1874) | 18 May 2017, 23:31:37 UTC |
8a27705 | Neng Lu | 18 May 2017, 22:02:38 UTC | add tmaster zk watch on tmaster location (#1872) | 18 May 2017, 22:02:38 UTC |
e3f317b | Bill Graham | 17 May 2017, 23:09:34 UTC | Fix heron/common targets to be mutually exclusive (#1867) | 17 May 2017, 23:09:34 UTC |
d66f453 | Neng Lu | 17 May 2017, 22:18:20 UTC | add stateful checkpoints support in cpp statemgr (#1861) | 17 May 2017, 22:18:20 UTC |
6f5ee97 | Neng Lu | 17 May 2017, 21:53:13 UTC | package ckptmgr and statefulstorages into heron-core (#1866) | 17 May 2017, 21:53:13 UTC |
27971da | Huijun Wu | 17 May 2017, 20:34:51 UTC | add trace for potential timeout checking | 17 May 2017, 20:34:51 UTC |
96ef8e7 | Huijun Wu | 17 May 2017, 20:18:16 UTC | bind port 0; replace join with async | 17 May 2017, 20:18:16 UTC |
a905add | Bill Graham | 17 May 2017, 18:43:46 UTC | 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 | Neng Lu | 17 May 2017, 17:57:30 UTC | 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 | Runhang Li | 17 May 2017, 16:39:17 UTC | heron-shell refactor (#1864) | 17 May 2017, 16:39:17 UTC |
53311d5 | Bill Graham | 16 May 2017, 19:05:50 UTC | 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 | Neng Lu | 15 May 2017, 21:59:09 UTC | fix the flaky ckptmgr server test (#1858) | 15 May 2017, 21:59:09 UTC |
b1ff278 | Sanjeev Kulkarni | 14 May 2017, 17:09:00 UTC | Added Checkpoint Manager for stateful topologies (#1831) * Added Checkpoint Manager for stateful topologies | 14 May 2017, 17:09:00 UTC |
3fb4350 | John Crawford | 11 May 2017, 18:29:25 UTC | Added docs for marathon / dcos deployments (#1851) | 11 May 2017, 18:29:25 UTC |
988be93 | Huijun Wu | 10 May 2017, 22:22:19 UTC | add port==0 in if checking | 10 May 2017, 22:22:19 UTC |
9e4067f | Neng Lu | 10 May 2017, 18:02:42 UTC | 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 | Huijun Wu | 09 May 2017, 21:44:53 UTC | add comments; replace global var | 09 May 2017, 21:44:53 UTC |
52855f6 | Neng Lu | 08 May 2017, 23:39:39 UTC | 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 | Huijun Wu | 08 May 2017, 22:58:33 UTC | add 1 more check | 08 May 2017, 22:58:33 UTC |
5367fc0 | Huijun Wu | 08 May 2017, 22:49:03 UTC | add header | 08 May 2017, 22:49:03 UTC |
f124e44 | Huijun Wu | 08 May 2017, 22:45:14 UTC | sync for port transfer between threads | 08 May 2017, 22:45:14 UTC |
aeebc81 | Huijun Wu | 08 May 2017, 22:34:59 UTC | replace hard coded port to bind0 | 08 May 2017, 22:34:59 UTC |
de06fac | Huijun Wu | 08 May 2017, 22:30:01 UTC | update port after bind/listen | 08 May 2017, 22:30:01 UTC |
9f4a914 | Andrew Jorgensen | 08 May 2017, 17:29:54 UTC | Stream subprocess stdout and stderr in heron-executor (#1840) | 08 May 2017, 17:29:54 UTC |
a037526 | Maosong Fu | 05 May 2017, 21:15:13 UTC | Fail Heron-instance fast for errors (#1839) | 05 May 2017, 21:15:13 UTC |
f1c7f17 | Neng Lu | 05 May 2017, 02:30:55 UTC | create containerResource with updatedPackingPlan (#1836) | 05 May 2017, 02:30:55 UTC |
c9c7ffa | Maosong Fu | 05 May 2017, 00:26:36 UTC | 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 | bed debug | 04 May 2017, 01:00:04 UTC | turn on IntegrationTest_OneSpoutBoltMultiTasks (#1830) | 04 May 2017, 01:00:04 UTC |
fb91935 | Sanjeev Kulkarni | 03 May 2017, 23:38:08 UTC | 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 | bed debug | 03 May 2017, 19:50:12 UTC | 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 | Karthik Ramasamy | 03 May 2017, 05:23:22 UTC | Merge pull request #1648 from jrcrawfo/dcos-support DC/OS Support + Docker-based executors via Marathon | 03 May 2017, 05:23:22 UTC |
5e33ec5 | Sanjeev Kulkarni | 02 May 2017, 20:37:59 UTC | 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 | Karthik Ramasamy | 02 May 2017, 18:46:20 UTC | 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 | Mark Li | 27 April 2017, 19:00:54 UTC | Bump version number on website/config.yaml. (#1822) | 27 April 2017, 19:00:54 UTC |
0ba7bc4 | Bill Graham | 27 April 2017, 18:12:04 UTC | 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 | Bill Graham | 26 April 2017, 23:22:25 UTC | 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 | Bill Graham | 26 April 2017, 00:14:39 UTC | Fix idea copywrite to match checkstyle checks (#1819) | 26 April 2017, 00:14:39 UTC |
15f10d1 | Mark Li | 25 April 2017, 21:36:24 UTC | Better POM. (#1817) | 25 April 2017, 21:36:24 UTC |
382d4eb | Bill Graham | 25 April 2017, 21:30:15 UTC | Clean up CustomGroupingTest (#1813) * Clean up CustomGroupingTest * Refactored more to set up for extensibility | 25 April 2017, 21:30:15 UTC |
453acf2 | bed debug | 25 April 2017, 21:00:48 UTC | Fix flaky test IntegrationTest_MultiSpoutsMultiTasks (#1815) * fix flaky integration test MultiSpoutsMultiTasks * re-enable IntegrationTest_MultiSpoutsMultiTasks | 25 April 2017, 21:00:48 UTC |
02c6178 | Mark Li | 25 April 2017, 17:50:49 UTC | Rename pom file. (#1816) | 25 April 2017, 17:50:49 UTC |
52a476e | Karthik Ramasamy | 25 April 2017, 16:04:35 UTC | 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 | John Crawford | 25 April 2017, 05:46:09 UTC | Not checking for HOST env variable in executor test | 25 April 2017, 05:46:09 UTC |
56ed886 | John Crawford | 25 April 2017, 05:42:07 UTC | Bug fix for marathon scheduler | 25 April 2017, 05:42:07 UTC |
744d7ac | John Crawford | 25 April 2017, 05:41:45 UTC | Performing a check to determine if in docker environment | 25 April 2017, 05:41:45 UTC |
88c578f | Mark Li | 25 April 2017, 03:52:18 UTC | Properly shade + POM heron-api.jar and heron-storm.jar (#1811) | 25 April 2017, 03:52:18 UTC |
25c9e95 | detoo | 25 April 2017, 02:58:56 UTC | Fix unexpected non-OK response in metricsmgr_client.py | 25 April 2017, 02:58:56 UTC |
67f3b9e | John Crawford | 25 April 2017, 02:50:04 UTC | Fixed a route for the UI with base url | 25 April 2017, 02:50:04 UTC |
5f67004 | John Crawford | 23 April 2017, 14:14:38 UTC | Added needed host for tests | 23 April 2017, 14:14:38 UTC |
78b14be | Bill Graham | 21 April 2017, 19:03:19 UTC | UpdateTopologyManager test should not assert re-activation withg mocks (#1812) | 21 April 2017, 19:03:19 UTC |
0a47fef | John Crawford | 21 April 2017, 12:05:16 UTC | Style fix | 21 April 2017, 12:05:16 UTC |
c3333da | John Crawford | 21 April 2017, 05:08:55 UTC | Merged in master | 21 April 2017, 05:08:55 UTC |
4e85f2f | John Crawford | 21 April 2017, 04:00:04 UTC | Accessing config via class variable. Fix for test | 21 April 2017, 04:00:04 UTC |
21c7bd2 | Bill Graham | 13 April 2017, 23:27:27 UTC | 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 | Bill Graham | 11 April 2017, 17:05:33 UTC | 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 | Bill Graham | 10 April 2017, 19:13:11 UTC | One-liner to fix Heron Tracker code (#1805) | 10 April 2017, 19:13:11 UTC |
b31009f | Karthik Ramasamy | 07 April 2017, 18:31:46 UTC | 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 | Karthik Ramasamy | 07 April 2017, 18:20:40 UTC | 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 |