SAMZA-1478: Delete unneeded data from intermediate Kafka topic on offset commit
[samza.git] / samza-core /
37 hours ago  Dong LinSAMZA-1478: Delete unneeded data from intermediate... master
39 hours ago  Prateek MaheshwariMisc. Util cleanup
43 hours ago  Shanthoosh Venkata... SAMZA-1640: JobModel Json deserialization error in...
2 days ago  Shanthoosh Venkata... SAMZA-1664: ZkJobCoordinator stability fixes.
2 days ago  xiliuRevert "SAMZA-1645: A few issues found by BEAM stress...
2 days ago  Bharath Kumarasubr... Initial version for in memory system.
6 days ago  Prateek MaheshwariSAMZA-1643: StreamPartitionCountMonitor should only...
7 days ago  JagadishSAMZA-1649: Improve host-aware allocation to account...
7 days ago  Aditya ToomulaSAMZA-1650: Fix for firing trigger at the end of trigge...
7 days ago  Shanthoosh Venkata... SAMZA-1584: Improve logging in StreamProcessor.
8 days ago  Shanthoosh Venkata... SAMZA-1183: Fix TestAsyncRunLoop flaky tests
8 days ago  xinyuiscoolSAMZA-1645: A few issues found by BEAM stress test
2018-03-31  Prateek MaheshwariSAMZA-1630: Move thread dump from stdout to logs
2018-03-29  James LentSD-1599: Improve the efficiency of the AsynRunLoop...
2018-03-29  Prateek MaheshwariSAMZA-1630: Log a thread dump on timeouts
2018-03-29  Prateek MaheshwariSAMZA-1631: Improve logging on Task callback timeout
2018-03-28  xinyuiscoolSAMZA-1627: Watermark broadcast enhancements
2018-03-26  thunderstumpgesScheduleAfterDebounceTime should catch all Throwable...
2018-03-22  Aditya ToomulaAdd stream-table join support for samza sql
2018-03-15  Xinyu LiuSAMZA-1615: Fix a couple of issues in ControlMessageSender
2018-03-14  Aditya ToomulaSAMZA-1611: BootstrappingChooser should use systemAdmin...
2018-03-09  Peng DuSAMZA-1610: Implementation of remote table provider
2018-03-09  Srinivasulu PunuruInfinite loop when trying to use SamzaSqlApplicationRun...
2018-03-07  Shanthoosh Venkata... SAMZA-1607: Handle ZkNoNodeExistsException in zkUtils...
2018-03-07  xiliuSAMZA-1498: Support arbitrary system clock timer in...
2018-03-04  Prateek MaheshwariMisc. minor cleanup.
2018-02-27  Wei SongSAMZA-1597: Expose an interface for throttling
2018-02-21  Srinivasulu PunuruFixes to get the build working with Scala 2.10 build
2018-02-16  Daniel NishimuraSAMZA-1555: Move creation of checkpoint and changelog...
2018-02-14  Shanthoosh Venkata... SAMZA-1568: Handle ZkInterruptedException in zkclient...
2018-02-01  Dong LinSAMZA-1489: TaskInstance should commit offset before...
2018-02-01  JagadishSAMZA-1552: Host affinity improvements - Improve matchi...
2018-01-26  Xinyu LiuSAMZA-1578: Fix watermark bug found by BEAM tests
2018-01-26  Prateek MaheshwariAdded some logging to stdout for easier parsing by...
2018-01-26  Dong LinSAMZA-1548; Add start() and stop() to SystemAdmin
2018-01-24  Xinyu LiuSAMZA-1557: Broadcast operator
2018-01-22  Shanthoosh Venkata... SAMZA-1561: Fix inconsistency problem in JobModel publish.
2018-01-02  JagadishSAMZA-1528: Change ClusterResourceManager to use the...
2017-12-14  Wei SongAdded document for table API to feature preview
2017-12-13  Aditya ToomulaSAMZA-1502; Make AllSspToSingleTaskGrouper work with...
2017-12-12  Xinyu LiuSAMZA-1534: Fix the visualization in job graph with...
2017-12-05  Wei SongInitial version of Table API
2017-12-04  Prateek MaheshwariUpdated Serde related documentation and error messages...
2017-12-01  Abhishek ShivannaSAMZA-1506: Fix for robust ContainerHeartbeatMonitor...
2017-12-01  Jacob MaesSAMZA-1518: Add CPU utilization and file descriptor...
2017-11-29  xiliuSAMZA-1516: Another round of issues found by BEAM tests
2017-11-29  Daniel NishimuraSAMZA-1514: Prevent changelog stream names with empty...
2017-11-22  Shanthoosh Venkata... SAMZA-1507; Create changelog streams in Leader(ZkJobCoo...
2017-11-21  JagadishSAMZA-1494; Flush operator state at end of stream
2017-11-21  Xinyu LiuSAMZA-1505: Fix CheckpointTool writing only one ssp...
2017-11-17  JagadishSAMZA-1479; Refactor KafkaCheckpointManager, KafkaCheck...
2017-11-16  Xinyu LiuSAMZA-1504: Allow user to register container-level...
2017-11-15  Prateek MaheshwariSAMZA-1495: Set intermediate streams as higher priority...
2017-11-15  Prateek MaheshwariSAMZA-1501: Validate operator IDs so that they don...
2017-11-14  Yi Pan (Data Infra... SAMZA-1482: Restart or fail Samza jobs in YARN when...
2017-11-14  Shanthoosh Venkata... SAMZA-1487: Disable Flaky Zk Integration tests.
2017-11-09  Jacob MaesSAMZA-1480: TaskStorageManager improperly initializes...
2017-11-08  xiliuFix test failures caused by PR345
2017-11-07  Xinyu LiuSAMZA-1477: Fix issues found by BEAM tests
2017-10-27  JagadishSAMZA-1473; Fix handling of initial values for aggregat...
2017-10-27  Hai LuSAMZA-1471: SystemConsumers should not poll ssp that...
2017-10-26  Prateek MaheshwariSAMZA-1454: Globally unique and user settable IDs for...
2017-10-25  Prateek MaheshwariSAMZA-1464: Flushing a closed RocksDB store causes...
2017-10-25  Boris STestExecutionPlanner compilation error
2017-10-25  Boris SStreamOperatorTask does not need to be final.
2017-10-13  Boris SChangeLog should not require KafkaSystemAdmin
2017-10-13  JagadishSAMZA-1424 SAMZA-1425 SAMZA-1426; Support serdes and...
2017-10-11  Nacho SolisSAMZA-1452: Clean up interrupted thread bugs
2017-10-09  Prateek MaheshwariSAMZA-1292: Merge operator can be no-op when there...
2017-10-06  Prateek MaheshwariSAMZA-272, SAMZA-1440, SAMZA-1269: Fixed thread interru...
2017-10-05  Prateek MaheshwariSAMZA-1444: Removed circular dependency b/w samza-core...
2017-10-05  Daniel NishimuraSAMZA-1429: Add callback success/failure metrics to...
2017-10-04  Prateek MaheshwariSAMZA-1056: Added wiring for High Level API state store...
2017-10-04  Prateek MaheshwariSAMZA-1109: Updated High Level API serde impl with...
2017-10-04  Jacob MaesSAMZA-1439: Address late review feedback from SAMZA...
2017-10-04  Boris SSAMZA-1427; use systemFactory in checkpoint manager.
2017-10-03  Xinyu LiuMerge branch '0.14.0'
2017-10-03  Xinyu LiuMerge branch 'master' into 0.14.0
2017-10-02  JagadishSAMZA-1423; Follow-up to PR:303 - Remove version const...
2017-10-02  JagadishSAMZA-1423; Implement time series storage for joins...
2017-09-29  Xinyu LiuSAMZA-1434: Fix issues found in Hadoop
2017-09-29  Xinyu LiuSAMZA-1386: Inline End-of-stream and Watermark logic...
2017-09-28  Prateek MaheshwariSAMZA-1109; Allow setting Serdes for fluent API operato...
2017-09-25  Xinyu LiuSAMZA-1417: Clear and recreate intermediate and metadat...
2017-09-21  Jacob MaesSAMZA-1428: Fix scala 2.10 compilation issue with java...
2017-09-20  Jacob MaesSAMZA-1392: KafkaSystemProducer performance and correct...
2017-09-19  Daniel NishimuraSAMZA-1414: SamzaContainer log statements incorrectly...
2017-09-19  Daniel NishimuraSAMZA-1416: Better logging around the exception where...
2017-09-15  Shanthoosh Venkata... SAMZA-1406: Fix potential orphaned containers problem...
2017-09-12  Xinyu LiuFix some integration tests after merging from master
2017-09-12  Xinyu LiuMerge branch 'master' into 0.14.0
2017-09-07  Xinyu LiuSAMZA-1415: Add clearStream API in SystemAdmin and...
2017-08-30  Boris ShkolnikSAMZA-1413: Config for CoordinationUtilsFactory class...
2017-08-29  Boris ShkolnikSAMZA-1385: Coordination utils factory with distributed...
2017-08-29  Boris ShkolnikIntroduces CoordinationUtilsFactory to create different...
2017-08-28  Fred JiSAMZA-1410 make tests pass in different Junit versions...
2017-08-28  Bharath Kumarasubr... SAMZA-1404: Add warning in case of potential process...
2017-08-23  Boris ShkolnikSAMZA-1382: added Zk communication protocol version...
2017-08-16  Boris ShkolnikSAMZA-1397; log.debug loop to run only if debug is...
2017-08-16  Navina RameshSAMZA-1396 TestZkLocalApplicationRunner tests fails...
next