Google Git
Sign in
apache / samza / HEAD
  1. b56044a SAMZA-2709: Adding partial update api to Table API (#1560) by ajo thomas · 2 years, 4 months ago
  2. 4584d5d SAMZA-2680 Remove wildcard import from SystemStreamPartitionGrouper. (#1574) by smptx · 2 years, 5 months ago
  3. b76a7af Fix NPE in finally block hiding original exception in FileUtil by Prateek Maheshwari · 2 years, 5 months ago
  4. c411598 Fix NPE hiding original exception in FileUtil by Prateek Maheshwari · 2 years, 5 months ago
  5. 85151e2 Merge pull request #1572 from shekhars-li/config-fix by Prateek Maheshwari · 2 years, 5 months ago
  6. b0541f1 Remove expected exception class from test by shekhars-li · 2 years, 5 months ago
  7. 93b6978 Fix test failures by shekhars-li · 2 years, 5 months ago
  8. 49e8ae9 Update RocksDB default compaction thread count and return empty map for checkpoint v1 in init by shekhars-li · 2 years, 5 months ago
  9. c125b15 Fix rollback stale checkpoints (#1571) by Daniel Chen · 2 years, 5 months ago
  10. 68a4ac7 Merge pull request #1570 from prateekm/nonblocking-restore by Prateek Maheshwari · 2 years, 5 months ago
  11. 636b67f Removed unused test method. by Prateek Maheshwari · 2 years, 5 months ago
  12. 90a44b3 Made ContainerStorageManager restore nonblocking to prevent deadlock when num restoreExecutor threads <= num tasks. by Prateek Maheshwari · 2 years, 5 months ago
  13. 05d5916 Bump up log4j2 version (#1569) by Alan Zhang · 2 years, 5 months ago
  14. 810fe6e SAMZA-2714: Bump log4j2 to mitigate CVE-2021-44228 by Jon Bringhurst · 2 years, 6 months ago
  15. 6c7fbaa SAMZA-2713: Add flag to disable container heartbeat monitor (#1567) by Cameron Lee · 2 years, 6 months ago
  16. 1daca89 SAMZA-2075: Add execEnvContainerId and execEnvAttemptId for diagnostics for Kubernetes job coordinator (#1566) by Cameron Lee · 2 years, 6 months ago
  17. 5714ff9 [Tests] Fix TestZkLocalApplicationRunner (#1563) by jia-gao · 2 years, 6 months ago
  18. 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 · 2 years, 6 months ago
  19. b01b051 Remove flooding log (#1565) by Ziting · 2 years, 6 months ago
  20. 0faf072 SAMZA-2707: Convert metrics snapshot reporter code to java (#1558) by Cameron Lee · 2 years, 6 months ago
  21. d77211d Update AvroRelConverter.java (#1562) by Hengyu JiaNG · 2 years, 6 months ago
  22. dc687db [Tests] Add longer delay time to mitigate flaky test in TestAsyncFlatMap (#1561) by Cameron Lee · 2 years, 6 months ago
  23. f9c0e2b SAMZA-2704: Wire in diagnostics reporter for Kubernetes job coordinator (#1553) by Cameron Lee · 2 years, 6 months ago
  24. 39f6530 [Tests] fix flaky TestContainerAllocatorWithHostAffinity.testExpiredRequestAllocationOnAnyHost (#1559) by Cameron Lee · 2 years, 6 months ago
  25. a8c3b39 SAMZA-2698: Remove Travis CI Config (#1540) by Jon Bringhurst · 2 years, 7 months ago
  26. a6ebddd SAMZA-2708: Update yarn from 2.7.1 to 2.10.1 (#1557) by Tony Brusseau · 2 years, 7 months ago
  27. 8e9ac40 [Tests] Fix flaky tests and memory leak related to ContainerAllocator tests (#1556) by Cameron Lee · 2 years, 7 months ago
  28. 1254659 [Tests] add more context on flaky testProcessingFutureCompletesAfterTaskTimeout test (#1554) by Cameron Lee · 2 years, 7 months ago
  29. 3054a86 SAMZA-2706: Clean up specific handling of diagnostics-specific metrics reporter (#1550) by Cameron Lee · 2 years, 7 months ago
  30. 88e113d [Tests] Updating memory for test task for samza-core (#1551) by Cameron Lee · 2 years, 7 months ago
  31. 35e9151 Minor: fixing duplicate validation on kafka checkpoint manager test (#1549) by Cameron Lee · 2 years, 7 months ago
  32. 1348d51 SAMZA-2703: Add input stream partition count and input stream regex monitoring for refreshing job model (#1548) by Cameron Lee · 2 years, 7 months ago
  33. 96d4b80 Using TCK Tested JDK builds of OpenJDK (#1545) by Carl Dea · 2 years, 8 months ago
  34. 45c0aa9 SAMZA-2699: AzureBlob SystemProducer: remove retries when uploading block as azure sdk does internal retries (#1542) by lakshmi-manasa-g · 2 years, 8 months ago
  35. ab1c4c3 SAMZA-2701: AzureBlob SystemProducer: bump azure-storage-blob and azure-identity sdks to latest versions (#1546) by lakshmi-manasa-g · 2 years, 8 months ago
  36. 0423e04 SAMZA-2700: StaticResourceJobCoordinator does not set config for LoggingContextHolder (#1544) by Cameron Lee · 2 years, 8 months ago
  37. dcdd0ec SAMZA-2695: Unit tests for KafkaCheckpointManager take too long to run (#1541) by Cameron Lee · 2 years, 8 months ago
  38. bc9e93f SAMZA-2679: Add missing Override annotations (#1539) by Jon Bringhurst · 2 years, 8 months ago
  39. daeecf5 Merge pull request #1521 from dxichen/SAMZA-2674 by Daniel Chen · 2 years, 8 months ago
  40. 960f0dd Use only Context for init by Daniel Chen · 2 years, 9 months ago
  41. 922a5c1 SAMZA-2674: Remove unnecessary init call by Daniel Chen · 2 years, 9 months ago
  42. 4773574 SAMZA-2693: Make Samza log4j appenders agnostic of where they are running (#1532) by Cameron Lee · 2 years, 8 months ago
  43. c570a3d SAMZA-2685: Add job coordinator which does not do resource management (#1529) by Cameron Lee · 2 years, 8 months ago
  44. 571f394 Fix container physical memory monitoring to fetch all children process RSS memory with 1 process (#1533) by Ziting · 2 years, 8 months ago
  45. a433ce4 SAMZA-2697: Increase build time max heap (#1538) by Jon Bringhurst · 2 years, 8 months ago
  46. 7da4ac9 SAMZA-2696: Set CI timeout to 60 minutes (#1536) by Jon Bringhurst · 2 years, 8 months ago
  47. b4dc99f SAMZA-2694: Always show stack traces on gradle failures (#1534) by Jon Bringhurst · 2 years, 8 months ago
  48. b1ed421 SAMZA-2678: Configure Github Actions for CI (#1525) by Jon Bringhurst · 2 years, 8 months ago
  49. c4d059a Include memory usage of child processes in physical-memory-mb metric (#1530) by Ziting · 2 years, 9 months ago
  50. 516a40d SAMZA-2663: Handle job model expiration and new job model flows for multiple incomplete rebalances (#1528) by mynameborat · 2 years, 9 months ago
  51. 041075c SAMZA-2676: Pass parameter into subset, not format (#1523) by Jon Bringhurst · 2 years, 9 months ago
  52. 27b1495 SAMZA-2672: Extract creation of stream monitors into separate classes for reuse (#1520) by Cameron Lee · 2 years, 9 months ago
  53. e3ab00d SAMZA-2683: Bump Scalatra Version (#1527) by Daniel Chen · 2 years, 9 months ago
  54. a7cb039 SAMZA-2677: Fix format string used to print uuid (#1524) by Jon Bringhurst · 2 years, 9 months ago
  55. a731312 SAMZA-2669: Inject MetricsRegistry into SamzaContainer so that it can be shared in higher layers (#1518) by Cameron Lee · 2 years, 9 months ago
  56. 120098d SAMZA-2670: Update granularity of JobCoordinatorMetadataManager.checkForMetadataChanges and epoch id extraction (#1519) by Cameron Lee · 2 years, 9 months ago
  57. 1169b31 [SAMZA-2667] Refactor logic in JobModelManager so it is easier to use certain parts of it (#1515) by Cameron Lee · 2 years, 9 months ago
  58. 39e5806 Bump azure blob store version since 12.0.1 no longer in mvn central by Daniel Chen · 2 years, 9 months ago
  59. 4824bfe SAMZA-2668: AzureBlobSystemProducer: using TokenCredential throws ResourceNotFound 404 when establishing connection (#1516) by lakshmi-manasa-g · 2 years, 10 months ago
  60. f404029 Merge pull request #1514 from apache/state-backend-async-commit by Prateek Maheshwari · 2 years, 10 months ago
  61. c95d828 Merge pull request #1513 from dxichen/merge-state-backend-async-commit by Prateek Maheshwari · 2 years, 10 months ago state-backend-async-commit
  62. e975b86 Merge branch 'master' into state-backend-async-commit by Daniel Chen · 2 years, 10 months ago
  63. bad9ee8 [SAMZA-2666] Updating tests to use TestRunner framework (#1510) by Cameron Lee · 2 years, 10 months ago
  64. 48699c4 Merge pull request #1512 from dxichen/checkpoint-restore-precendence-cleanup by Prateek Maheshwari · 2 years, 10 months ago
  65. 65b5df6 Test fix for failing job: only backup persistent stores by shekhars-li · 2 years, 10 months ago
  66. 3c8a462 checkstyle for samza-api by Daniel Chen · 2 years, 10 months ago
  67. 785d506 checkstype cleanup by Daniel Chen · 2 years, 10 months ago
  68. ad408d5 Cleanup of TODOs by Daniel Chen · 2 years, 10 months ago
  69. e74c241 Added tests for CSM for non configured stores by Daniel Chen · 2 years, 10 months ago
  70. 0697457 Fixed case where there are no stores to backup for CSM by Daniel Chen · 2 years, 10 months ago
  71. 5379f97 Job level state backend configs by Daniel Chen · 2 years, 11 months ago
  72. 7676da9 Per store restore manager config precendence by Daniel Chen · 2 years, 11 months ago
  73. 35c0dbc Checkpoint version config precedence list by Daniel Chen · 3 years ago
  74. 7f5ff3a Updated log line in BlobStoreUtil by shekhars-li · 3 years ago
  75. 7d61a7d Added lastCommitNs and commitTimedOut metrics, updated default timeout to 30 mins by shekhars-li · 3 years ago
  76. 271ef64 Fix async cleanup TaskMetric by Daniel Chen · 3 years ago
  77. 2063155 HOT FIX: KafkaConsumerProxy without any registered TopicPartitions by Daniel Chen · 3 years ago
  78. 48a8785 Checkpoint-tool changes for checkpoint v2 by Daniel Chen · 3 years ago
  79. 354620f SnapshotIndexSerde serialization fixes by Daniel Chen · 3 years ago
  80. 8fa07fe Samza-2665: AzureBlob SystemProducer: stop block upload retrying when InterruptedException is thrown (#1511) by lakshmi-manasa-g · 2 years, 10 months ago
  81. 4c11067 SAMZA-2303: Exclude side inputs when handling end-of-stream and watermarks for high-level (#1506) by Cameron Lee · 2 years, 11 months ago
  82. 337628e SAMZA-2660: Add authentication via TokenCredential for AzureBlobSystemProducer (#1507) by lakshmi-manasa-g · 2 years, 11 months ago
  83. 1f0f8bd SAMZA-1885: Enable parallel task execution for build (#1504) by Cameron Lee · 3 years ago
  84. c2b77f0 Fix StorageConfig bug from newly introduced BlobStoreRestore factory config (#1503) by shekhars-li · 3 years ago
  85. 7cc4eaa SAMZA-2657: Blob Store as backend for Samza State backup and restore (#1501) by shekhars-li · 3 years ago
  86. 08931ce KafkaChangelogKeySerde should support deserializing multiple keys (#1502) by Daniel Chen · 3 years ago
  87. d5f5494 Merge pull request #1492 from perkss/SAMZA-398-allow-compressed-changelog by Yi Pan · 3 years ago
  88. 23627cc [SAMZA-2655] Expose RocksDB maxOpenFiles setting as Samza parameter (#1500) by Adam Faris · 3 years, 1 month ago
  89. c85aade SAMZA-2591: Async Commit [3/3]: Container restore lifecycle (#1491) by Daniel Chen · 3 years, 1 month ago
  90. c2ef12f SAMZA-2653: Write pathing jar of run-class.sh into its own directory (#1498) by Cameron Lee · 3 years, 1 month ago
  91. c117a68 SAMZA-2591: Async Commit [2/3]: Task Commit api changes and async commit (#1490) by Daniel Chen · 3 years, 1 month ago
  92. 96b09b5 SAMZA-2649: Add MetricsReporter which logs metrics to log file (#1495) by Cameron Lee · 3 years, 1 month ago
  93. aa58950 SAMZA-2591: Async Commit [1/3]: Checkpoint v2 migration (#1489) by Daniel Chen · 3 years, 1 month ago
  94. 65e51ec SAMZA-2654: Allow coordinator url port to be configurable (#1499) by Cameron Lee · 3 years, 1 month ago
  95. 2563caa SAMZA-2648: Add simple placeholder FaultDomainManager for when YARN is not used (#1494) by Cameron Lee · 3 years, 1 month ago
  96. 8250a43 SAMZA-2652: Application Master High Availability metric - change counter to gauge (#1497) by lakshmi-manasa-g · 3 years, 1 month ago
  97. de067c4 SAMZA-2647: Clean up unused split deployment code (#1493) by Cameron Lee · 3 years, 1 month ago
  98. 33bc5be SAMZA-2650: [Scala cleanup] Convert ShellCommandBuilder from scala to java (#1496) by Cameron Lee · 3 years, 1 month ago
  99. 8ecd445 SAMZA-2646: Minor refactor of StreamAppender to support sending formats other than byte[] to SystemProducer (#1488) by lakshmi-manasa-g · 3 years, 1 month ago
  100. 9d9ebc7 SAMZA-398: Remove force NONE compression for changelog topic producer by perkss · 3 years, 1 month ago