GitHub user vjagadish opened a pull request:
https://github.com/apache/samza/pull/525
SAMZA-1718: Simplify management of Zookeeper coordination state
1. Currently coordination related state is spread across several Zookeeper
classes. There are also back-and-forth flows that exist
GitHub user vjagadish opened a pull request:
https://github.com/apache/samza/pull/504
Fix NPE in ClusterResourceManager
When the ClusterResourcedManager receives a notification that a container
is started, it moves the container from the "pending queue" to its "
GitHub user vjagadish opened a pull request:
https://github.com/apache/samza/pull/488
SAMZA-1687: Prioritize preferred host requests over ANY-HOST requests
Working on a documentation that describes this better, but a TL;DR summary
is that we should prioritize preferred-host
GitHub user vjagadish opened a pull request:
https://github.com/apache/samza/pull/480
Update PMC membership on the Samza web-page
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vjagadish1989/samza pmc
Alternatively you can
GitHub user vjagadish opened a pull request:
https://github.com/apache/samza/pull/471
SAMZA-1649: Improve host-aware allocation to account for strict locality
Working on a doc for the behavior of the CapacityScheduler and further
testing is needed on an actual cluster - but here's
GitHub user vjagadish opened a pull request:
https://github.com/apache/samza/pull/42
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
GitHub user vjagadish opened a pull request:
https://github.com/apache/samza/pull/40
SAMZA-1077: Catch throwables in SamzaContainer
Here's the snippet from the startup sequence of the SamzaContainer.
SamzaContainer.scala
```
startProducers
startTask
GitHub user vjagadish opened a pull request:
https://github.com/apache/samza/pull/30
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
GitHub user vjagadish opened a pull request:
https://github.com/apache/samza/pull/29
Samza operator v2
test pull request
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vjagadish1989/samza samza-operator-v2
Alternatively you can
Github user vjagadish closed the pull request at:
https://github.com/apache/samza/pull/29
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature
10 matches
Mail list logo
