Yi Pan \
Jordi Blasi Uribarri
Bae, Jae Hyeon
Shadi A. Noghabi
Renato Marroquín Mogrovej...
József Márton Jung
Ash W Matheson
Anh Thu Vu
mail # dev
last 7 days (2)
last 30 days (7)
last 90 days (22)
last 6 months (54)
last 9 months (188)
newest on top
oldest on top
. Results from
Loading phrases to help you
refine your search...
[SAMZA-1788] Introduce LocationIdProvider abstraction
...Currently in standalone, hostName of the standalone processor is used as LocationId. However, for containerized environments like azure cloud, kubernetes this defaulting does not work. Stan...
, 2018-08-10, 21:27
[SAMZA-1793] Upgrade to recent API for kafka consumer / producer.
...Kafka consumer: 1. Samza currently uses SimpleConsumer to consume messages from the KafkaBroker. However, the SimpleConsumer API is deprecated and is slated to be removed in future ka...
, 2018-08-10, 20:57
[SAMZA-1791] Fix compilation errors introduced by SAMZA-1733.
, 2018-07-28, 01:29
[SAMZA-1554] Host affinity in standalone.
...Samza framework enables its users to build stateful stream processing applications–that is, applications that remember information about past events in a local state(store), which will be th...
, 2018-07-26, 23:53
[SAMZA-1786] Introduce metadata store abstraction.
...As a part of SEP-11, this JIRA introduces MetadataStore interface to store task and container locality for both yarn and standalone deployment models. Refer to SEP-11 design doc for more det...
, 2018-07-26, 21:52
[SAMZA-1730] Add state validations in StreamProcesssor.
...Existing StreamProcessor implementation doesn't have state variable to represent it's current state(if it's in rebalance/shutdown/running state). Absence of this information leads to followi...
, 2018-07-18, 02:14
[SAMZA-1665] Fix race condition when stopping StreamProcessor.
...When the user thread stops the streamProcessor and onNewJobModelExpired event is executed from debounce thread at the same time, we observe the following issue:A. User thread stops the Strea...
, 2018-07-18, 02:14
[SAMZA-1761] Reduce runTime of TestZkUtils test.
...Currently the test ZkUtils.testRegisterProcessorAndGetIdShouldFailForDuplicateProcessorRegistration takes 40 seconds to complete.During processor registration if there're duplicate processo...
, 2018-07-09, 19:29
[SAMZA-1647] Fix race conditions in StreamProcessor.
...Problem:There's a minor race condition when container shutdown is triggered from onJobModelExpired event handler. This race condition leads to an NPE and eventually kills the StreamProcessor...
, 2018-06-27, 20:47
[SAMZA-1748] Standalone failure tests.
...In the standalone model, a processor can leave and join the group at any point in time. This processor reshuffle is referred to as rebalancing which results in task(work) redistribution amon...
, 2018-06-22, 22:54
Apache Lucene, Apache Solr and all other Apache Software Foundation project and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by