Google Git
Sign in
apache / samza / HEAD
  1. f44b4f7 Fix AvroRelConverter to only consider cached schema while populating SamzaSqlRelRecord for all the nested records. by Aditya Toomula · 4 years, 5 months ago
  2. 9b8f841 doc and blog related update on master branch for 1.3.0 release (#1231) by Hai Lu · 4 years, 5 months ago
  3. 6ab1249 [DOCS] Update kafka consumer command to use bootstrap-server (#1232) by lakshmi-manasa-g · 4 years, 5 months ago
  4. fed0359 update gradle properties to mark 1.4.0 as the next version (#1230) by Hai Lu · 4 years, 5 months ago
  5. 19a0581 SAMZA-2388: [Scala cleanup] Convert Util to Java (#1221) by Cameron Lee · 4 years, 5 months ago
  6. bad38b8 SAMZA-2403: fix standalone integration failure (#1225) by Hai Lu · 4 years, 5 months ago
  7. a618245 update release instruction to include integration tests (#1224) by Hai Lu · 4 years, 5 months ago
  8. 3832bf8 SAMZA-2333: [AM isolation] Use cytodynamics classloader to launch job coordinator (#1173) by Cameron Lee · 4 years, 5 months ago
  9. 1feaa50 Allow users to configure URL's in reflection-based-resolver. (#1222) by shanthoosh · 4 years, 6 months ago
  10. be1b8ac SAMZA-2324: Adding maximum (serialized) record size metrics for rocksdb (#1209) by bkonold · 4 years, 6 months ago
  11. 33fc0b8 SAMZA-2386: Get store names should return correct store names in the presence of side inputs (#1220) by mynameborat · 4 years, 6 months ago
  12. f6295aa SAMZA-2381: Refactor JobRunner#run and split into multiple util methods. (#1217) by Ke Wu · 4 years, 6 months ago
  13. fa873bf Fixed javadoc compilation warnings (api, sql-shell, yarn) (#1206) by micpod · 4 years, 6 months ago
  14. 86ab945 SAMZA-2382: User specified side input processor should take precedence over the identity processor (#1218) by rmatharu · 4 years, 6 months ago
  15. ba02b46 SAMZA-2377: Batch mode should be computed based on generated configs (#1215) by xinyuiscool · 4 years, 6 months ago
  16. 0ee458f Merge pull request #1216 from sborya/DocConfigSingle by Boris Shkolnik · 4 years, 6 months ago
  17. 6e32400 fixed a typo in the config table doc by Boris Shkolnik · 4 years, 6 months ago
  18. 6aacee2 SAMZA-2375, SAMZA-2376: Add display name to UdfMetadata and handle trailing semi-colons (#1214) by Aditya Toomula · 4 years, 6 months ago
  19. bd9e9d8 SAMZA-1949: Add java docs and configuration documentation for side inputs (#1064) by mynameborat · 4 years, 6 months ago
  20. 5defb06 Fixed typo in SqlFieldSchema::getValueSchema method name (#1205) by micpod · 4 years, 6 months ago
  21. dec929f Adding gpg key to KEYS for Hai (#1212) by Hai Lu · 4 years, 6 months ago
  22. ab1512f SAMZA-2340: [Container Placements] Introduce ContainerManager for handling validation for failures & starts of active & standby containers (#1211) by Sanil Jain · 4 years, 6 months ago
  23. 6a9896b Revert "SAMZA-2340: [Container Placements] Introduce ContainerManager for handling validation for failures & starts of active & standby containers" (#1208) by rmatharu · 4 years, 6 months ago
  24. 6201be1 SAMZA-2372: Null pointer exception in LocalApplicationRunner (#1210) by IgorDurovic · 4 years, 6 months ago
  25. 4f715d3 SAMZA-2340: [Container Placements] Introduce ContainerManager for handling validation for failures & starts of active & standby containers (#1180) by rmatharu · 4 years, 6 months ago
  26. de215f1 SAMZA-2364: Include the localized resource lib directory in the classpath of SamzaContainer (#1207) by shanthoosh · 4 years, 6 months ago
  27. bc8b01c Upgrade Gradle to 5.2.1 (#1203) by lakshmi-manasa-g · 4 years, 6 months ago
  28. 45decc2 Merge branch 'master' into container-placement-service by Sanil15 · 4 years, 6 months ago
  29. ede9d4c SAMZA-2358: refactor rewriterConfig to java (#1199) by MabelYC · 4 years, 6 months ago
  30. d99a870 Revert "Samza-2330: Handle expired resource request for Container allocator when host affinity is disabled" by Sanil Jain · 4 years, 6 months ago
  31. c5af0af SAMZA-2360 : Adding config stores.init.clean to clean all store-dirs on init, regardless of contents (#1200) by rmatharu · 4 years, 6 months ago
  32. f72577d SAMZA-2334: SSPGrouperProxy should check if job is stateful, not if host-affinity is enabled (#1179) by Daniel Nishimura · 4 years, 6 months ago
  33. 2671231 Include the ScalarUDF implementations with the configured package prefix in ReflectionBasedUdfResolver. (#1202) by shanthoosh · 4 years, 6 months ago
  34. 80f06f3 SAMZA-2332: [AM isolation] YarnJob should pass new command and additional environment variables for AM deployment (#1172) by Cameron Lee · 4 years, 6 months ago
  35. 9a9b7d7 SAMZA-2356: [Transactional State] Do not trim changelog if time since last checkpoint is greater than min.compaction.lag. (#1196) by Prateek Maheshwari · 4 years, 7 months ago
  36. a50a62f Moving writeMetadataFile() invocation to ContainerLaunchUtil from LocalContainerRunner (#1198) by rmatharu · 4 years, 7 months ago
  37. e7361bb Update Documentation (#1189) by Ke Wu · 4 years, 7 months ago
  38. 842f970 SAMZA-2352: Use min.compaction.lag.ms to avoid compacting the Kafka changelog topic (#1190) by xinyuiscool · 4 years, 7 months ago
  39. e2928e1 SAMZA-2354: Improve UDF discovery in samza-sql. (#1192) by shanthoosh · 4 years, 7 months ago
  40. 493b275 Revert "SAMZA-2324: Adding KV store metrics for rocksdb (#1158)" (#1194) by bkonold · 4 years, 7 months ago
  41. 4eb5e52 Bugfix: Notify the BEM from KafkaSystemConsumer (#1193) by rmatharu · 4 years, 7 months ago
  42. 4f29de6 [Minor] Fixed incorrect log message during changelog restore. (#1191) by Prateek Maheshwari · 4 years, 7 months ago
  43. cb78a61 SAMZA-2348 : Notifying BEM about kafkaConsumerProxy failure to prevent BEM poll-blockin in case of proxy failures (#1187) by rmatharu · 4 years, 7 months ago
  44. 6258d2b SAMZA-2347: Samza Sql - Fix AvroTypeFactoryImpl to properly denote a field as optional and nullable. (#1186) by Aditya Toomula · 4 years, 7 months ago
  45. 26df437 SAMZA-2347: Samza Sql - Fix AvroTypeFactoryImpl to properly denote a field as optional and nullable. by Aditya Toomula · 4 years, 7 months ago
  46. 223d371 Addressing feedback minor improvements by Sanil15 · 4 years, 7 months ago
  47. 5660b86 SAMZA-2343: Remove original split deployment code (#1182) by Cameron Lee · 4 years, 7 months ago
  48. b8708ed SAMZA-2347: Samza Sql - Fix AvroTypeFactoryImpl to properly denote a field as optional and nullable. by Aditya Toomula · 4 years, 7 months ago
  49. aba8d04 Transactional State [5/5]: Added implementations for transactional state checkpoints and restore (#1164) by Prateek Maheshwari · 4 years, 7 months ago
  50. ebca883 SAMZA-2160 - Ability to configure application type on YARN deploys (#1185) by Abhishek Shivanna · 4 years, 7 months ago
  51. 84d45c2 SAMZA-2347: Samza Sql - Fix AvroTypeFactoryImpl to properly denote a field as optional and nullable. by Aditya Toomula · 4 years, 7 months ago
  52. 71e5ae5 SAMZA-2347: Samza Sql - Fix AvroTypeFactoryImpl to properly denote a field as optional and nullable. by Aditya Toomula · 4 years, 7 months ago
  53. a9f06da SAMZA-2340: Introduce ContainerManager for handling validation for failures & starts for active & standby containers by Sanil15 · 4 years, 7 months ago
  54. a3dd6fd SAMZA-2346: Fixing Test timeouts for Allocator testing (#1184) by Sanil Jain · 4 years, 7 months ago
  55. f0e77eb Add validation for delete op and change RelSchemaConverter to set all fields to nullable regardless of nullable flag in sql schema. (#1183) by Aditya Toomula · 4 years, 7 months ago
  56. a07e386 SAMZA-2324: Adding KV store metrics for rocksdb (#1158) by bkonold · 4 years, 7 months ago
  57. dc55bd3 Transactional State [4/5]: Added new interfaces for TaskRestoreManager and TaskStorageManager by Prateek Maheshwari · 4 years, 7 months ago
  58. 2ae3450 Samza-2330: Handle expired resource request for Container allocator when host affinity is disabled (#1170) by Sanil Jain · 4 years, 7 months ago
  59. 6057a49 Update KafkaSystemAdmin to adhere to the checkpoint replication factor (#1177) by VartulAgrawal · 4 years, 7 months ago
  60. 7380f19 SAMZA-2341: Make the Udf type mismatch validation failure string more user friendly (#1181) by Aditya Toomula · 4 years, 7 months ago
  61. 6c90ce6 SAMZA-2320: Samza-sql: Refactor validation to cover more cases and make it more extensible. (#1153) by Aditya Toomula · 4 years, 7 months ago
  62. c92df1e Introducing ContainerManager the brain of JC by Sanil15 · 4 years, 7 months ago
  63. 159683b SAMZA-2322: Integrate startpoints with ZK Standalone integration tests. (#1155) by Daniel Nishimura · 4 years, 7 months ago
  64. bc15f5b SAMZA-1757: Tests in samza-api which are written in Scala are not triggered (#1176) by Cameron Lee · 4 years, 7 months ago
  65. a6338f5 Merge pull request #1175 from joncwong/patch-2 by mynameborat · 4 years, 7 months ago
  66. b3f93cb Fix typo in Slack case study by Jonathan Wong · 4 years, 7 months ago
  67. a4d8014 Transactional State [3/5]: Made StorageManagerUtil and FileUtil non-static for mocking side effects in tests by Prateek Maheshwari · 4 years, 7 months ago
  68. 3e5ede6 Transactional State [2/5]: Added a ChangelogSSPIterator API by Prateek Maheshwari · 4 years, 7 months ago
  69. 18755a3 Transactional State [1/5]: Added Store Checkpoint API by Prateek Maheshwari · 4 years, 7 months ago
  70. 554f7c5 Fix ClusterBasedProcessorLifecycleListener test to exit without waiting for timeout (#1159) by Abhishek Shivanna · 4 years, 7 months ago
  71. 4ba15fe SAMZA-2335: Remove classloader argument from ReflectionUtil (#1174) by Cameron Lee · 4 years, 7 months ago
  72. fb7f1b3 Renaming AbstractContainerAllocator to ContainerAllocator (#1169) by Sanil Jain · 4 years, 7 months ago
  73. fab7c56 Merge pull request #1171 from sborya/StreamConfigJava1 by Boris Shkolnik · 4 years, 7 months ago
  74. 20f8508 modified comment by Boris S · 4 years, 7 months ago
  75. 548c9f0 review comments by Boris S · 4 years, 7 months ago
  76. ba1d456 SAMZA-2319: [1/2] Simplify Container Allocation logic (#1152) by Sanil Jain · 4 years, 7 months ago
  77. f0b2f4c rename back to StreamConfig by Boris S · 4 years, 7 months ago
  78. a109588 add comments by Boris S · 4 years, 7 months ago
  79. 135b17c updates by Boris S · 4 years, 7 months ago
  80. f862358 more cleanup by Boris S · 4 years, 7 months ago
  81. c5791ac added file by Boris S · 4 years, 7 months ago
  82. ad95122 replaced StreamConfig with StreamConfigJava by Boris S · 4 years, 7 months ago
  83. 57f8bac rename by Boris S · 4 years, 7 months ago
  84. 6d91400 SAMZA-2328: [Scala cleanup] Convert StreamConfig to Java (part 1: update test coverage and clarify functionality in javadocs) (#1166) by Cameron Lee · 4 years, 7 months ago
  85. 6b19cd6 SAMZA-2323: Provide option allow single containers to fail without failing the job (#1156) by Daniel Nishimura · 4 years, 7 months ago
  86. 0effeb6 SAMZA-2326 : Add interface to support specific configs (#1165) by MabelYC · 4 years, 7 months ago
  87. 48b3c8e Samza-2331: Fix java doc of table descriptor for default rate limiter (#1168) by Hai Lu · 4 years, 7 months ago
  88. 96097a4 Merge pull request #1167 from mynameborat/watermark-fix by mynameborat · 4 years, 7 months ago
  89. 686be0b SAMZA-2329: Chain watermark future to the result future in onMessageAsync by mynameborat · 4 years, 7 months ago
  90. e6fe169 SAMZA-2325 : Adding logic to read system config for repl-factor when creating a topic (#1157) by rmatharu · 4 years, 8 months ago
  91. eace5a2 [SAMZA-2198] Fix deadlock in container signal handler (#1151) by Abhishek Shivanna · 4 years, 8 months ago
  92. 83e1529 SAMZA-2321: Samza-sql - Introduce REAL Samza sql schema type (#1154) by Aditya Toomula · 4 years, 8 months ago
  93. 5af4b3b SAMZA-2318: Empty config values from coordinator stream shouldn't be removed (#1150) by dengpanyin · 4 years, 8 months ago
  94. 713a8bf SAMZA-2316: Validate that all non-default value fields in output schema are set in the projected fields. (#1149) by Aditya Toomula · 4 years, 8 months ago
  95. ae8e857 [SAMZA-2283] Samza Sql Diagnostics: use Nanosecond for logical operator processing time and query latency (#1117) by Shenoda Guirguis · 4 years, 8 months ago
  96. 97afd3f SAMZA-2313: Adding validation for Samza Sql statements. (#1148) by Aditya Toomula · 4 years, 8 months ago
  97. e0b5a32b1 SAMZA-2298: Fix CoordinatorStreamStore creation for LocalApplicationRunner (#1136) by Daniel Nishimura · 4 years, 8 months ago
  98. 767a5d4 SAMZA-2311 : Removing use of logger from appender (#1146) by rmatharu · 4 years, 8 months ago
  99. c8f8757 Emitting numPersistentStores instead of num stores with changelog from DiagnosticsManager (#1145) by rmatharu · 4 years, 8 months ago
  100. 19c977c SAMZA-2309: Remove readFn requirement for remote tables (#1144) by Daniel Chen · 4 years, 9 months ago