GitHub user Sanil15 opened a pull request:
https://github.com/apache/samza/pull/501
Samza 1648: Integration Test Framework & Collection Stream Impl
This patch provides the following:
- TestRunner: Tesing Wrapper to run Samza job
- CollectionStream: Acts as a stream descriptor
GitHub user ahmedahamid opened a pull request:
https://github.com/apache/samza/pull/500
SAMZA-1696: Fix TestKeyValueStores flaky test
Fix flaky test testParallelReadWriteSameKey that was failing due to a race
condition between the main test thread and the thread manipulating the key
Thanks everyone for the discussion! I marked the Kafka 0.11 upgrade ticket
as 0.14.1 and will include it in this release. Now we have 3 binding votes
from Jagadish, Yi and Jake, so I will go ahead and start the release
procedure.
Thanks,
Xinyu
On Tue, May 1, 2018 at 4:31 PM, Jake Maes wrote:
>
