Title: Message Title
Navina Ramesh resolved as Fixed
SAMZA-1080 : Initial Standalone JobCoordinator and StreamProcessor API
This patch contains changes associated with the Standalone StreamProcessor,
where there is no coordination. This will work for load-balanced consumers like
new Kafka consumer and statically partitioned cases.
Additionally,
Repository: samza
Updated Branches:
refs/heads/master 154cda2c7 -> 2a3a5ac7f
http://git-wip-us.apache.org/repos/asf/samza/blob/2a3a5ac7/samza-core/src/main/scala/org/apache/samza/coordinator/JobCoordinator.scala
--
diff --git
Title: Message Title
Navina Ramesh updated an issue
Repository: samza
Updated Branches:
refs/heads/master bf9bc2c37 -> 154cda2c7
SAMZA-1074; Fix builds for hello-samza on various CDH versions
This issue is mainly related of hello-samza, but modification of document is
needed to help user understand this process well.
Author: Dongkyu Hwangbo
Title: Message Title
ASF GitHub Bot commented on SAMZA-1074
Title: Message Title
Jagadish resolved as Fixed
Title: Message Title
Jagadish commented on SAMZA-1079
Repository: samza
Updated Branches:
refs/heads/master 1c7e4d7aa -> bf9bc2c37
SAMZA-1079: Add timeouts for reads from HttpFileSystem. Add tests.
* Wrote a unit/integration test to simulate a stuck connection when reading
binaries for the job.
Other misc. changes:
- Moved some debug log
Title: Message Title
Prateek Maheshwari commented on SAMZA-984
Title: Message Title
Jagadish assigned an issue to Jagadish
Title: Message Title
Jagadish commented on SAMZA-1077
Title: Message Title
Jagadish commented on SAMZA-984
Title: Message Title
ASF GitHub Bot commented on SAMZA-860
Repository: samza
Updated Branches:
refs/heads/master c6c10d31e -> 1c7e4d7aa
SAMZA-984; Upgraded RocksDB version to 5.0.1 and added configuration for
managing RocksDB logging.
Author: Prateek Maheshwari
Reviewers: Jake Maes , Jagadish
Title: Message Title
ASF GitHub Bot commented on SAMZA-1077
Repository: samza
Updated Branches:
refs/heads/master 6dc33a850 -> c6c10d31e
SAMZA-1077: SamzaContainer should catch all Throwables instead of only
exceptions
Author: vjagadish1989
Reviewers: Jake Maes
Closes #30 from vjagadish1989/samza-1077
Specification of various Window and Trigger APIs in Samza
- Defined APIs for specifying different types of windows - sessions, tumbling,
global and keyed variants.
- Defined APIs for specifying early and late triggers for a window.
- Standardized all above Window types to be expressed as a
http://git-wip-us.apache.org/repos/asf/samza/blob/6dc33a85/samza-api/src/main/java/org/apache/samza/operators/windows/Windows.java
--
diff --git
a/samza-api/src/main/java/org/apache/samza/operators/windows/Windows.java
Title: Message Title
Jagadish commented on SAMZA-1025
Title: Message Title
Jagadish resolved as Fixed
Repository: samza
Updated Branches:
refs/heads/master db8b228d9 -> f01b28628
SAMZA-1025: Documentation for HdfsSystemConsumer
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/f01b2862
Tree:
Title: Message Title
Jake Maes created an issue
23 matches
Mail list logo