- 02a86ae502730970606cda4ca048d470f0728cfe: Merge pull request #247 from allenxwang/master
- 0480770480204f57b91b703e9c35bb6f3fd5743f: Separate handling of batch exception and exception on individual item
- 687b124b3a7019081b66c237e5a754da32269e27: Merge pull request #246 from allenxwang/master
- 95a9d24a4acd94f89b87aea720b88cfd6c6f7230: JUnit enhancement
- b4db78b50b2b5a6a196fc6873f81c0d1eac0b919: Fix issues that ElasticSearchSink may retry indefinitely on exception
- 12a087f4133ceb310c81ba92015e433742abfe1c: Merge pull request #245 from allenxwang/master
- 279ae59a94790b10d7a0d70b1c38ed4a7284a9b8: Add if-else to make it easier to read.
- 9dc5453c53880b0ddd3523a3bceecc1e8376e1bf: Fix JUnit for concurrent issue.
- 86aad2323b46362af1a70b82ee131355b3fb9ee9: Use synchronous queue when sink does not want to drop message to deal with back pressure.
- caecfd72f08a245ac9fc38562dc62dababa9c453: fix the deadlock of TestFileBlockingQueue
- 5b95e58cc8bc54a952bfd2879a98b0b53c03f414: Merge pull request #241 from Netflix/ISSUE-240
- d2b7d26da61e64f3d6d7ff6f799c1e317d2fae88: IndexInfoBuilder interface extended
- 7c9e0b1810bab70380cfb7d77d7b02754c7a317a: Merge pull request #239 from Netflix/ISSUE-238
- 04d64e763b116107fef69ba4688d92a1e2d4d8f4: delete Rx from metadata fetch waiting policy
- 4f6b660892a8240d1054657c3d3b716a7200aa0a: add counter
- 75bd676a69e9286591c1a9cada50021f773f4f96: Merge branch 'ISSUE-236'
- c4a71bcfae60d17c35e7ff00b906245f9b5d54f2: add more counter
- 5d735b24ee1de813eebe9c2113fbe73165a682a8: Merge pull request #237 from Netflix/ISSUE-236
- ac45241b41310cabe4dc8daca397fe5ef2826853: attempted from processed
- 877cc8737cbed7f0b244525f1631e76ffdb5dd62: counters are added
- 1c31295bab279ff39f6b44b0234820447407e511: new oss gradle
- ed751a2da8edbb79c1d65eeb70aa58c3f3943315: Merge pull request #205 from Netflix/ISSUE-185
- f3038f90dfee02fca2d0f1c0587c6d93aeb3f663: merge conflict
- 5c1b7dcb3a985fd37c26b26e6c0cea3d6be781b4: updated kafka version to 0.8.2.0
- d7cdf0c1898150812923a00262cf8fd1c6c4aa85: Merge pull request #204 from Netflix/ISSUE-203
- 28c43bf7797b641db8a8bd186fbe7a28d5cf7479: test fixed
- 7b2a8d7bfd9f5e45fc95750128e6819accd6e686: PathExistsMessageFilter bug fixed
- 31c2ec9e58e88daa8fe84e60a02ca7ac8438185b: Merge pull request #191 from adamschmidt/ExtensionModules
- 56badfe44c68d83faa03cdffb4803dd2b7dfae79: Merge pull request #192 from Netflix/FIX_BUILD
- 4c5551957cfe97bd91c7b7ff17ff10bee94b23a2: fixed TestAsyncSuroClient.testRestore with small number of messages
- 674a4ccdadf3e87f2a7bf45e6cc831c72d8e9c2c: dependencies changed for fixing build
- e9d1391a49a29292016941364c674acfbe85a98b: Added the ability to load modules from configuration (-x option on command line), removing the compile-time dependency. suro-server project can now specify modules as a runtime dependency.
- c8a55f1d9624830bd4d570c2538263d6777dadd4: Merge pull request #183 from rspieldenner/netflixossbuild
- 988335349245672c6ae831bb758c6f2ae2967bab: Delete unneeded build files
- 39ee1f59a7ac7b9760c1f0cf032d3aa3927d5ccd: Remove commented out dependencies
- 3d8b67eb8173b89af3662a42236101daa013d03a: Build switched to nebula.netflixoss. Dependencies cleaned up.
- 57eb3373c3caaebc69583fe871ba6792fe9951f3: move to gradle 2.2.1
- 121a34a085298477624a24539849f30081f49f73: Merge pull request #180 from stevenzwu/master
- 11dc18548c6fd70c584ad5f5fb10d768d0c06a1c: switch from ConcurrentSkipListSet to CopyOnWriteArraySet
- c6db346675f67fc126c9f1f480b668f508b6ae3a: Merge pull request #178 from Netflix/ISSUE-176
- 2614897c8e63df71ff11a2fd2d43d7ad5e2bc8c5: conflict fixed
- 8a3e7c3263335539454e2c2f5623d5edd47cbfb0: Merge pull request #177 from Netflix/ISSUE-174
- c2108f85793764bc51fc4cbafb64bf4d2a2b254b: temporarily disabled flaky tests
- 85a2ce02aaf57ef78cb2ff2a69e91ec7ddd3ceda: Merge pull request #175 from adamschmidt/Log4jFix
- 57b03435c33dbb7c427bfc435453d4b172a2a5c2: temporarily commented out flaky tests
- 2cfe0d2c2317b84c0b8a1e01b7c31b410c084d01: test fixed
- a30b2c646af924ca32e2bf67a90a6d21cf1d51e9: control SuroInput pause with just one time, not accumulative one
- 8a8eaab29205e97a2abdd4f6970ce2e4b6344b3e: ClientException is handled with sleep
- 7e09180bfd5f385360c674c6a6fe798e28212775: Removed hard dependency on log4j in favour of slf4j to be consistent. Added basic log4j config file and system properties to Gradle runServer task
- 3a0dab2762fe818bd370c3c85e4db2707307abd2: Merge pull request #173 from allenxwang/master
- 481c7064a42055cc70a63d93f7ed5566fe413d30: changes according to review comments.
- 3b6fb0c6268c72478aa604e66e78c09af16434f6: Simplified code with Observable.observeOn().
- efad351c06f2c26d12ce041292134ea7029092f2: Merge pull request #171 from Netflix/ISSUE-170
- d039ad79a9efc461b40c022a8d8b04d88f055af4: Merge pull request #172 from Netflix/ISSUE-126
- d98305ee1847d5b9062a933cb94051f35c921d8b: more error handling
- 65b586c79a39ef78f8e9b2476f8fa65ab1d95041: timer and retry added
- ac75ebdf67e0a53b103ce1c1a78a4dcc43b34c9b: test fixed
- cd52a9868342d7bcecea7cd63cb362200614e057: without jest, ribbon http client is used
- e25a8bd4c671d7cbce0295f7c5ffc4aab615c88a: ElasticSearchSink with Jest
- a1690e332c5b9f78e79e3c4a3e67fc16528c3ab2: metadata management manually
- 2bbaca9cb3d5299b1cd59dde4e406038c109fed6: Merge pull request #168 from Netflix/ISSUE-167
- 86b645de49aef129a69545f222a9b571f63aa9d9: jets3t version upgraded
- e7cd20c2db546cca7910797581d553df06d053bf: Merge pull request #166 from Netflix/ISSUE-165
- 037b4d51a298d8c0ed58d71bf6e2cd360e02c6fd: test fixed
- 7cb50d964dec2dbd323f67d6a497728d18ef7909: connected nodes as gauge
- 3c3611df1f9c246c87981e2e3410ac8f8a4626be: ElasticSearchSink manual server list refresh with Eureka
- 3c927ae2cf73907cde68d1f86c86bfa5e7fcd010: Merge pull request #164 from Netflix/ISSUE-163
- bc6ed18f9a082a6db685ef46781b30918a7f47b7: ribbon upgrade to RC9
- aada72d5a605b057bdb8ebdf3d5f7a70237a6b3f: Merge pull request #160 from g9yuayon/default-routes
- f69f4eb41094de704d86e8a8c95b4d5b5efafda0: Replaced hardcoded Kafka port with free ports
- c824f3bf11f9982e886795ec9d41fe67276fd558: Enhanced test cases so they pass under different JVMs
- 94c49483ddfd46822182b14801bc07808ab00171: Fixed compilation failure under Java 7
- 20ca76fe51f340d52d21b469217e87fe7acf6a8e: Added default routing info to routing map
- 993cd97a4cb20907d42beebc67821e31aff4a536: Merge pull request #157 from Netflix/ISSUE-154
- 8e593d1139bb99ea6880ad05b5e5e54b3c7a600f: AsyncSuroClient fixed with event Listener
- 0ad5bdd1e023ba58655d9d0342eea1a280d9a0e4: test fixed
- 89496778d765ee98aca1f2eac74f0d7c680728ad: test fixed
- 4892de0d6322d30846fa443f45ffd1dd43835669: Kafka with more configuration
- 20148d97048077c502421f703118a2a3506e95a3: conflit fixed
- f761d07bc400a9b92d363e1ee5fcbc9fe20e39c4: conflict fixed
- 91363e056c494767b130d9de7e4fbbc8e784e03a: Merge pull request #158 from Netflix/update-gradle-1.12
- d191a40eb86c6b72b59773ee561c85bc4461b442: Upgrading to Gradle 1.12
- 3de97c00af11b3baa969c683b20f42cbdf2056e0: additional commit
- a4e1aa21b9ceadf48f314df714f8f20a809fd4a4: Kafka producer/consumer with 0.8.2-beta
- c0a2a568dfdff888e98918dd399e6a92a18fc4a0: Merge pull request #156 from Netflix/ISSUE-153
- cae26011b2abe64c079401636571ec0eff04aa9b: Map of LongGauge is added to Servo for indexDelay per topic
- 9d084c920a1a12459bae3a0dd22f447ddc2a7b76: elasticsearch sink with replication type, its default is async
- 4d2cceea7d956996b40a2cb6f418738e5fcae73a: conflict fixed
- 1e91b6afa144b2819118d4ece931f3de760c88b3: fixed conflicts
- f060e92de2662f66e9b96885559fdaf678ec4866: Merge branch 'ISSUE-102'
- e440007a3d5308fb1948653d06cbe6538ce544c9: pause on input side on the long queue
- c5befb3772a0298d42dd4085c17beff919156559: Merge pull request #148 from Netflix/ISSUE-141
- e1ae02a9be4f4ae0f8c24dabbc89961927ec3fdc: DynamicCounter changed to Servo with BasicCounter
- 80042fda5eba0438b729da5db2335599b3013b31: ElasticSearchSink with DynamicCounter
- 10f14c562dccc58b6f99bbc0098e799e88136924: Merge pull request #143 from BrightTag/master
- 55eeefb7f7c4a9e6438b142d49bffc50a1d6cc5d: Simplified failure/retry logic
- ab31feb7e00f108fee056ee8a7d9526ab1783fba: added comment explaining thread pool issue in KafkaSinkV2
- 0bff0f885a41bab599729cf2fa869b93e870d281: clarified retry/failure logic
- ffc292b4d494b5e3cde2c336886c14c7ebd9d2ca: updated sample KafkaSinkV2 config, added 2 new sink stats, fixed pending message count
- 08426f162d4b592747d408ce1f55cd4a720084ca: Changed counters from ints to longs to prevent overflow
- 58acd8d19051c34cef5e738955c4e3691c6adf85: added message counters to KafkaSinkV2
- 98678e36b7524130d6dc2e0151861b0466e65bdf: Merge pull request #138 from Netflix/ISSUE-137
- f447c204342461adcfc2a5ac58a8053c591d818a: Merge branch 'master' of https://github.com/Netflix/suro into ISSUE-137
- bc6f75bd134d6453f11dc9722a0101f18da6acc3: Merge pull request #136 from Netflix/ISSUE-128
- d5eace6a86b8f5c497d7d65daf83f49bfdff322f: Merge pull request #127 from BrightTag/master
- a10caeb1783c220fa0a0d397fe940e09d7918897: make SuroServer4Test to pick up the random port immediately
- 58ff317264559d3914b290699f2109d56aa1db54: Merge branch 'master' of https://github.com/Netflix/suro
- ecea949658beb423b80d0090e6ccbd8c6440965c: Merge branch 'master' into ISSUE-128
- 6c23d046caa997cf9f7898dcc3ccfb235fd6e5d9: unit test fixed
- 9ac94e00fdf8925ca0b2a810e5d39be810e1dfd3: s3consumer with cloudtrail
- 06fa6a3b282f8ca3d4335772937db5f818dd21ef: allocate DefaultPartitioner only once
- 846cddc6af8529e9a63520558014353d7740733a: Use default partitioner and don't store key. Added unit test.
- 90aa3ce2952f1301decac66a94237f97cda1e705: Merge pull request #134 from iPinYou/ISSUES-131
- 84d14d1be68795f8ec68f190d1b84537eb0760db: Merge pull request #135 from iPinYou/ISSUES-132
- f5f037261297cdd734dbc168b5a6e90227356ebd: run hadoop's local file system #132
- 5c795819b2c7a6ac6602d1d721a4c393b668d39d: #131 semicolon will be a better choice.
- fa42389248505122f8a8eefe8f12f403df29404c: removed bad assertion test (it depends on timing)
- 000d4b33a1f3df3b94cebb28f6cfb0f781b57635: Fixed key/partitioning, fixed stats reporting, added unit tests
- c006d87e8a43342a6912d9019b7e37831b205fd8: added KafkaV2 sink using new kafka producer in 0.8.2-SNAPSHOT
- 2eabdd0250e61864691c93f9330a9623945144e8: [Gradle Release Plugin] - new version commit: '0.2.10-SNAPSHOT'.
- 618503cb0a3eebd77b6d20b5861b68d2320934fb: Adding mavenLocal() for local resolution
- 6df65bf346344a1b29abc51c2f3e866b6a9d2c55: Fixing aggregateJavadoc
- b0585dae4cfe7108fd8bd80d7c4b890f95e42119: Passing status to Artifactory builds
- 28c6989099fc538cfd9d1d8d13075901bcec769d: Verify before we can't take it back, use preferredVersion variable
- d0e42e3dfb45c8d792c6cced1c943c89b1d861dc: Handle unavailable sonatype properties
- 9de561434f303b8020269984d7ef313428414715: Make uploadMavenCentral task, that encompasses other tasks
- 832eb537e9df36a2e53a90e1f34e2008a36f3f17: Automatically aggregate and publish docs (java,groovy,scala)
- 498c25feaa03a9a3a09e633814c192ddc770ced4: Matching wrapper to 1.5
- 8caf8ec93b3617749db90ceac64e06116567f072: Upgrading release process
- 63e44e8e73b9fdfe56655cc1fb13180885dedc9e: Using latest features of release plugin
- 883dd0daf391695a3b26e1d0f5c1bb112022c803: Add sonatype snapshot repository
- c3477877da453c81a3c3c121d7677fce2911551d: Use newer version of license-gradle-plugin that fixes skipExistingHeaders field
- d87b66e0d0074d42b35e46a5c3664dd57294e16d: Move gradle-release dependency to bintray
- 84339e0a40358919863496d6fd8c6035228b6329: Switching to bintray for dependencies (same as Maven Central)
- 6f9e3a024fd9213446079e6160ef872849e91c53: Upgrading to Gradle 1.4
- f5a10c63c56b2cc5c07c7a602be6cd965a8415d3: Update codequality/checkstyle.xml
- b7847eb946161b85609621f0392eb33e32b5cf42: Fixing transitive-ness of provided
- 36e5b8f5d64e08147ea98ae17e15a21d716b8b10: Adding provided scope
- 66ff83f789785e9351cec4fb54b6f6ffa0eb9874: Using a better github location
- 1cbb4d6dbe34998f4caa2cbe52c59abc8e0e4886: Fixing issue when publishing source/javadoc to maven central
- 05c4d0660d4f5317e430f0dc7f0c1487ac4f51e2: Putting javadoc and sources into proper confs and setting types
- 61bd2b059be16052e2372e792ec8698af9589d79: Add local publishing
- 6d4a854dca49cbfd989b468efc4e7bce89796e08: Filling in more pom fields for Sonatype
- a8674db7d92f5a6669b8f373205cfef52b995ba9: Stop relying on maven convention on project
- 2b31d36a03edcc93a3d2c478ba8b8c3b315df85a: Changes needed for release plugin
- 1954d730193a6ee7300cbcdf5f4cfaa74e9faa3e: Setting default name for multi-project
- f170238c6df0e5991758ea14058e1b6ef05fa905: Using custom build of release plugin, to support building from a branch
- ddedbd72afbfbd786614983f3ffbc10e1522c6ec: Pointing to a repo in our control
- 8f289b73e539edc34a4fcd22df1c6dc9d97f216f: Release plugin
- a85e1963ffaacd0d695baa356f69adccfcbbebf4: Adding cobertura
- c2af08e723518a2191e51bf9eae694fda12d1bbc: Upgrade to Gradle 1.1.
- 0f0c6114889de1c0c3d702661aa44f95ec76edea: Enable license header plugin
- cc1b04ce986105cc04a141554902e5cb699efbcc: Merge pull request #3 from Randgalt/multi-project