Hi all,
Here's the proposal for System and Stream Descriptors - a way of
specifying systems, input and output streams properties in application
code instead of configurations.
https://cwiki.apache.org/confluence/display/SAMZA/SEP-14%3A+System+and+Stream+Descriptors
Here's the PR with an implement
GitHub user prateekm opened a pull request:
https://github.com/apache/samza/pull/603
SAMZA-1804: System and Stream Descriptors
Design details:
https://cwiki.apache.org/confluence/display/SAMZA/SEP-14%3A+System+and+Stream+Descriptors
You can merge this pull request into a Git reposi
GitHub user rmatharu opened a pull request:
https://github.com/apache/samza/pull/602
Create diagnostic topic and ACLs if diagnostics enabled
* Current SnapshotReporter semantics are to specify stream as
.
* We create topic in JobRunner because AM can also emit metrics.
GitHub user bharathkk opened a pull request:
https://github.com/apache/samza/pull/601
SAMZA-1803: Make InMemoryManager system aware
- Fix getSystemStreamMetadata in InMemoryManager to filter based on the
system name on top of stream names
You can merge this pull request into a Git
GitHub user weisong44 opened a pull request:
https://github.com/apache/samza/pull/600
SAMZA-1802: Enable host affinity when RocksDB is present
We should enable host affinity when RocksDB table is present, this should
be done in RocksDB table provider
You can merge this pull reques
GitHub user rmatharu opened a pull request:
https://github.com/apache/samza/pull/599
Fix for transient error failure -- concurrent evictions causing
incorrectness
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rmatharu/samza bu
