clear query| facets| time Search criteria: .   Results from 1 to 10 from 311 (0.0s).
Loading phrases to help you
refine your search...
[SAMZA-1168] Migrate yarn local runner to use StreamProcessor - Samza - [issue]
...Right now LocalContainerRunner is used in Yarn to run SamzaContainers on each node. This is not consistent with the real local runner which uses StreamProcessor to run locally. We should be ...
http://issues.apache.org/jira/browse/SAMZA-1168    Author: Xinyu Liu , 2018-08-23, 04:47
[SAMZA-1130] ApplicationRunner for running StreamApplication - Samza - [issue]
...ApplicationRunner is the layer between high fluent API and physical execution. It is responsible for planning execution, materializing the streams and configs, and running the physical execu...
http://issues.apache.org/jira/browse/SAMZA-1130    Author: Xinyu Liu , 2018-08-23, 04:47
[SAMZA-1768] Handle corrupted OFFSET file elegantly - Samza - [issue]
...TaskStorageManager.readOffsetFile() has a bug that if the OFFSET file is corrupted, it will throw exception and shut down the container. If host affinity is turned on, the container won't be...
http://issues.apache.org/jira/browse/SAMZA-1768    Author: Xinyu Liu , 2018-08-20, 19:34
[SAMZA-1551] Add latest documentation link to old doc pages - Samza - [issue]
...Google search shows old doc pages when seaching "samza documentation". It'll be nice to add the link to latest doc so the user can go there directly....
http://issues.apache.org/jira/browse/SAMZA-1551    Author: Xinyu Liu , 2018-08-03, 18:38
[SAMZA-1796] PassthroughJobCoordinator doesn't create changelog streams - Samza - [issue]
...Currently only the ClusterBasedJobCoordinator and ZkJobCoordinator are creating changelog streams. The Passthrough one should also do it....
http://issues.apache.org/jira/browse/SAMZA-1796    Author: Xinyu Liu , 2018-08-02, 18:23
[SAMZA-1179] Documentation of ApplicationRunner - Samza - [issue]
...API of ApplicationRunner details of different runners and their components such as graph, planner, stream creator. CommandLine argument for "operation", which was added in SAMZA-1089...
http://issues.apache.org/jira/browse/SAMZA-1179    Author: Xinyu Liu , 2018-07-27, 18:02
[SAMZA-1218] Support StreamTaskFactory and AsyncStreamTaskFactory in LocalApplicationRunner - Samza - [issue]
...We need to still support low level task api when running standalone so it's backward compatible....
http://issues.apache.org/jira/browse/SAMZA-1218    Author: Xinyu Liu , 2018-07-27, 18:01
[expand - 1 more] - [VOTE] Committership for Wei and Srini - Samza - [mail # dev]
...Sorry, sent to the wrong mailing list. Please ignore.Thanks,XinyuOn Wed, Jul 4, 2018 at 8:17 AM, Xinyu Liu  wrote:> Hi, All,>> Seems the feedback from the discussion thread is ...
   Author: Xinyu Liu , 2018-07-04, 15:19
[SAMZA-1534] Fix the visualization in job graph with the new PartitionBy op - Samza - [issue]
...Seems the stream and the partitionBy op has the same id. So in rendering I added the stream as the id for the node. Also resolved the run.id collision issue....
http://issues.apache.org/jira/browse/SAMZA-1534    Author: Xinyu Liu , 2018-06-28, 23:50
[SAMZA-1766] FileUtil should use autoclosable for the read/writeWithChecksum - Samza - [issue]
...Multiple problems in the current impl: close() of file stream and output stream without null check we only need to close the objectstream once, it will close the file stream automaticallyWe ...
http://issues.apache.org/jira/browse/SAMZA-1766    Author: Xinyu Liu , 2018-06-28, 23:30