clear query| facets| time Search criteria: .   Results from 1 to 10 from 30 (0.0s).
Loading phrases to help you
refine your search...
[SAMZA-1919] Add KafkaSystemDescriptor constructor to allow arbitrary factory class - Samza - [issue]
...Currently KafkaSystemDescriptor is hardcoded to use org.apache.samza.system.kafka.KafkaSystemFactory as the system factory for instantiating producer/consumer/admin. Users may want to use mo...
http://issues.apache.org/jira/browse/SAMZA-1919    Author: Dong Lin , 2018-09-30, 18:35
[SAMZA-1530] Bump up Kafka dependency to 0.11 - Samza - [issue]
...See http://kafka.apache.org/0110/documentation.html#upgrade_1100_notable for notable changes in Kafka 0.11.One of the important feature in 0.11 is the ability to delete records on demand. Sa...
http://issues.apache.org/jira/browse/SAMZA-1530    Author: Dong Lin , 2018-07-20, 01:36
[SAMZA-1548] Add start() and stop() to SystemAdmin - Samza - [issue]
...This patch adds start() and stop() to SystemAdmin interface. This can be useful for e.g. kafka.admin.AdminClient which needs to be started before it can be used.Since we add this method in i...
http://issues.apache.org/jira/browse/SAMZA-1548    Author: Dong Lin , 2018-05-02, 16:53
[SAMZA-1489] TaskInstance should commit offset before it closes() if auto commit is enabled - Samza - [issue]
http://issues.apache.org/jira/browse/SAMZA-1489    Author: Dong Lin , 2018-05-02, 16:47
[SAMZA-1478] Delete unneeded data from intermediate Kafka topic on offset commit - Samza - [issue]
http://issues.apache.org/jira/browse/SAMZA-1478    Author: Dong Lin , 2018-05-02, 16:43
[SAMZA-1293] Enable partition expansion of input streams - Samza - [issue]
...Right now, Samza does not allow partitions of the input stream to increase after a stateful job is created. This causes problem when Kafka is used as the input system, because we need to exp...
http://issues.apache.org/jira/browse/SAMZA-1293    Author: Dong Lin , 2018-03-26, 23:20
[SAMZA-1579] RemoteApplicationRunner should allow user to kill app or query app status - Samza - [issue]
http://issues.apache.org/jira/browse/SAMZA-1579    Author: Dong Lin , 2018-02-02, 21:34
[SAMZA-1490] Fix TestRepartitionJoinWindowApp - Samza - [issue]
http://issues.apache.org/jira/browse/SAMZA-1490    Author: Dong Lin , 2017-11-14, 18:51
[SAMZA-1475] The latest branch of hello-samza should pass compilation - Samza - [issue]
...The latest branch of hello-samza could not compile due to the following error:$ ./gradlew jarJava HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in ...
http://issues.apache.org/jira/browse/SAMZA-1475    Author: Dong Lin , 2017-10-30, 23:26
[expand - 1 more] - [VOTE] SEP-5: Enable partition expansion of input streams - Samza - [mail # dev]
...Thanks everyone, especially Navina, Yi, Jacob and Xinyu for your comments!Since Yi has voted +1 in the discussion thread, this SEP is now adoptedwith two binding votes (Yi, Navina) and one n...
   Author: Dong Lin , 2017-06-24, 00:40