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
Luis De Pombo
mail # dev
last 7 days (4)
last 30 days (4)
last 90 days (12)
last 6 months (49)
last 9 months (339)
newest on top
oldest on top
. Results from
Loading phrases to help you
refine your search...
[SAMZA-1411] Document SystemProducer changes in Samza 0.14.0
...Document the producer changes in SAMZA-1392. Particularly:0. MOST IMPORTANTLY: if users enable task.drop.producer.errors they should also alert on *producer-send-failed metric!1. How are pro...
, 2017-09-21, 22:46
[SAMZA-1428] Fix scala 2.10 compilation issue with java 8 interface static methods
, 2017-09-21, 18:58
[SAMZA-1392] KafkaSystemProducer performance and correctness with concurrent sends and flushes
...There are 2 issues we need to fix in the KafkaSystemProducer when sends and flushes are called concurrently:1. Concurrent sends contend for the sendlock, especially when producer compression...
, 2017-09-20, 19:41
[SAMZA-1414] SamzaContainer log statements incorrectly expect containerId is a number
...The line numbers wont match up with the latest, but here's a stack trace. java.util.IllegalFormatConversionException: d != java.lang.String at java.util.Formatter$FormatSpecifie...
, 2017-09-19, 21:44
[SAMZA-1393] Asynchronous SystemProducer API
...We've encountered a number of issues with the current SystemProducer interface with async processors. For example, see SAMZA-1392. Most of the issues arise from the fact that there's no way ...
, 2017-08-15, 17:51
[SAMZA-1388] Flaky test - TestStatefulTask#testShouldStartAndRestore
...testShouldStartAndRestore FAILED org.junit.ComparisonFailure: expected:<> but was:<> at org.junit.Assert.assertEqua...
, 2017-08-14, 16:02
[SAMZA-1384] Race condition with async commit affects checkpoint correctness
...tl;dr if any in-flight request updates the offsets between producer.flush() and offsetmanager.checkpoint() we could write a checkpoint for a message that did not yet go out over the wire and...
, 2017-08-10, 22:45
[SAMZA-1366] ScriptRunner should allow callers to control the child process environment.
...The ScriptRunner class used by samza-rest currently uses the defaults for ProcessBuilder to construct the child process and by default, all environment variables are forwarded to the child p...
, 2017-08-02, 16:23
[SAMZA-1383] KafkaCheckpointManager does not propagate the cause of exceptions.
...Specifically, when the DifferingSystemStreamPartitionGrouperFactoryValues exception is thrown from KafkaCheckpointLogKey, it gets wrapped in a SamzaException with a generic message. Then, on...
, 2017-08-02, 16:18
[SAMZA-1356] Improve monitoring for state restore
...There are a couple problems that can affect our ability to troubleshoot state restore from changelog.1. KeyValueStorageEngine logs a message for every 1M messages restored, but it doesn't pr...
, 2017-07-13, 18:36
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