Claudio Fahey

In the event that a single worker dies, the segments that it was reading will be automatically assigned to another worker. However, this code does not transfer the state between...

This PR is ready for re-review.

The latest commit should provide at-least-once semantics in a clean way using only Pravega. I believe the code is complete but it does not have any automated tests yet. We...

This PR is ready for review. For a description of this PR, see https://github.com/claudiofahey/pravega-samples/blob/issue-191-streamprocessing/pravega-client-examples/src/main/java/io/pravega/example/streamprocessing/README.md. Unit and integration tests can be run with `./gradlew pravega-client-examples:build`.

@RaulGracia, I have addressed all of your comments. However, it appears that there is an intermittent timeout failure in the test kill5of6Test. I will continue to investigate.

FYI, I ran the integration 20 times and all have passed: ``` for i in {1..20}; do ./gradlew clean test; done |& tee -a /tmp/test.log grep "SUCCESSFUL" /tmp/test.log BUILD SUCCESSFUL...

I believe it would be a lot of unnecessary work to maintain a separate repo for Nautilus-specific samples. As you can see this in PR, the main difference is the...

This PR is ready for re-review.

This PR is ready for re-review.

This is not a very convenient API as it requires two awaits and then a match statement to flatten the result. It gets even more complicated without the anyhow macro....