Google Git
Sign in
apache / samza / HEAD
  1. 2eb556a Create store directory paths in CSM constructor for disk space monitor (#1697) by Shekhar Sharma · 5 weeks ago master
  2. fb9f5cd SAMZA-2799: Remove worker.opts handling in shell command builder (#1696) by Bharath Kumarasubramanian · 4 months ago
  3. 93b9828 SAMZA-2784: Remove excessive commit logs (#1695) by Daniel Chen · 4 months ago
  4. 082899d Add MAX_BACKGROUND_JOBS config for RocksDB (#1694) by Shekhar Sharma · 5 months ago
  5. 8ed3572 SAMZA-2798: Populate worker.opts in environment variable only if available (#1693) by Bharath Kumarasubramanian · 6 months ago
  6. e1816f3 SAMZA-2797: Call flush during stop from CoordinatorStreamWriter (#1692) by ajo thomas · 6 months ago
  7. 66495b6 SAMZA-2796: Introduce config knob for framework thread sub DAG execution (#1691) by Bharath Kumarasubramanian · 6 months ago
  8. 65f31eb SAMZA-2763: Support worker JVM opts for Samza Beam portable mode (#1689) by Bharath Kumarasubramanian · 6 months ago
  9. 2e91dfe SAMZA-2795: Set thread to daemon thread for operator executor service (#1690) by Bharath Kumarasubramanian · 6 months ago
  10. 24e530d Unique System.exit in ContainerLaunchUtil (#1686) by Jun Guan · 8 months ago
  11. c43f423 SAMZA-2774: Resolve classpath symlinks (#1653) by Jon Bringhurst · 8 months ago
  12. 65bf4ae SAMZA-2791: Introduce callback timeout specific to watermark messages (#1681) by Bharath Kumarasubramanian · 8 months ago
  13. aeeaf0b SAMZA-2790: Cleanup RunLoop constructor explosion (#1680) by Bharath Kumarasubramanian · 8 months ago
  14. fa4008e Ignore file owners comparison on restore when config is set (#1684) by Shekhar Sharma · 9 months ago
  15. 0e8ac2e Close TaskRestoreManager only after all restores are complete (#1682) by shekhars-li · 9 months ago
  16. 1373db2 [SAMZA-2787] GetDeleted API and Recover from DeletedException (#1676) by shekhars-li · 9 months ago
  17. 3ce67ac SAMZA-2789: Remove cap on intermediate stream partition count for stream mode (#1679) by Bharath Kumarasubramanian · 9 months ago
  18. 9357a91 Merge pull request #1678 from Zhangyx39/master by Boris Shkolnik · 9 months ago
  19. b78b66c add comment by Yixing Zhang · 10 months ago
  20. ec7d105 fix unit test by Yixing Zhang · 10 months ago
  21. f53c6f9 Add new metric to emit 1 when containers are processing by Yixing Zhang · 10 months ago
  22. 7dee997 Add new SamzaApplicationMaster metric to track allocated containers buffered in AM (#1677) by jia-gao · 10 months ago
  23. f856004 Authenticate GitHub Actions builds to ge.apache.org (#1672) by Clay Johnson · 11 months ago
  24. aa5db44 SAMZA-2778: Make AzureBlobOutputStream buffer initialization size configurable. (#1662) by Eric Honer · 11 months ago
  25. cc21b6e Fix scope of caches for DirDiffUtil.areSameFile (#1671) by Andy Sautins · 11 months ago
  26. d138757 Re-factor DirDiffUtil.getDirDiff to minimize calls to sun.nio.fs.* (#1669) by Andy Sautins · 11 months ago
  27. 03d70a5 - Fix parameter ReceiverOptions parameters usaged (#1670) by Eric Honer · 11 months ago
  28. 9111bb7 SAMZA-2781: Use framework thread to execute hand-offs and sub-DAG execution (#1667) by Bharath Kumarasubramanian · 11 months ago
  29. 4600dd3 SAMZA-2782: Clean up container thread pool DI into StreamOperatorTask (#1668) by Bharath Kumarasubramanian · 11 months ago
  30. 7020e3a SAMZA-2776: Upgrade Azure libraries in module samza-azure. (#1660) by Eric Honer · 11 months ago
  31. e75a7e6 SAMZA-2777: Add support for GenericFixed to AzureBlobAvroWriter (#1661) by Eric Honer · 11 months ago
  32. 524d687 Capture build scans on ge.apache.org to benefit from deep build insights (#1665) by Clay Johnson · 12 months ago
  33. 815dfc6 Removed unnecessary logging for configs (#1664) by Prateek Maheshwari · 1 year, 1 month ago
  34. 03b187a Only verify permissions for file owner after blob store restore. (#1659) by Prateek Maheshwari · 1 year, 2 months ago
  35. 985a604 Changed uses of Apache Commons IO FileUtils.deleteDirectory to PathUtils.deleteDirectory (#1658) by Prateek Maheshwari · 1 year, 2 months ago
  36. d261a0b Side Inputs + Blob Store Backups - Part 2 - Allow bulk restore from blob store for side input stores (#1657) by Prateek Maheshwari · 1 year, 2 months ago
  37. 325e463 Merge pull request #1656 from prateekm/side-inputs-blob-store-restore-part-2 by Prateek Maheshwari · 1 year, 2 months ago
  38. 542cd48 Fixed line-length related formatting issues. by Prateek Maheshwari · 1 year, 2 months ago
  39. cfae3e4 Merge pull request #1655 from prateekm/side-inputs-blob-store-restore by Prateek Maheshwari · 1 year, 2 months ago
  40. 69851fb Updated based on PR feedback. by Prateek Maheshwari · 1 year, 2 months ago
  41. 5c43962 Refactoring ContainerStorageManager for readability and manageability. by Prateek Maheshwari · 1 year, 2 months ago
  42. 3b54392 Merge pull request #1654 from prateekm/master by Prateek Maheshwari · 1 year, 2 months ago
  43. 9041b3a Side Inputs + Blob Store Backups - Fix duplicate uploads and broken metrics. by Prateek Maheshwari · 1 year, 2 months ago
  44. 77dec99 Fix deadlock in StreamAppender (#1652) by jia-gao · 1 year, 3 months ago
  45. 19e61ab Merge pull request #1650 from shekhars-li/master by Prateek Maheshwari · 1 year, 3 months ago
  46. 083c85d Fix comment, remove accessors by Shekhar Sharma · 1 year, 3 months ago
  47. dac1333 style fix by Shekhar Sharma · 1 year, 3 months ago
  48. b8fc2db Delete twoEnter.txt by shekhars-li · 1 year, 3 months ago
  49. 773029b Add license to new file by Shekhar Sharma · 1 year, 3 months ago
  50. bb3194b Delete empty.txt by shekhars-li · 1 year, 3 months ago
  51. ba0a756 Delete oneEnter.txt by shekhars-li · 1 year, 3 months ago
  52. 2a4365e Delete noEnter.txt by shekhars-li · 1 year, 3 months ago
  53. a39e2a4 remove file added by mistake by shekhars-li · 1 year, 3 months ago
  54. 9a95f75 Move configs to retry into RetryPolicyConfig class by Shekhar Sharma · 1 year, 3 months ago
  55. 653ae51 Fix style check - unused import by Shekhar Sharma · 1 year, 3 months ago
  56. 70819db Fix style check - unused import by Shekhar Sharma · 1 year, 3 months ago
  57. 2172408 Fix issues based on PR comments by Shekhar Sharma · 1 year, 3 months ago
  58. b15b4f8 [SAMZA-2773] Migrate zkclient library (#1651) by Katie Liu · 1 year, 3 months ago
  59. 931d963 Fix style issues by Shekhar Sharma · 1 year, 3 months ago
  60. 617dd93 Move Blob Store retry related tunables behind configs by Shekhar Sharma · 1 year, 3 months ago
  61. 344b318 Merge branch 'apache:master' into master by shekhars-li · 1 year, 3 months ago
  62. d102d20 [SAMZA-2772] Manage Jekyll dependencies with Gradle (#1647) by Adam Faris · 1 year, 4 months ago
  63. 1f8033b Merge pull request #1649 from ajothomas/DocUpdate by ajo thomas · 1 year, 4 months ago
  64. 790afd3 Samza 1.8.0 release website updates by Ajo Thomas · 1 year, 4 months ago
  65. a0d12da Update RocksDB to version 7.8.3 to reduce write amplification (#1648) by shekhars-li · 1 year, 4 months ago
  66. 8b4beb6 Update RocksDB to 7.8.3 by Shekhar Sharma · 1 year, 4 months ago
  67. 4cfcdf5 Update RocksDB to 7.8.3 by Shekhar Sharma · 1 year, 4 months ago
  68. 5aec2c0 Update RocksDB to 7.8.3 by Shekhar Sharma · 1 year, 4 months ago
  69. a0bac34 Adding ajothomas to samza committers and gpg keys (#1646) by ajo thomas · 1 year, 5 months ago
  70. d9e139a Merge branch 'apache:master' into master by shekhars-li · 1 year, 5 months ago
  71. ad8af0c Fix restore factory not configured log (#1645) by Daniel Chen · 1 year, 5 months ago
  72. 2688cc1 Fix perferomance bug with async commit (#1644) by shekhars-li · 1 year, 5 months ago
  73. 7a6a5bf Fix perferomance bug with async commit by Shekhar Sharma · 1 year, 5 months ago
  74. d5d3d98 LISAMZA-27395 removing the current recursive call prevention logic (#1641) by jia-gao · 1 year, 6 months ago
  75. d412842 SAMZA-2769: [PipelineDrain] Introduce enum in DrainNotification to allow for different drain modes (#1642) by ajo thomas · 1 year, 6 months ago
  76. 6a1652f SAMZA-2765: [Pipeline Drain] Adding config for task callback timeout during drain (#1637) by ajo thomas · 1 year, 6 months ago
  77. 86d9b51 SAMZA-2741: [Pipeline Drain] Fix ApplicationUtil.isHighLevelApiJob to work for anonymous SamzaApplication (#1640) by ajo thomas · 1 year, 6 months ago
  78. dd8ecf1 SAMZA-2762: new cpu usage metric which counts child processes usage (#1636) by Alan Zhang · 1 year, 6 months ago
  79. 95a0c33 add the metric "container-active-threads" back (#1638) by Alan Zhang · 1 year, 6 months ago
  80. 3d4747c SAMZA-2741: Pipeline Drain- Fix processing of Drain messages for both low-level and high level API (#1639) by ajo thomas · 1 year, 6 months ago
  81. c1bc442 Merge pull request #1634 from PawasChhokra/ZK by Boris Shkolnik · 1 year, 7 months ago
  82. 40e0608 Update zookeeper and kazoo version by Pawas Chhokra · 1 year, 7 months ago
  83. 5580bcf SAMZA-2757: Make Samza Compatible with Java 11 (#1628) by Jamie DeMichele · 1 year, 7 months ago
  84. 010d148 Emit to diagnostic kafka topic in round robin fashion to support increasing this topic partition count (#1631) by jia-gao · 1 year, 7 months ago
  85. 4e4e477 Make StreamAppender extensible for sending event to SystemProducer (#1627) by jia-gao · 1 year, 8 months ago
  86. 1e8745d SAMZA-2758: Upgrade vulnerable versions jetty and jackson (#1630) by Stuart · 1 year, 8 months ago
  87. 0b5e32a SAMZA-2741: [Pipeline Drain] Simplifying DrainUtils' writeDrainNotification method and change tests (#1629) by ajo thomas · 1 year, 9 months ago
  88. 0ac55be Revert elasticity commits - bug found with broadcast input (#1626) by lakshmi-manasa-g · 1 year, 9 months ago
  89. 2951193 remove keyBucket from checkpoint serde to allow for simpler rollback (#1625) by lakshmi-manasa-g · 1 year, 9 months ago
  90. a3c3e10 SAMZA-2751: RunLoop and High-Level API changes for Drain (#1616) by ajo thomas · 1 year, 9 months ago
  91. 3032c78 SAMZA-2755: Pin jdk to 8.0.232 (#1620) by Jon Bringhurst · 1 year, 10 months ago
  92. 702fd81 SAMZA-2753: Consolidate Clocks (#1617) by Ke Wu · 1 year, 10 months ago
  93. f7afdff SAMZA-2749: Startpoint bug fix (#1615) by Alan Zhang · 1 year, 10 months ago
  94. 493de64 SAMZA-2742: [Pipeline Drain] Add Drain components and integrate them with SamzaContainer and JC (#1605) by ajo thomas · 1 year, 11 months ago
  95. 22c3071 SAMZA-2747: Standby bug fixes (#1614) by Bharath Kumarasubramanian · 1 year, 11 months ago
  96. 1072aed SAMZA-2746: Allow customizable log4j configuration file (#1613) by Ke Wu · 1 year, 11 months ago
  97. 9f36e72 Merge pull request #1610 from lakshmi-manasa-g/elasticity-watermark by rayman7718 · 2 years ago
  98. eaf8252 SAMZA-2745: handle processing of watermark and end of stream when elasticity is enabled by Manasa · 2 years ago
  99. 5135a53 Merge pull request #1608 from lakshmi-manasa-g/elasticity-ssp-serde by rayman7718 · 2 years ago
  100. 0fc3702 trigger travis build by Manasa · 2 years ago