clear query| facets| time Search criteria: .   Results from 1 to 10 from 63 (0.0s).
Loading phrases to help you
refine your search...
[SAMZA-2300] Incomplete propagation of end-of-stream messages for intermediate stream operators - Samza - [issue]
...Summary:If an intermediate operator (e.g. partitionBy) corresponds to multiple partitions, and the intermediate system returns IncomingMessageEnvelope.END_OF_STREAM_OFFSET for end-of-stream ...    Author: Cameron Lee , 2019-10-17, 17:09
[SAMZA-2303] Exclude side inputs when handling end-of-stream and watermarks for high-level - Samza - [issue]
...OperatorImplGraph builds EndOfStreamStates and WatermarkStates objects with all of the input SSPs from the job model. That includes side-input SSPs. However, high-level operator tasks aren't...    Author: Cameron Lee , 2019-10-17, 17:09
[SAMZA-2307] Migrate tests in samza-test to use in-memory system instead of Kafka/Zookeeper - Samza - [issue]
...Many tests in samza-test use the IntegrationTestHarness which sets up local instances of Kafka and Zookeeper. However, these systems take time to start up. Also, using Kafka as a system is s...    Author: Cameron Lee , 2019-10-17, 17:09
[SAMZA-2328] [Scala cleanup] Convert StreamConfig to Java - Samza - [issue]
...This can be done in two parts:1) Update tests to have better coverage and clean up javadocs to clarify how configs are read. This will make the migration to Java easier since the javadocs wi...    Author: Cameron Lee , 2019-10-17, 17:09
[SAMZA-2335] Remove classloader argument from ReflectionUtil - Samza - [issue]
...SAMZA-2204 added a ReflectionUtil class for some reflection-based helpers, and SAMZA-2210 started to replace the usage of Util.getObj with those ReflectionUtil methods.The intended purpose o...    Author: Cameron Lee , 2019-10-17, 17:08
[SAMZA-1757] Tests in samza-api which are written in Scala are not triggered - Samza - [issue]
...The samza-api project does not have the "scala" plugin applied, and it is not configured to run the tests in "src/test/scala".It looks like we would need to add a scala suffix to samza-api i...    Author: Cameron Lee , 2019-10-17, 17:08
[SAMZA-2343] Remove original split deployment code - Samza - [issue]
... added some code for split deployment of the Samza framework, but it was not used. We are going to be using a different implementation for spli...    Author: Cameron Lee , 2019-10-17, 17:08
[SAMZA-2357] Fix incorrectly formatted entries in WikitionaryEditEvents.txt in samza-hello-samza - Samza - [issue]
...WikitionaryEditEvents.txt is not valid JSON, so when the unit test(s) for samza-hello-samza try to parse them, they throw some exceptions. The test(s) don't actually seem to depend on the in...    Author: Cameron Lee , 2019-10-17, 17:08
[SAMZA-2333] [AM isolation] Use cytodynamics classloader to launch job coordinator - Samza - [issue]
...If application master isolation is enabled, then Samza needs to build an isolating classloader (cytodynamics) which will be used to run the job coordinator....    Author: Cameron Lee , 2019-10-09, 22:08
[SAMZA-2332] [AM isolation] YarnJob should pass new command and additional environment variables for AM deployment - Samza - [issue]
...When sending a request to YARN to deploy an application master, some extra environment variables need to be set so that the application master can be run in an isolated mode. "APPLICATION_MA...    Author: Cameron Lee , 2019-10-09, 17:37