1. 4e4e477 Make StreamAppender extensible for sending event to SystemProducer (#1627) by jia-gao · 5 days ago master
  2. 1e8745d SAMZA-2758: Upgrade vulnerable versions jetty and jackson (#1630) by Stuart · 5 days ago
  3. 0b5e32a SAMZA-2741: [Pipeline Drain] Simplifying DrainUtils' writeDrainNotification method and change tests (#1629) by ajo thomas · 5 weeks ago
  4. 0ac55be Revert elasticity commits - bug found with broadcast input (#1626) by lakshmi-manasa-g · 7 weeks ago
  5. 2951193 remove keyBucket from checkpoint serde to allow for simpler rollback (#1625) by lakshmi-manasa-g · 8 weeks ago
  6. a3c3e10 SAMZA-2751: RunLoop and High-Level API changes for Drain (#1616) by ajo thomas · 8 weeks ago
  7. 3032c78 SAMZA-2755: Pin jdk to 8.0.232 (#1620) by Jon Bringhurst · 9 weeks ago
  8. 702fd81 SAMZA-2753: Consolidate Clocks (#1617) by Ke Wu · 9 weeks ago
  9. f7afdff SAMZA-2749: Startpoint bug fix (#1615) by Alan Zhang · 3 months ago
  10. 493de64 SAMZA-2742: [Pipeline Drain] Add Drain components and integrate them with SamzaContainer and JC (#1605) by ajo thomas · 3 months ago
  11. 22c3071 SAMZA-2747: Standby bug fixes (#1614) by Bharath Kumarasubramanian · 4 months ago
  12. 1072aed SAMZA-2746: Allow customizable log4j configuration file (#1613) by Ke Wu · 4 months ago
  13. 9f36e72 Merge pull request #1610 from lakshmi-manasa-g/elasticity-watermark by rayman7718 · 4 months ago
  14. eaf8252 SAMZA-2745: handle processing of watermark and end of stream when elasticity is enabled by Manasa · 4 months ago
  15. 5135a53 Merge pull request #1608 from lakshmi-manasa-g/elasticity-ssp-serde by rayman7718 · 4 months ago
  16. 0fc3702 trigger travis build by Manasa · 4 months ago
  17. 3792d71 SAMZA-2744 Update RocksDb version (#1609) by Daniel Chen · 4 months ago
  18. 9363ea6 SAMZA-2740: Provide a way to specify a static file name for container metadata file (#1604) by Cameron Lee · 4 months ago
  19. 01c1c71 SAMZA-2743: [Elasticity] Add keybucket into SSP serde for checkpoint by Manasa · 4 months ago
  20. 7dc3de5 Merge pull request #1607 from lakshmi-manasa-g/elasticity-checkpoint-rw by rayman7718 · 4 months ago
  21. 49354c6 SAMZA-2734: [Elasticity] Update last processed offset after an envelope is finished processing when elasticity is enabled by Manasa · 4 months ago
  22. 1ff98f3 Merge pull request #1598 from lakshmi-manasa-g/elasticity-checkpoint-lastProcessedOffsets by rayman7718 · 4 months ago
  23. be7e014 empty commit to trigger travis by Manasa · 4 months ago
  24. a962e13 Merge pull request #1603 from lakshmi-manasa-g/elasticity-SSPKeyDeser by rayman7718 · 4 months ago
  25. 170f378 Merge pull request #1606 from prateekm/dir-diff-fix by Prateek Maheshwari · 4 months ago
  26. fedfd30 Fixed unit test. by Prateek Maheshwari · 4 months ago
  27. e2b67d1 Fixed check for files both present and removed in DirIndex. Added a check for blobs too. by Prateek Maheshwari · 4 months ago
  28. 20e6529 SAMZA-2729: samza-rest: Crash on uncaught exceptions in monitor threads by Prateek Maheshwari · 5 months ago
  29. 603cfaa remove new config and add one more unit test and address comments by Manasa · 5 months ago
  30. 8e2f8bc add test to deser with old deser logic by Manasa · 5 months ago
  31. cea7ab9 use elasticity checkpoints only if job.elasticity.checkpoints.enabled=true by Manasa · 5 months ago
  32. e52b650 SAMZA-2739: Improve SystemStreamPartition key deserializer to not be rigid about ssp having only 3 fields by Manasa · 5 months ago
  33. 58af358 handle null in some edge cases and add tests for these edge cases by Manasa · 5 months ago
  34. c4d42a4 SAMZA-2737: Change RemoteAppRunner to plan for local deployments (#1602) by Daniel Chen · 5 months ago
  35. 314f5c7 Merge pull request #1596 from lakshmi-manasa-g/elasticity-taskName-format by rayman7718 · 5 months ago
  36. 30cc2c0 empty commit to trigger travis build by Manasa · 5 months ago
  37. 840233a Merge pull request #1597 from lakshmi-manasa-g/elasticity-kafka-readAllCheckpoints by rayman7718 · 5 months ago
  38. cb63b27 SAMZA-2735: Support configurable command to run jc in Yarn (#1600) by Xinyu Liu · 5 months ago
  39. 2cda174 SAMZA-2733: [Elasticity] Compute last processed offsets when container starts up using checkpoints from previous deploys when elasticity was enabled by Manasa · 5 months ago
  40. 400d197 SAMZA-2731: Add readAllCheckpoints to CheckpointManager and implement for KafkaCheckpointManager by Manasa · 5 months ago elasticity-kafka-readAllCheckpoints
  41. da75b63 SAMZA-2732: [Elasticity] Add elasticityFactor into the TaskName when elasticity is enabled by Manasa · 5 months ago
  42. e37fe25 SAMZA-2730: Add process CPU usage metric using units of processor count instead of percentage (#1593) by Cameron Lee · 6 months ago
  43. 303a02e SAMZA-2685: fall back to ClusterBasedJobCoordinator when job.coordinator.factory is the empty string for cluster-based deployments (#1594) by Cameron Lee · 6 months ago
  44. 53dbc48 Merge pull request #1595 from shekhars-li/log-delete by Prateek Maheshwari · 6 months ago
  45. 309e718 Debug -> info in TaskInstance for cleanup and init by Shekhar Sharma · 6 months ago
  46. bc5c01e Fix style issues by Shekhar Sharma · 6 months ago
  47. c24d631 Removed unused import - fix checkstyle by Shekhar Sharma · 6 months ago
  48. 2352ae4 Add logs for deletes by Shekhar Sharma · 6 months ago
  49. 50500ed Change retry counts limit of 3 to unlimited for async blob store operations (#1592) by shekhars-li · 6 months ago
  50. f41d29c SAMZA-2728: [Elasticity] improve distribution of messages across elastic tasks (#1589) by lakshmi-manasa-g · 6 months ago
  51. 3a023c1 Crash on uncaught exceptions in monitor threads by Jon Bringhurst · 6 months ago
  52. 3a90277 SAMZA-2720: Allow custom task executor to be injected and used. (#1588) by Christopher Zhang · 7 months ago
  53. 735f546 SAMZA-2719: [Elasticity] fix container level metrics when elasticity is enabled (#1585) by lakshmi-manasa-g · 7 months ago
  54. 858ed3f SAMZA-2727: Fix UTFDataFormatException for FileUtil (#1587) by Daniel Chen · 7 months ago
  55. 95f9e0d SAMZA-2723: Fix yarn version and scala version for scalate (#1586) by Daniel Chen · 7 months ago
  56. 06ef532 Update log4j2 version (#1584) by Aman Singh · 7 months ago
  57. bee7f25 Merge pull request #1580 from lakshmi-manasa-g/elasticity-ssp-grouper by Prateek Maheshwari · 7 months ago
  58. a7c77c6 address comments by Manasa · 7 months ago
  59. 664ebb0 SAMZA-2721: Container should exit with non-zero status code in case of errors during launch (#1583) by mynameborat · 7 months ago
  60. 589f5c5 pick only one elastic task to broadcast control messages like eos and watermark by Manasa · 8 months ago
  61. ae4453b handle end of stream/watermark, add runloop test by Manasa · 8 months ago
  62. 55a8b26 remove new test in TestRunLoop as it needs special handling for end_of_stream offsets by Manasa · 8 months ago
  63. 0c2f9a1 use envelop.getSSP(elasticityFactor) uniformly by Manasa · 8 months ago
  64. d134bef merge by Manasa · 8 months ago
  65. 69b9beb merge master and fix merge conflicts by Manasa · 8 months ago
  66. e0bd1f1 SAMZA-2689 [Elasticity] generate JobModel and update RunLoop with (elastic) tasks processing keyBuckets of SystemStreamPartition by Manasa · 8 months ago
  67. 5b733a4 add tests and address comments by Manasa · 8 months ago
  68. 8e85333 SAMZA-2689 [Elasticity] generate JobModel and update RunLoop with (elastic) tasks processing keyBuckets of SystemStreamPartition by Manasa · 8 months ago
  69. 2e7c2fe Fix - filter only configured stores in backup/restore init (#1582) by shekhars-li · 8 months ago
  70. 3eaa697 SAMZA-2688 [Elasticity] introduce elasticity factor config and key bucket within SSP (#1576) by lakshmi-manasa-g · 8 months ago
  71. 43ff95f Upgrade to Kafka 2.4 and fix flaky tests (#1581) by jia-gao · 8 months ago
  72. 28b644c SAMZA-2717: Adding docs for table api updates (#1579) by ajo thomas · 8 months ago
  73. c5831bf [Docs] Add Daniel Chen to committers list and GPG keys (#1578) by Daniel Chen · 8 months ago
  74. aa31bb6 SAMZA-2718: TaskContext.getTable should not upcast ReadWriteUpdateTable to ReadWriteTable (#1577) by ajo thomas · 8 months ago
  75. b56044a SAMZA-2709: Adding partial update api to Table API (#1560) by ajo thomas · 8 months ago
  76. 4584d5d SAMZA-2680 Remove wildcard import from SystemStreamPartitionGrouper. (#1574) by smptx · 9 months ago
  77. b76a7af Fix NPE in finally block hiding original exception in FileUtil by Prateek Maheshwari · 9 months ago
  78. c411598 Fix NPE hiding original exception in FileUtil by Prateek Maheshwari · 9 months ago
  79. 85151e2 Merge pull request #1572 from shekhars-li/config-fix by Prateek Maheshwari · 9 months ago
  80. b0541f1 Remove expected exception class from test by shekhars-li · 9 months ago
  81. 93b6978 Fix test failures by shekhars-li · 9 months ago
  82. 49e8ae9 Update RocksDB default compaction thread count and return empty map for checkpoint v1 in init by shekhars-li · 9 months ago
  83. c125b15 Fix rollback stale checkpoints (#1571) by Daniel Chen · 9 months ago
  84. 68a4ac7 Merge pull request #1570 from prateekm/nonblocking-restore by Prateek Maheshwari · 9 months ago
  85. 636b67f Removed unused test method. by Prateek Maheshwari · 9 months ago
  86. 90a44b3 Made ContainerStorageManager restore nonblocking to prevent deadlock when num restoreExecutor threads <= num tasks. by Prateek Maheshwari · 9 months ago
  87. 05d5916 Bump up log4j2 version (#1569) by Alan Zhang · 9 months ago
  88. 810fe6e SAMZA-2714: Bump log4j2 to mitigate CVE-2021-44228 by Jon Bringhurst · 10 months ago
  89. 6c7fbaa SAMZA-2713: Add flag to disable container heartbeat monitor (#1567) by Cameron Lee · 10 months ago
  90. 1daca89 SAMZA-2075: Add execEnvContainerId and execEnvAttemptId for diagnostics for Kubernetes job coordinator (#1566) by Cameron Lee · 10 months ago
  91. 5714ff9 [Tests] Fix TestZkLocalApplicationRunner (#1563) by jia-gao · 10 months ago
  92. 2e2ed70 SAMZA-2712: AzureBlob SystemProducer: flushtimeout is not respected if main thread is uploading to azure and azure upload is stuck (#1564) by lakshmi-manasa-g · 10 months ago
  93. b01b051 Remove flooding log (#1565) by Ziting · 10 months ago
  94. 0faf072 SAMZA-2707: Convert metrics snapshot reporter code to java (#1558) by Cameron Lee · 10 months ago
  95. d77211d Update AvroRelConverter.java (#1562) by Hengyu JiaNG · 10 months ago
  96. dc687db [Tests] Add longer delay time to mitigate flaky test in TestAsyncFlatMap (#1561) by Cameron Lee · 10 months ago
  97. f9c0e2b SAMZA-2704: Wire in diagnostics reporter for Kubernetes job coordinator (#1553) by Cameron Lee · 10 months ago
  98. 39f6530 [Tests] fix flaky TestContainerAllocatorWithHostAffinity.testExpiredRequestAllocationOnAnyHost (#1559) by Cameron Lee · 10 months ago
  99. a8c3b39 SAMZA-2698: Remove Travis CI Config (#1540) by Jon Bringhurst · 11 months ago
  100. a6ebddd SAMZA-2708: Update yarn from 2.7.1 to 2.10.1 (#1557) by Tony Brusseau · 11 months ago