Google Git
Sign in
apache / samza / HEAD
  1. 84a9e83 [Test fix]: Increasing heap allocation for test executor for samza-core tests after Gradle 5 upgrade (#1307) by Cameron Lee · 4 years, 2 months ago
  2. d6e4f67 SAMZA-2379: Support Container Placements for job running in degraded state (#1297) by Sanil Jain · 4 years, 2 months ago
  3. 1596e40 style check by Fan Xie · 4 years, 2 months ago
  4. bf8b7d2 Use RocksDbKeyValueStore instead of InMemoryKeyValueStore by Fan Xie · 4 years, 2 months ago
  5. 6d5f3a1 modify by Fan Xie · 4 years, 2 months ago
  6. 16899e3 check style by Fan Xie · 4 years, 2 months ago
  7. fd79504 license shift left by Fan Xie · 4 years, 2 months ago
  8. b7dbe5e modify by Fan Xie · 4 years, 2 months ago
  9. ea54f98 Merge branch 'master' into new_kv_metric by Fan Xie · 4 years, 2 months ago
  10. 9870dd2 check style by Fan Xie · 4 years, 2 months ago
  11. f112848 Add license by Fan Xie · 4 years, 2 months ago
  12. eff3df4 modify by Fan Xie · 4 years, 2 months ago
  13. 36ced5e reset by Fan Xie · 4 years, 2 months ago
  14. aad2ccf modify by Fan Xie · 4 years, 2 months ago
  15. a8ccc05 modify by Fan Xie · 4 years, 2 months ago
  16. f782bc8 modify by Fan Xie · 4 years, 2 months ago
  17. 8fe7c7f [DOCS] Remove duplicate committer file by Sanil15 · 4 years, 2 months ago
  18. 9d5c9ef SAMZA-2475: Add a allocated resource expiry timeout in samza yarn type of apps (#1303) by mynameborat · 4 years, 2 months ago
  19. 796d97b Revert "SAMZA-2475: Add a allocated resource expiry timeout in samza yarn type of apps (#1296)" (#1302) by rmatharu · 4 years, 2 months ago
  20. 3a6e48c SAMZA-2475: Add a allocated resource expiry timeout in samza yarn type of apps (#1296) by rmatharu · 4 years, 2 months ago
  21. 76d216e delete unused function by Fan Xie · 4 years, 2 months ago
  22. 6478824 coding done by Fan Xie · 4 years, 2 months ago
  23. 7e87d21 Add record key value size histogram metric by Fan Xie · 4 years, 2 months ago
  24. f8bfe87 SAMZA-2464: Container shuts down when task fails to remove old state checkpoint dirs (#1283) by bkonold · 4 years, 2 months ago
  25. b9ef56a SAMZA-2473: gradleVersion and wrapper jar are out-of-sync (#1295) by Kyle Moore · 4 years, 2 months ago
  26. 851fc48 SAMZA-2476:Fix flaky tests in TestAzureBlobOutputStream (#1298) by lakshmi-manasa-g · 4 years, 2 months ago
  27. d022167 SAMZA-2378: Container Placements support for Standby containers enabled jobs (#1281) by Sanil Jain · 4 years, 2 months ago
  28. 0aa1e7c SAMZA-2472: Use runtime-framework-resources-pathing.jar to specify part of the runtime classpath and leverage it in IsolatingClassLoaderFactory (#1293) by Cameron Lee · 4 years, 2 months ago
  29. e52aecd SAMZA-2471: Simplify CommandLine (#1291) by Ke Wu · 4 years, 2 months ago
  30. ded197d SAMZA-2468: Make Standby containers respond to shutdown request (#1290) by Sanil Jain · 4 years, 2 months ago
  31. eb215c5 upgrade jackson-core to 2.10.0 as needed by azure-storage-blob (#1277) by lakshmi-manasa-g · 4 years, 2 months ago
  32. 999f5e9 SAMZA-2461 Fix: Concurrent Modification Exception in InMemorySystem (#1280) by Yixing Zhang · 4 years, 2 months ago
  33. ae9349a Update blog and release notes for 1.3.1 release (#1285) by Hai Lu · 4 years, 2 months ago
  34. cd535d0 Updating hello-world open source instructions (#1284) by rmatharu · 4 years, 2 months ago
  35. 66f3b8e SAMZA-2419: removing duplicate cleaning of stores (#1236) by bkonold · 4 years, 2 months ago
  36. 9849c37 SAMZA-2463: Duplicate firings of processing timers (#1282) by mynameborat · 4 years, 2 months ago
  37. 0189b5d SAMZA-2456: Upgrade Rocksdb to 6.5.3 (#1275) by PanTheMan · 4 years, 2 months ago
  38. 031b5e2 SAMZA-2462 : Adding metric for container thread pool size (#1279) by rmatharu · 4 years, 2 months ago
  39. 93c1dd5 SAMZA-2458: Update ProcessJobFactory and ThreadJobFactory to load full job config (#1278) by Ke Wu · 4 years, 2 months ago
  40. b4a9fe6 SAMZA-2402: Tie Container placement service and Container placement handler and validate placement requests (#1267) by Sanil Jain · 4 years, 2 months ago
  41. 252a6e4 Merge pull request #1276 from lhaiesp/master by Boris Shkolnik · 4 years, 2 months ago
  42. fd5865f update pgp key in KEYS for Hai by Hai Lu · 4 years, 2 months ago
  43. f1a8b51 SAMZA-2448: [Scala cleanup] Clean up and convert some parts of samza-kafka to java (#1263) by Cameron Lee · 4 years, 2 months ago
  44. ea49010 SAMZA-2455: Validate the argument types in SamzaSQL UDF on execution planning phase (#1269) by shanthoosh · 4 years, 3 months ago
  45. b88922b adding Cameron Lee gpg key to KEYS (#1272) by Cameron Lee · 4 years, 3 months ago
  46. faf482e SAMZA-2452 : Adding internal autosizing related configs (#1266) by rmatharu · 4 years, 3 months ago
  47. ca641dc SAMZA-2444: JobModel save in CoordinatorStreamStore resulting flush for each message (#1259) by Alan Zhang · 4 years, 3 months ago
  48. 5a58877 SAMZA-2441: Update ApplicationRunnerMain#ApplicationRunnerCommandLine not to load local file (#1265) by Ke Wu · 4 years, 3 months ago
  49. 841c9a7 SAMZA-2373: [SEP-22] Container Placement Service (core functionality) for container move and restart (#1219) by Sanil Jain · 4 years, 3 months ago
  50. 92f53c7 SAMZA-2275: Azure Blob System Producer: fixes for high level jobs (#1258) by lakshmi-manasa-g · 4 years, 3 months ago
  51. 1a03a6a SAMZA-2420: Update CommandLine to use config loader for local config file (#1256) by Ke Wu · 4 years, 3 months ago
  52. e6e0f46 SAMZA-2429: Update LocalApplicationRunner to load full job config from config loader when present. (#1255) by Ke Wu · 4 years, 3 months ago
  53. 7259623 [MINOR] KafkaCheckPointManager -> Move log line so it does not have a forward reference. (#1262) by Jordan Messec · 4 years, 3 months ago
  54. 3ce0aa3 SAMZA-2447: Checkpoint dir removal should only search in valid store dirs (#1261) by bkonold · 4 years, 3 months ago
  55. 5ece27c SAMZA-2446: Invoke onCheckpoint only for registered SSPs (#1260) by bkonold · 4 years, 3 months ago
  56. 4e136a9 SAMZA-2443: Upgrade Jetty version to prevent AM file descriptor leak by Prateek Maheshwari · 4 years, 3 months ago
  57. d20b9b3 SAMZA-2397: Updating gauge-val function on newGauge on same metric name (#1223) by rmatharu · 4 years, 3 months ago
  58. b379933 SAMZA-2404: [SEP-22] Container Placement Handler for dispatching container placement messages between metastore and JobCoordinator (#1227) by Sanil Jain · 4 years, 3 months ago
  59. 5bef725 SAMZA-2410: Update ClusterBasedJobCoordinator config retrieval logic from loader. (#1248) by Ke Wu · 4 years, 3 months ago
  60. d28a1df SAMZA-2408: Update RemoteApplicationRunner to submit job only (#1247) by Ke Wu · 4 years, 3 months ago
  61. dd7b9b8 SAMZA-2409: Update YarnJob to construct job submission env variable (#1246) by Ke Wu · 4 years, 3 months ago
  62. 8a45efe Fix the RocksDB TTL type conversion in change log properties generation. (#1254) by shanthoosh · 4 years, 3 months ago
  63. 14bf312 SAMZA-2421: Add SystemProducer for Azure Blob Storage (#1239) by lakshmi-manasa-g · 4 years, 3 months ago
  64. 842d259 Merge pull request #1253 from abhishekshivanna/rc by Aditya Toomula · 4 years, 3 months ago
  65. 22f4747 Disable Flaky Tests by Abhishek Shivanna · 4 years, 3 months ago
  66. 80c799d SAMZA-2431: Fix the checkpoint and changelog topic auto-creation. (#1251) by shanthoosh · 4 years, 3 months ago
  67. 2827c96 Merge pull request #1252 from shanthoosh/fix-coordinator-streeam-ttl by Boris Shkolnik · 4 years, 3 months ago
  68. b3e1a4e5 Fix the coordinator stream creation workflow. by Shanthoosh Venkataraman · 4 years, 3 months ago
  69. eaa0491 Clean up unused org.apache.samza.autoscaling module (#1250) by Ke Wu · 4 years, 3 months ago
  70. 2659bc0 SAMZA-2428: Clean up unused org.apache.samza.sql.util.ConfigUtil (#1245) by Ke Wu · 4 years, 3 months ago
  71. db259fa Add "strict" parameter to all the log4j.xml files (#1244) by Boris Shkolnik · 4 years, 3 months ago
  72. 2a34cf2 Refactor LocalApplicationRunner (#1249) by Ke Wu · 4 years, 4 months ago
  73. a90563f Merge pull request #1238 from kw2542/SAMZA-2407 by Boris Shkolnik · 4 years, 4 months ago
  74. 00c1616 Move CONFIG_LOADER_PROPERTIES_PREFIX from JobConfig to ConfigLoaderFactory by Ke Wu · 4 years, 4 months ago
  75. 84f5cad Update javadoc by Ke Wu · 4 years, 4 months ago
  76. b58aeea Merge branch 'master' of https://github.com/apache/samza into SAMZA-2407 by Ke Wu · 4 years, 4 months ago
  77. abdaf1b Merge pull request #1237 from kw2542/SAMZA-2406 by Boris Shkolnik · 4 years, 4 months ago
  78. 090f49c Fix typo and switch to Optional for getConfigLoaderFactory by Ke Wu · 4 years, 4 months ago
  79. ea38575 Revert indentions change by Ke Wu · 4 years, 4 months ago
  80. f0c706b Merge branch 'master' of https://github.com/apache/samza into SAMZA-2407 by Ke Wu · 4 years, 4 months ago
  81. 7651ed3 Add javadoc for PropertiesConfigLoader by Ke Wu · 4 years, 4 months ago
  82. d59aa7e Update JavaDocs by Ke Wu · 4 years, 4 months ago
  83. 2f1762c Add getConfigLoaderFactory() for easy access to config loader factory. by Ke Wu · 4 years, 4 months ago
  84. de6b094 Remove unused import by Ke Wu · 4 years, 4 months ago
  85. a649f88 Update javadoc by Ke Wu · 4 years, 4 months ago
  86. 8ded2b1 Update javadoc by Ke Wu · 4 years, 4 months ago
  87. beb5e1b Merge pull request #1242 from atoomula/join_subquery by Aditya Toomula · 4 years, 4 months ago
  88. abeb06f SAMZA-2425: Add support for sub-query in joins by Aditya Toomula · 4 years, 4 months ago
  89. 08ee3a3 SAMZA-2423: Heartbeat failure causes incorrect container shutdown (#1240) by Abhishek Shivanna · 4 years, 4 months ago
  90. f9a34c0 Merge branch 'SAMZA-2407' of https://github.com/kw2542/samza into SAMZA-2407 by Ke Wu · 4 years, 4 months ago
  91. 36990a3 SAMZA-2407: Add job.config.loader.* configs in JobConfig & corresponding env variables in ShellCommandConfig by Ke Wu · 4 years, 4 months ago
  92. f389dbd Add license info by Ke Wu · 4 years, 4 months ago
  93. 057d69f SAMZA-2407: Add job.config.loader.* configs in JobConfig & corresponding env variables in ShellCommandConfig by Ke Wu · 4 years, 4 months ago
  94. dad5d96 Merge branch 'SAMZA-2406' of https://github.com/kw2542/samza into SAMZA-2406 by Ke Wu · 4 years, 4 months ago
  95. c2b1af2 SAMZA-2406: Add ConfigLoader, ConfigLoaderFactory interface and default PropertiesConfigLoader as well as PropertiesConfigLoaderFactory implementations. by Ke Wu · 4 years, 4 months ago
  96. 0611d38 SAMZA-2406: Add ConfigLoader, ConfigLoaderFactory interface and default PropertiesConfigLoader as well as PropertiesConfigLoaderFactory implementations. by Ke Wu · 4 years, 4 months ago
  97. 454bfab SAMZA-2418: Integration tests are failing and do not properly pass params to zopkio (#1235) by Cameron Lee · 4 years, 4 months ago
  98. 6ff4863 Adding null-check before incrementing metrics for bytesSerialized (#1234) by rmatharu · 4 years, 5 months ago
  99. 0436528 SAMZA-2305: Stream processor should ensure previous container is stopped during a rebalance (#1213) by mynameborat · 4 years, 5 months ago
  100. fb20518 Merge pull request #1233 from atoomula/schema_fix by Aditya Toomula · 4 years, 5 months ago