Google Git
Sign in
apache / samza / HEAD
  1. 82c53aa SAMZA-2804: Concurrency issues identified in run-class.sh on samza-yarn (#1716) by Jon Bringhurst · 5 months ago master
  2. 23f52e9 SAMZA-2803 Remove Google Analytics from the Samza Website (#1715) by Niall Pemberton · 7 months ago
  3. 28149ea [Docs] Add Shekhar Sharma to committers list and GPG keys by Shekhar Sharma · 7 months ago
  4. ef8bc76 Clear local logged stores if input checkpoints are empty (#1713) by ajo thomas · 9 months ago
  5. 63c86b5 Add new configuration allowing to keep processing when there are fatal exceptions or timeout (#1708) by Haolan Ye · 10 months ago
  6. 0cf9f9a Fix get future exception message (#1712) by ajo thomas · 11 months ago
  7. d6ffeeb Log bob deserialization exception for snapshot blobs (#1711) by ajo thomas · 12 months ago
  8. 56c6267 Update versions and use io.github.rburgst instead of com.burgstaller for okhttp-digest (#1709) by ajo thomas · 12 months ago
  9. a52ef9d Add Default Configuration for RocksDB MaxManifestFileSize (#1706) by Haolan Ye · 1 year, 1 month ago
  10. 2a94cad New interface & factory for AzureHTTPClient providers (#1700) by Ayush Khandelwal · 1 year, 1 month ago
  11. 3cb57c2 SAMZA-2801: fix the case when waterrmark is not aggregated when quorum is not met (#1707) by Xinyu Liu · 1 year, 1 month ago
  12. 50280c6 SAMZA-2801: Support excluding tasks from watermark computation when exceeding idle time (#1705) by Xinyu Liu · 1 year, 1 month ago
  13. 5b4b1b7 Improve Samza AM retry count logging (#1701) by Michael Barskii · 1 year, 2 months ago
  14. 17e552c BUG FIX: set target file size multiplier (#1704) by Haolan Ye · 1 year, 2 months ago
  15. f9c3241 Output Current Timestamp at run-class.sh script (#1702) by Haolan Ye · 1 year, 2 months ago
  16. 2eb556a Create store directory paths in CSM constructor for disk space monitor (#1697) by Shekhar Sharma · 1 year, 6 months ago
  17. fb9f5cd SAMZA-2799: Remove worker.opts handling in shell command builder (#1696) by Bharath Kumarasubramanian · 1 year, 8 months ago
  18. 93b9828 SAMZA-2784: Remove excessive commit logs (#1695) by Daniel Chen · 1 year, 8 months ago
  19. 082899d Add MAX_BACKGROUND_JOBS config for RocksDB (#1694) by Shekhar Sharma · 1 year, 10 months ago
  20. 8ed3572 SAMZA-2798: Populate worker.opts in environment variable only if available (#1693) by Bharath Kumarasubramanian · 1 year, 10 months ago
  21. e1816f3 SAMZA-2797: Call flush during stop from CoordinatorStreamWriter (#1692) by ajo thomas · 1 year, 10 months ago
  22. 66495b6 SAMZA-2796: Introduce config knob for framework thread sub DAG execution (#1691) by Bharath Kumarasubramanian · 1 year, 10 months ago
  23. 65f31eb SAMZA-2763: Support worker JVM opts for Samza Beam portable mode (#1689) by Bharath Kumarasubramanian · 1 year, 10 months ago
  24. 2e91dfe SAMZA-2795: Set thread to daemon thread for operator executor service (#1690) by Bharath Kumarasubramanian · 1 year, 11 months ago
  25. 24e530d Unique System.exit in ContainerLaunchUtil (#1686) by Jun Guan · 2 years ago
  26. c43f423 SAMZA-2774: Resolve classpath symlinks (#1653) by Jon Bringhurst · 2 years, 1 month ago
  27. 65bf4ae SAMZA-2791: Introduce callback timeout specific to watermark messages (#1681) by Bharath Kumarasubramanian · 2 years, 1 month ago
  28. aeeaf0b SAMZA-2790: Cleanup RunLoop constructor explosion (#1680) by Bharath Kumarasubramanian · 2 years, 1 month ago
  29. fa4008e Ignore file owners comparison on restore when config is set (#1684) by Shekhar Sharma · 2 years, 1 month ago
  30. 0e8ac2e Close TaskRestoreManager only after all restores are complete (#1682) by shekhars-li · 2 years, 1 month ago
  31. 1373db2 [SAMZA-2787] GetDeleted API and Recover from DeletedException (#1676) by shekhars-li · 2 years, 2 months ago
  32. 3ce67ac SAMZA-2789: Remove cap on intermediate stream partition count for stream mode (#1679) by Bharath Kumarasubramanian · 2 years, 2 months ago
  33. 9357a91 Merge pull request #1678 from Zhangyx39/master by Boris Shkolnik · 2 years, 2 months ago
  34. b78b66c add comment by Yixing Zhang · 2 years, 2 months ago
  35. ec7d105 fix unit test by Yixing Zhang · 2 years, 2 months ago
  36. f53c6f9 Add new metric to emit 1 when containers are processing by Yixing Zhang · 2 years, 2 months ago
  37. 7dee997 Add new SamzaApplicationMaster metric to track allocated containers buffered in AM (#1677) by jia-gao · 2 years, 2 months ago
  38. f856004 Authenticate GitHub Actions builds to ge.apache.org (#1672) by Clay Johnson · 2 years, 3 months ago
  39. aa5db44 SAMZA-2778: Make AzureBlobOutputStream buffer initialization size configurable. (#1662) by Eric Honer · 2 years, 3 months ago
  40. cc21b6e Fix scope of caches for DirDiffUtil.areSameFile (#1671) by Andy Sautins · 2 years, 3 months ago
  41. d138757 Re-factor DirDiffUtil.getDirDiff to minimize calls to sun.nio.fs.* (#1669) by Andy Sautins · 2 years, 3 months ago
  42. 03d70a5 - Fix parameter ReceiverOptions parameters usaged (#1670) by Eric Honer · 2 years, 3 months ago
  43. 9111bb7 SAMZA-2781: Use framework thread to execute hand-offs and sub-DAG execution (#1667) by Bharath Kumarasubramanian · 2 years, 3 months ago
  44. 4600dd3 SAMZA-2782: Clean up container thread pool DI into StreamOperatorTask (#1668) by Bharath Kumarasubramanian · 2 years, 3 months ago
  45. 7020e3a SAMZA-2776: Upgrade Azure libraries in module samza-azure. (#1660) by Eric Honer · 2 years, 4 months ago
  46. e75a7e6 SAMZA-2777: Add support for GenericFixed to AzureBlobAvroWriter (#1661) by Eric Honer · 2 years, 4 months ago
  47. 524d687 Capture build scans on ge.apache.org to benefit from deep build insights (#1665) by Clay Johnson · 2 years, 5 months ago
  48. 815dfc6 Removed unnecessary logging for configs (#1664) by Prateek Maheshwari · 2 years, 6 months ago
  49. 03b187a Only verify permissions for file owner after blob store restore. (#1659) by Prateek Maheshwari · 2 years, 6 months ago
  50. 985a604 Changed uses of Apache Commons IO FileUtils.deleteDirectory to PathUtils.deleteDirectory (#1658) by Prateek Maheshwari · 2 years, 6 months ago
  51. d261a0b Side Inputs + Blob Store Backups - Part 2 - Allow bulk restore from blob store for side input stores (#1657) by Prateek Maheshwari · 2 years, 6 months ago
  52. 325e463 Merge pull request #1656 from prateekm/side-inputs-blob-store-restore-part-2 by Prateek Maheshwari · 2 years, 7 months ago
  53. 542cd48 Fixed line-length related formatting issues. by Prateek Maheshwari · 2 years, 7 months ago
  54. cfae3e4 Merge pull request #1655 from prateekm/side-inputs-blob-store-restore by Prateek Maheshwari · 2 years, 7 months ago
  55. 69851fb Updated based on PR feedback. by Prateek Maheshwari · 2 years, 7 months ago
  56. 5c43962 Refactoring ContainerStorageManager for readability and manageability. by Prateek Maheshwari · 2 years, 7 months ago
  57. 3b54392 Merge pull request #1654 from prateekm/master by Prateek Maheshwari · 2 years, 7 months ago
  58. 9041b3a Side Inputs + Blob Store Backups - Fix duplicate uploads and broken metrics. by Prateek Maheshwari · 2 years, 7 months ago
  59. 77dec99 Fix deadlock in StreamAppender (#1652) by jia-gao · 2 years, 8 months ago
  60. 19e61ab Merge pull request #1650 from shekhars-li/master by Prateek Maheshwari · 2 years, 8 months ago
  61. 083c85d Fix comment, remove accessors by Shekhar Sharma · 2 years, 8 months ago
  62. dac1333 style fix by Shekhar Sharma · 2 years, 8 months ago
  63. b8fc2db Delete twoEnter.txt by shekhars-li · 2 years, 8 months ago
  64. 773029b Add license to new file by Shekhar Sharma · 2 years, 8 months ago
  65. bb3194b Delete empty.txt by shekhars-li · 2 years, 8 months ago
  66. ba0a756 Delete oneEnter.txt by shekhars-li · 2 years, 8 months ago
  67. 2a4365e Delete noEnter.txt by shekhars-li · 2 years, 8 months ago
  68. a39e2a4 remove file added by mistake by shekhars-li · 2 years, 8 months ago
  69. 9a95f75 Move configs to retry into RetryPolicyConfig class by Shekhar Sharma · 2 years, 8 months ago
  70. 653ae51 Fix style check - unused import by Shekhar Sharma · 2 years, 8 months ago
  71. 70819db Fix style check - unused import by Shekhar Sharma · 2 years, 8 months ago
  72. 2172408 Fix issues based on PR comments by Shekhar Sharma · 2 years, 8 months ago
  73. b15b4f8 [SAMZA-2773] Migrate zkclient library (#1651) by Katie Liu · 2 years, 8 months ago
  74. 931d963 Fix style issues by Shekhar Sharma · 2 years, 8 months ago
  75. 617dd93 Move Blob Store retry related tunables behind configs by Shekhar Sharma · 2 years, 8 months ago
  76. 344b318 Merge branch 'apache:master' into master by shekhars-li · 2 years, 8 months ago
  77. d102d20 [SAMZA-2772] Manage Jekyll dependencies with Gradle (#1647) by Adam Faris · 2 years, 8 months ago
  78. 1f8033b Merge pull request #1649 from ajothomas/DocUpdate by ajo thomas · 2 years, 8 months ago
  79. 790afd3 Samza 1.8.0 release website updates by Ajo Thomas · 2 years, 8 months ago
  80. a0d12da Update RocksDB to version 7.8.3 to reduce write amplification (#1648) by shekhars-li · 2 years, 9 months ago
  81. 8b4beb6 Update RocksDB to 7.8.3 by Shekhar Sharma · 2 years, 9 months ago
  82. 4cfcdf5 Update RocksDB to 7.8.3 by Shekhar Sharma · 2 years, 9 months ago
  83. 5aec2c0 Update RocksDB to 7.8.3 by Shekhar Sharma · 2 years, 9 months ago
  84. a0bac34 Adding ajothomas to samza committers and gpg keys (#1646) by ajo thomas · 2 years, 9 months ago
  85. d9e139a Merge branch 'apache:master' into master by shekhars-li · 2 years, 9 months ago
  86. ad8af0c Fix restore factory not configured log (#1645) by Daniel Chen · 2 years, 9 months ago
  87. 2688cc1 Fix perferomance bug with async commit (#1644) by shekhars-li · 2 years, 10 months ago
  88. 7a6a5bf Fix perferomance bug with async commit by Shekhar Sharma · 2 years, 10 months ago
  89. d5d3d98 LISAMZA-27395 removing the current recursive call prevention logic (#1641) by jia-gao · 2 years, 10 months ago
  90. d412842 SAMZA-2769: [PipelineDrain] Introduce enum in DrainNotification to allow for different drain modes (#1642) by ajo thomas · 2 years, 10 months ago
  91. 6a1652f SAMZA-2765: [Pipeline Drain] Adding config for task callback timeout during drain (#1637) by ajo thomas · 2 years, 11 months ago
  92. 86d9b51 SAMZA-2741: [Pipeline Drain] Fix ApplicationUtil.isHighLevelApiJob to work for anonymous SamzaApplication (#1640) by ajo thomas · 2 years, 11 months ago
  93. dd8ecf1 SAMZA-2762: new cpu usage metric which counts child processes usage (#1636) by Alan Zhang · 2 years, 11 months ago
  94. 95a0c33 add the metric "container-active-threads" back (#1638) by Alan Zhang · 2 years, 11 months ago
  95. 3d4747c SAMZA-2741: Pipeline Drain- Fix processing of Drain messages for both low-level and high level API (#1639) by ajo thomas · 2 years, 11 months ago
  96. c1bc442 Merge pull request #1634 from PawasChhokra/ZK by Boris Shkolnik · 3 years ago
  97. 40e0608 Update zookeeper and kazoo version by Pawas Chhokra · 3 years ago
  98. 5580bcf SAMZA-2757: Make Samza Compatible with Java 11 (#1628) by Jamie DeMichele · 3 years ago
  99. 010d148 Emit to diagnostic kafka topic in round robin fashion to support increasing this topic partition count (#1631) by jia-gao · 3 years ago
  100. 4e4e477 Make StreamAppender extensible for sending event to SystemProducer (#1627) by jia-gao · 3 years ago