Google Git
Sign in
apache / samza / HEAD
  1. c92b7a5 make MonitorPartition thread a daemon by Boris S · 3 years, 9 months ago
  2. dcbdf89 clean up comments and code by Cheng · 3 years, 9 months ago
  3. a05c6e4 address comment: adding javadoc and change to a more reasonable name by Cheng · 3 years, 9 months ago
  4. 2b148c9 SAMZA-2561: Add config map to DiagnosticsManager (#1406) by Pawas Chhokra · 3 years, 9 months ago
  5. 2092530 rename the input parameter by Cheng · 3 years, 9 months ago
  6. 7c4b31e SAMZA-2569: Add features into StreamAppender (#1403) by Binyao Jiang · 3 years, 9 months ago
  7. 5c4834e SAMZA-2575: Fix the flatten output values and add more tests (#1409) by Slim Bouguerra · 3 years, 9 months ago
  8. 984978b SAMZA-2574:improve flexibility of SystemFactory interface by Cheng · 3 years, 9 months ago
  9. e7d3067 Merge pull request #1 from apache/master by MabelYC · 3 years, 9 months ago
  10. 3b7d0d1 SAMZA-2562: [Scala cleanup] Clean up Scala in samza-kv-inmemory and samza-kv-couchbase (#1404) by Cameron Lee · 3 years, 9 months ago
  11. f5faae0 [SAMZA-2557] Adding support for nested rows access via dot path. (#1386) by Slim Bouguerra · 3 years, 10 months ago
  12. 0d8de7a SAMZA-2560: Generate SamzaSQLRelRecord using avro schema of input event instead of cached-schema. (#1401) by shanthoosh · 3 years, 10 months ago
  13. f665824 SAMZA-2549 - Samza-sql: Add query optimizations for remote table joins (#1384) by Aditya Toomula · 3 years, 10 months ago
  14. 6a3c6e4 [DOCS] Update the docs & blogs for 1.5.0 release (#1399) by mynameborat · 3 years, 10 months ago
  15. c2e7025 SAMZA-2551: Upgrade all modules to automatically use checkstyle 6.11.2 (part 6: enable for all modules) (#1397) by Cameron Lee · 3 years, 10 months ago
  16. 8a9a5e3 SAMZA-2554: Fix the handling of join condition against remote table (#1393) by Slim Bouguerra · 3 years, 10 months ago
  17. 3f38b21 SAMZA-2551: Upgrade all modules to automatically use checkstyle 6.11.2 (part 5: includes samza-yarn, samza-rest) (#1396) by Cameron Lee · 3 years, 10 months ago
  18. fcf1bbc SAMZA-2551: Upgrade all modules to automatically use checkstyle 6.11.2 (part 3: includes samza-kafka) (#1394) by Cameron Lee · 3 years, 10 months ago
  19. 8823fb0 SAMZA-2551: Upgrade all modules to automatically use checkstyle 6.11.2 (part 4: includes samza-sql, samza-sql-shell) (#1395) by Cameron Lee · 3 years, 11 months ago
  20. 188b9bb SAMZA-2551: Upgrade all modules to automatically use checkstyle 6.11.2 (part 2: includes all modules with checkstyle currently enabled, excluding samza-core) (#1390) by Cameron Lee · 3 years, 11 months ago
  21. 4e2fa96 SAMZA-2552: Avoid logging false positive error message on each record. (#1387) by Slim Bouguerra · 3 years, 11 months ago
  22. 3a66141 SAMZA-2555: Prevent downloading checkstyle DTD over the internet (#1391) by Kyle Moore · 3 years, 11 months ago
  23. ef4fbef SAMZA-2553: Fix NPE when one of the condition value is null (#1388) by Slim Bouguerra · 3 years, 11 months ago
  24. 5f05cdd SAMZA-2551: Upgrade all modules to automatically use checkstyle 6.11.2 (part 1: includes samza-core) (#1389) by Cameron Lee · 3 years, 11 months ago
  25. a5f7a66 SAMZA-2516: Migrate BaseKeyValueStorageEngineFactory to be an abstract class instead of trait (#1352) by Cameron Lee · 3 years, 11 months ago
  26. 0b65dbf [Minor test fix] Enabled and fixed a TestKafkaCheckpointManager test (#1382) by Cameron Lee · 3 years, 11 months ago
  27. 322bfdd SAMZA-2547: Add missing "tableId" for SendToTableOperatorSpec in Samza job execution plan (#1381) by Alan Zhang · 4 years ago
  28. 27e95d5 SAMZA-2533: Fix DiagnosticsUtil to use configured MetricsReporterFactory (#1369) by Abhishek Shivanna · 4 years ago
  29. 47a6890 Dynamically choose a port for Jersey test HTTP server (#1380) by Alan Zhang · 4 years ago
  30. 9346522 SAMZA-2530: Split out processing logic from TaskSideInputStorageManager (#1367) by bkonold · 4 years ago
  31. bcee407 SAMZA-2504: Improve Container Placement Flaky Test & Running Time by Sanil15 · 4 years ago
  32. 89538a9 SAMZA-2545: Fix testBatchOperationTriggeredByBatchSize flakiness by mynameborat · 4 years ago
  33. 8c753eb SAMZA-2544: Adding cleanup for Container Placement tests using threads, coordinator stream stores by Sanil15 · 4 years ago
  34. 07917f6 SAMZA-2542: Fix integration-tests by Ke Wu · 4 years ago
  35. c4f2c5d Samza-2540: Legacy Task application are missing app.run.id for both batch & stream jobs (#1375) by Sanil Jain · 4 years ago
  36. fbe8349 SAMZA-2442: Update doc/tutorials from config factory to config loader by Ke Wu · 4 years ago
  37. 8641081 Fixing log message for trimmed messages during state restore (#1356) by bkonold · 4 years ago
  38. 9e28134 SAMZA-2532: Refactor MetricsSnapshotReporter and MetricsSnapshotReporterFactory (#1368) by Abhishek Shivanna · 4 years ago
  39. b3d5dc3 SAMZA-2538: Update build.gradle from using config-path to job.config.loader.properties.path by Ke Wu · 4 years ago
  40. 85afbb7 SAMZA-2537: Fix JobCoordinatorLaunchUtil's execution sequence. by Ke Wu · 4 years ago
  41. bb7d65e Add PGP key to KEYS for Bharath by mynameborat · 4 years ago
  42. f134f0f SAMZA-2529: Extract interface from TaskInstance for reuse of RunLoop (#1366) by bkonold · 4 years ago
  43. 583da77 SAMZA-2534: AzureBlobSystemProducer: Enable adding of number of records in blob as metadata of the blob (#1364) by lakshmi-manasa-g · 4 years ago
  44. 3e18e19 SAMZA-2526: Azure blob system producer: do not commit blobs if avro DataFileWriter.close fails (#1362) by lakshmi-manasa-g · 4 years ago
  45. 160bbb2 SAMZA-2527:MetadataStore is not initialized before reading in JobCoordinatorLaunchUtil (#1365) by Ke Wu · 4 years ago
  46. 0a7760a SAMZA-2506: Inconsistent end of stream semantics in SystemStreamPartitionMetadata (#1345) by bkonold · 4 years ago
  47. 5e73b1f SAMZA-2525:Fix race condition in ClientHelper#isActiveApplication (#1361) by Ke Wu · 4 years ago
  48. 9f24f15 SAMZA-2522: Add metadata generator for azure storage blob (#1358) by lakshmi-manasa-g · 4 years ago
  49. ae82b0a SAMZA-2524:Fix Util#envVarEscape not to escape apostrophe (#1360) by Ke Wu · 4 years ago
  50. ca57730 SAMZA-2523: Update Util#envVarEscape to escape more characters (#1359) by Ke Wu · 4 years ago
  51. a29f29a SAMZA-2519: Support duplicate timer registration (#1355) by mynameborat · 4 years ago
  52. 70cfd3d SAMZA-2521 Aligning dependency versions between Samza Sql and Calcite, moving to commons-compiler 3.0.11 (#1357) by Slim Bouguerra · 4 years ago
  53. 0080433 Setting transactional state restore to default enabled (#1346) by bkonold · 4 years ago
  54. 10915fb SAMZA-2518: Update JobCoordinatorLaunchUtil to fetch launch config from metadata store. (#1354) by Ke Wu · 4 years ago
  55. 9977adf SAMZA-2517 : Adding handling and relevant exception message for null in oldest offset from system-admin (#1353) by rmatharu · 4 years ago
  56. a97f249 SAMZA-2515: Kafka consumer synchronized (#1351) by lakshmi-manasa-g · 4 years ago
  57. e86951f SAMZA-2514: Refactor codes to make runWithClassLoader method more generic (#1349) by Alan Zhang · 4 years ago
  58. 9f2d6dd Merge pull request #1348 from sborya/MDC_For_Beam by Boris Shkolnik · 4 years, 1 month ago
  59. 4af3179 Set MFC for logging for both Beam and non-beam apps by Boris S · 4 years, 1 month ago
  60. ae8bb2c populate MDC for both Beam and non-Beam applications by Boris S · 4 years, 1 month ago
  61. d745e7d SAMZA-2509: New config name to represent if split deployment feature is enabled (#1342) by Alan Zhang · 4 years, 1 month ago
  62. 9eadad1 SAMZA-2511 : Adding logic to handle container stop fail (#1347) by rmatharu · 4 years, 1 month ago
  63. 470ae2c SAMZA-2510: Incorrect shutdown status due to race between runloop and process callback thread (#1344) by mynameborat · 4 years, 1 month ago
  64. fff0bb0 SAMZA-2507: Bumping calciteVersion 1.19.0-->1.22.0. (#1341) by Aditya Toomula · 4 years, 1 month ago
  65. 76963c9 SAMZA-2503 : Adding retry when getting ssp metadata from kafka (#1339) by MabelYC · 4 years, 1 month ago
  66. 5e31503 disable transactional state restore in cases where standby or async commit are enabled (#1340) by bkonold · 4 years, 1 month ago
  67. b193d45 SAMZA-2493: Keep checkpoint manager consumer open for repeated polling (#1327) by bkonold · 4 years, 1 month ago
  68. 291e854 SAMZA-2502: Byte array keys be partitioned based on array contents in… (#1338) by Yixing Zhang · 4 years, 1 month ago
  69. a086ae0 SAMZA-2499: Add submission config file support (#1336) by Ke Wu · 4 years, 1 month ago
  70. 26d9eec SAMZA-2501 : Optimizing startpoint manager to not make successive bootstrapMessage calls to coordinator-store (#1335) by rmatharu · 4 years, 1 month ago
  71. c527ec5 SAMZA-2491: AM should log uncaught exceptions and System.exit to ensure that the process dies on errors (#1325) by Hai Lu · 4 years, 1 month ago
  72. bbb5bde SAMZA-2496: TestContainerHeartbeatMonitor does not properly stop the ContainerHeartbeatMonitor (#1334) by Cameron Lee · 4 years, 1 month ago
  73. b0fdb82 Add docs for configs of Azure Blob SystemProducer (#1323) by lakshmi-manasa-g · 4 years, 1 month ago
  74. 0d63d00 Remove TestSuiteAnnotation from TestBatchProcessor (#1329) by PanTheMan · 4 years, 1 month ago
  75. a8eee8b SAMZA-2481: Improve memory usage in samza-core unit tests (#1324) by Cameron Lee · 4 years, 2 months ago
  76. 74261aa [Minor] bump version to 1.5.0 since Samza 1.4 has been released (#1322) by Cameron Lee · 4 years, 2 months ago
  77. 8995438 [Documentation] clarifying some of the release instructions (#1321) by Cameron Lee · 4 years, 2 months ago
  78. 6685b28 SAMZA-2490: AsyncFlatmapOperatorImpl#handleClose should call transformFn.close() (#1320) by Yixing Zhang · 4 years, 2 months ago
  79. 05e5fd9 [minor] fix version property in releases pages (#1319) by Cameron Lee · 4 years, 2 months ago
  80. b7cab95 SAMZA-2488: Add JobCoordinatorLaunchUtil to handle common logic when launching job coordiantor. (#1318) by Ke Wu · 4 years, 2 months ago
  81. 7d09f23 blog and other website updates for Samza 1.4.0 release (#1317) by Cameron Lee · 4 years, 2 months ago
  82. 170be04 Samza-2478: Add new metrics to track key and value size of records written to RocksDb (#1301) by mynameborat · 4 years, 2 months ago
  83. f113a03 modify java doc by Fan Xie · 4 years, 2 months ago
  84. b97c130 Add java doc in MetricGroup by Fan Xie · 4 years, 2 months ago
  85. 3364c91 remove lines by Fan Xie · 4 years, 2 months ago
  86. 5e52b28 SAMZA-2479: Add configurable default for min compaction lag ms (#1305) by bkonold · 4 years, 2 months ago
  87. 9bd3d61 SAMZA-2486: Update TestFileReaderSystemAdmin to use test resource files (#1315) by Ke Wu · 4 years, 2 months ago
  88. b06cb3f SAMZA-2477: JobModel isn't updated with latest "task.inputs" if enabled regex topic rewriter (#1299) by Alan Zhang · 4 years, 2 months ago
  89. 215947f Fix new flaky test (#1306) by lakshmi-manasa-g · 4 years, 2 months ago
  90. c864c4c Fix flaky tests for Container Placements (#1314) by Sanil Jain · 4 years, 2 months ago
  91. d047b89 track the maximum key sizes by Fan Xie · 4 years, 2 months ago
  92. 5c02b92 modify by Fan Xie · 4 years, 2 months ago
  93. fa50c72 update docs by Fan Xie · 4 years, 2 months ago
  94. 48fc94a Fix the issue that getAppMainArgs and getAppMainClass is reversed (#1313) by Ke Wu · 4 years, 2 months ago
  95. d660871 SAMZA-2466: [Scala cleanup] Convert ShellCommandConfig from scala to java (#1288) by Cameron Lee · 4 years, 2 months ago
  96. b84c8b7 [Test fix] removing minHeapSize and increasing maxHeapSize to 4g (#1311) by Cameron Lee · 4 years, 2 months ago
  97. b8309aa SAMZA-2475: Fix allocated resource expiry bug (#1310) by Sanil Jain · 4 years, 2 months ago
  98. e4eefe2 SAMZA-2453: Update ClusterBasedJobCoordinator to support Beam jobs (#1309) by Ke Wu · 4 years, 2 months ago
  99. 896cfee SAMZA-2482: Add app.main.class and app.main.args in ApplicationConfig (#1308) by Ke Wu · 4 years, 2 months ago
  100. 0dafc28 SAMZA-2317: ProcessJob does not call CoordinatorStreamStore.close() (#1289) by PanTheMan · 4 years, 2 months ago