Google Git
Sign in
apache / samza / HEAD
  1. 86932b9 SAMZA-2633: Rolling upgrades cause downtime to upgraded processors for the entire deployment window (#1484) by mynameborat · 3 years, 1 month ago
  2. 9e8dcbe SAMZA-2643: Cleanup redundant null serde checks in ContainerStorageManager, these checks should only be in BaseKeyValueStorageEngineFactory (#1486) by Sanil Jain · 3 years, 1 month ago
  3. 78c50e7 SAMZA-2644: ContainerLaunchUtil swallows exception and does not even log them if an exception occurs while setting up a Samza container or invoking run on it (#1487) by Sanil Jain · 3 years, 1 month ago
  4. 78e4232 Changed StreamOperatorTask to throw appropriate Exception when InputOperator is not found for a SystemStream in the OperatorGraph (#1483) by ajo thomas · 3 years, 1 month ago
  5. da8d158 SAMZA-2638: Skip container stop/restart for processors that have same work assignment across rebalances (#1478) by mynameborat · 3 years, 2 months ago
  6. a2827db Fix NPE when thread pool size is 0 and thread pool is null (#1481) by Ziting · 3 years, 2 months ago
  7. 29deb42 Fix in the documentation for Window Types in high level api documentation (#1482) by ajo thomas · 3 years, 2 months ago
  8. ea14805 SAMZA-2639: Samza-sql: Fix ANY type validation for the parsed args (#1479) by Aditya Toomula · 3 years, 2 months ago
  9. 4e39201 SAMZA-2637: Samza-sql: Fix ANY type validation while checking UDF arg types (#1477) by Aditya Toomula · 3 years, 2 months ago
  10. acd4493 Add a metric to track the number of active threads of a container's thread pool (#1476) by Ziting · 3 years, 2 months ago
  11. 09863bf SAMZA-2630: Upgrade dependencies for security fixes (#1471) by Sarah Telesia · 3 years, 2 months ago
  12. c08f39d [SAMZA-2597]: Maintain traversal order for registered operators (#1436) by mynameborat · 3 years, 2 months ago
  13. 2aea5f7 SAMZA-2632: Processors should only write their own task locality to zookeeper (#1473) by mynameborat · 3 years, 2 months ago
  14. b3128e0 SAMZA-2627: Make StreamAppender extensible for sending messages to SystemProducer (#1474) by lakshmi-manasa-g · 3 years, 2 months ago
  15. 5547f8c Samza-2631: Samza-sql: Revert structured data support (#1472) by Aditya Toomula · 3 years, 2 months ago
  16. 87779c8 SAMZA-2620: Jackson upgrade. by perkss · 3 years, 3 months ago
  17. 89b71ed SAMZA-2617: Upgrade Kafka Client to 2.3.1 (#1462) by Stuart · 3 years, 2 months ago
  18. 93c41df SAMZA-2627: Make StreamAppender extensible for sending messages to SystemProducer (#1470) by lakshmi-manasa-g · 3 years, 2 months ago
  19. 66b2efd SAMZA-2628: Include the localized resource lib directory in the classpath of AM container (#1469) by Aditya Toomula · 3 years, 2 months ago
  20. 0f275cf SAMZA-2624: Add Ke Wu to committer page by Ke Wu · 3 years, 3 months ago
  21. e28daee Add Sanil to committers list (#1466) by Sanil Jain · 3 years, 3 months ago
  22. 83204fc AzureBlobSystemProducer: Catch all Exception in completableFuture during flush of producer (#1363) by lakshmi-manasa-g · 3 years, 3 months ago
  23. eb3de5c SAMZA-2556:AzureBlob SystemProducer: Fix NPE thrown during flush. NPE caused by unhandled previous exceptions (#1392) by lakshmi-manasa-g · 3 years, 3 months ago
  24. 17a9c2f Merge pull request #1460 from sborya/README by Boris Shkolnik · 3 years, 3 months ago
  25. 8cf6a4e updated README. Made it to match the directory structure by Boris Shkolnik · 3 years, 3 months ago
  26. 7e2e641 restored 1.5.1 in the list by Boris Shkolnik · 3 years, 3 months ago
  27. cf8f814 Merge branch 'master' of http://git-wip-us.apache.org/repos/asf/samza by Boris Shkolnik · 3 years, 3 months ago
  28. 479e510 SAMZA-2616: Upgrade ZK Client. (#1456) by Stuart · 3 years, 3 months ago
  29. 4e7154f SAMZA-2563: Fix double counting of InMemoryKeyValueStore deletion (#1458) by Ziting · 3 years, 3 months ago
  30. f305149 SAMZA-2618: Add per-container metric for memory-utilization (#1459) by Ziting · 3 years, 3 months ago
  31. 4bd8af1 Release docs update to 1.6.0 by Boris Shkolnik · 3 years, 4 months ago
  32. 07e475b updated to the next release version 1.7.0 by Boris Shkolnik · 3 years, 4 months ago
  33. d003651 SAMZA-2615: Metrics for Application Master High Availability (#1455) by mynameborat · 3 years, 4 months ago
  34. f7f9b90 Merge pull request #1454 from MabelYC/fixDupLog by Boris Shkolnik · 3 years, 4 months ago
  35. f013058 add precondition by Cheng · 3 years, 4 months ago
  36. f0afc48 SAMZA-2614:Fix NPE at KafkaCheckpointManager.start in standby containers by Cheng · 3 years, 4 months ago
  37. 5748fa6 SAMZA-2605: Make Standby Container Requests Rack Aware (#1446) by Pawas Chhokra · 3 years, 5 months ago
  38. 708a6de API Changes to make Standby Container Allocation Rack Aware (#1453) by Pawas Chhokra · 3 years, 5 months ago
  39. 1087683 SAMZA-2610: Handle Metadata changes for AM HA orchestration (#1450) by mynameborat · 3 years, 5 months ago
  40. 1962946 SAMZA-2609: Data model changes to track lifecycle information of job coordinator (#1449) by mynameborat · 3 years, 5 months ago
  41. 5a099eb SAMZA-2606: container orchestration for AM HA (#1448) by lakshmi-manasa-g · 3 years, 5 months ago
  42. 220cbe2 SAMZA-2611: [AM-HA] heartbeat reestablish causes container's heartbeat thread to die (#1452) by lakshmi-manasa-g · 3 years, 5 months ago
  43. dd2f2b8 Merge pull request #1451 from Sanil15/SAMZA-2608 by Boris Shkolnik · 3 years, 5 months ago
  44. 324c381 Updating the RocksDb version by Sanil15 · 3 years, 5 months ago
  45. 3179f86 Merge pull request #1437 from MabelYC/dupLog by Boris Shkolnik · 3 years, 5 months ago
  46. c212cac SAMZA-2604: Datamodel change to capture physical container id for AM HA (#1445) by lakshmi-manasa-g · 3 years, 5 months ago
  47. 3fd456a SAMZA-2602: Dynamic heartbeat establish with new AM (#1442) by lakshmi-manasa-g · 3 years, 6 months ago
  48. 126ae08 removed unused code by Cheng · 3 years, 6 months ago
  49. 1dfe009 address comments by Cheng · 3 years, 6 months ago
  50. 36e36bc Merge pull request #1447 from sborya/RELEASE by Boris Shkolnik · 3 years, 6 months ago
  51. 4ad502f SAMZA-2601: avoid infinite loop when resource not allocated with host affinity disabled (#1441) by Hai Lu · 3 years, 6 months ago
  52. a58125b update log messages based on feedback by Hai Lu · 3 years, 6 months ago
  53. 2d477cd Added another server for keys by Boris S · 3 years, 6 months ago
  54. ed0a230 address comments by Cheng · 3 years, 6 months ago
  55. db47dd3 clean up code by Cheng · 3 years, 6 months ago
  56. 42dcc91 modifies to close the clients according to lifecycle by Cheng · 3 years, 6 months ago
  57. c3636b8 corrected some release instructions by Boris S · 3 years, 6 months ago
  58. f2b10e0 Merge pull request #1444 from sborya/KEYS by Boris Shkolnik · 3 years, 6 months ago
  59. 0e0501b added pub keys for Boris S. by Boris Shkolnik · 3 years, 6 months ago
  60. 340af40 address comments by Cheng · 3 years, 6 months ago
  61. 64c659f Merge pull request #1443 from sborya/Rat by Boris Shkolnik · 3 years, 6 months ago
  62. 56f450e one directory is enough by Boris S · 3 years, 6 months ago
  63. 48dddc0 clean up code by Cheng · 3 years, 6 months ago
  64. f20be45 modified to use shutdownhook instead of finalize() by Cheng · 3 years, 6 months ago
  65. e53083b added two exclusions for RAT restrictions by Boris S · 3 years, 6 months ago
  66. 120f2fb SAMZA-2600: Extract constants for string literals used in AM and container (#1439) by lakshmi-manasa-g · 3 years, 6 months ago
  67. 6665098 SAMZA-2601: avoid infinite loop when resource not allocated with host affinity disabled by Hai Lu · 3 years, 6 months ago
  68. 60fa359 [Minor] Update the tests to use the master branch version for 1.5.0 release (#1438) by mynameborat · 3 years, 6 months ago
  69. 276ed04 SAMZA-2598:Kafka clients are not created and closed properly by Cheng · 3 years, 6 months ago
  70. fb508b7 Merge pull request #1435 from Zhangyx39/format_exception by Boris Shkolnik · 3 years, 7 months ago
  71. 23945a5 also replace string.format in CachingTable by Yixing Zhang · 3 years, 7 months ago
  72. c0e055d replace string.format calls by Yixing Zhang · 3 years, 7 months ago
  73. 13b5303 SAMZA-2595: Updated MonitorService to use separate ScheduleExecutor for each monitor (#1434) by shekhars-li · 3 years, 7 months ago
  74. d12af34 SAMZA-2587: IntermediateMessageSerde exception handling (#1426) by Yixing Zhang · 3 years, 7 months ago
  75. 9d5c2c4 SAMZA-2593: Update task callback to store only necessary fields instead of the message envelope (#1433) by mynameborat · 3 years, 8 months ago
  76. 42a57b2 Merge pull request #1430 from MabelYC/addLabel by Boris Shkolnik · 3 years, 8 months ago
  77. 71d2d46 clean up used code by Cheng · 3 years, 8 months ago
  78. 7eb7079 Adding internal table-api config for table-api rate limits (#1431) by FAN XIE · 3 years, 8 months ago
  79. 42e68e8 SAMZA-2574 : improve flexibility of SystemFactory interface by Cheng · 3 years, 8 months ago
  80. 3df04d3 SAMZA-2574: improve flexibility of SystemFactory interface by Cheng · 3 years, 9 months ago
  81. 764f09c SAMZA-2589: Consolidate Beam and High/Low Samza Apps launch workflow (#1428) by Ke Wu · 3 years, 8 months ago
  82. 3fcced3 SAMZA-2558: Refactor app.runner.class by Ke Wu · 3 years, 8 months ago
  83. 2079a10 SAMZA-2424: AM should cache and serve serialized Job Model to containers (#1241) by Prateek Maheshwari · 3 years, 8 months ago
  84. ccd5789 Make the StreamAppender output the formatted message in String format instead of Object (#1427) by Pawas Chhokra · 3 years, 8 months ago
  85. d689fd2 SAMZA-2584: Refactor ClusterBasedJobCoordinator (#1424) by Ke Wu · 3 years, 8 months ago
  86. a66fcd1 SAMZA-2585: Modify shutdown sequence to handle orphaned AMs (#1422) by Pawas Chhokra · 3 years, 8 months ago
  87. 6ff6f55 [DOCS] Update the docs & blogs for 1.5.1 release (#1425) by mynameborat · 3 years, 9 months ago
  88. f7f9f3c SAMZA-2439: Remove LocalityManager and container location information from JobModel (#1421) by mynameborat · 3 years, 9 months ago
  89. 29f2ef7 SAMZA-2579: Force restart feature for Container Placements (#1414) by Sanil Jain · 3 years, 9 months ago
  90. 44fe776 SAMZA-2583: Fix NPE in update SamzaHistogram Gauge values (#1418) by Vishwajith Shivappa · 3 years, 9 months ago
  91. 0c6b6b6 SAMZA-2578: Excessive trimming during transactional state restore (#1413) by bkonold · 3 years, 9 months ago
  92. 216a87f SAMZA-2581: Fix Samza Histogram update to update percentile Gauge values (#1416) by Vishwajith Shivappa · 3 years, 9 months ago
  93. 114bdee Fixing missing initialization in TestStreamAppender that causes test to fail (#1415) by rmatharu · 3 years, 9 months ago
  94. b736af9 Merge pull request #1408 from MabelYC/interfaceChange by Boris Shkolnik · 3 years, 9 months ago
  95. 926c758 address comment: clean typo by Cheng · 3 years, 9 months ago
  96. 2b11d94 SAMZA-2577 : Adding support for Async-Logger in Log4j2 Stream Appender (#1411) by rmatharu · 3 years, 9 months ago
  97. 5d98e25 SAMZA-2550: Move side input processing to use RunLoop (#1385) by bkonold · 3 years, 9 months ago
  98. 10d5d2f address comments and provide better comments by Cheng · 3 years, 9 months ago
  99. c8bf03d Merge pull request #1410 from sborya/master by Boris Shkolnik · 3 years, 9 months ago
  100. 7aa6580 clean up comments by Cheng · 3 years, 9 months ago