samza-commits mailing list archives: September 2018

Site index · List index
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Shanthoosh Venkataraman (JIRA) [jira] [Created] (SAMZA-1837) Fix TestLocalTableWithSideInputs failures. Sat, 01 Sep, 00:15
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1837) Fix TestLocalTableWithSideInputs failures. Sat, 01 Sep, 00:29
Yi Pan (Data Infrastructure) (JIRA) [jira] [Commented] (SAMZA-1834) Too many IDs for processors in Samza Sat, 01 Sep, 01:16
DM (JIRA) [jira] [Commented] (SAMZA-1822) Samza 0.14.1 not correctly handling OffsetOutOfRangeException exception Tue, 04 Sep, 03:10
Boris Shkolnik (JIRA) [jira] [Resolved] (SAMZA-1753) Add set/get timestamp for IncomingMessageEnvelope from the kafka event Tue, 04 Sep, 20:42
Boris Shkolnik (JIRA) [jira] [Assigned] (SAMZA-1776) Refactor KafkaSystemConsumer to remove the usage of deprecated SimpleConsumer client Tue, 04 Sep, 20:47
srinivas...@apache.org samza git commit: SAMZA-1821: fix the IllegalStateException complaining duplicate key when fetching systemStream configs Tue, 04 Sep, 23:27
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1821) Fetching systemStream configs causes duplicate key exception Tue, 04 Sep, 23:28
Srinivasulu Punuru (JIRA) [jira] [Resolved] (SAMZA-1821) Fetching systemStream configs causes duplicate key exception Tue, 04 Sep, 23:29
Srinivasulu Punuru (JIRA) [jira] [Closed] (SAMZA-1821) Fetching systemStream configs causes duplicate key exception Tue, 04 Sep, 23:29
Ahmed Abdul Hamid (JIRA) [jira] [Created] (SAMZA-1838) Make some minor improvements to ExecutionPlanner Wed, 05 Sep, 00:36
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1838) Make some minor improvements to ExecutionPlanner Wed, 05 Sep, 02:14
Yi Pan (Data Infrastructure) (JIRA) [jira] [Created] (SAMZA-1839) Cleanup the old constructors of StreamProcessor Wed, 05 Sep, 04:30
Sanil Jain (JIRA) [jira] [Created] (SAMZA-1840) Integrate StreamDescriptors and System Descriptors with Test Framework Wed, 05 Sep, 19:31
Yi Pan (Data Infrastructure) (JIRA) [jira] [Created] (SAMZA-1841) Add broadcast feature to InputDescriptor Thu, 06 Sep, 01:20
Yi Pan (Data Infrastructure) (JIRA) [jira] [Created] (SAMZA-1842) Need consistent logic to calculate input, output, and intermediate streams in high and low-level API applications Thu, 06 Sep, 01:27
Wei Song (JIRA) [jira] [Created] (SAMZA-1843) Consolidate task input generation for side input to TableConfigGenerator Thu, 06 Sep, 18:01
Shanthoosh Venkataraman (JIRA) [jira] [Created] (SAMZA-1844) Implicitly set TaskNameGrouper factory for standalone in configuration. Thu, 06 Sep, 18:04
Shanthoosh Venkataraman (JIRA) [jira] [Updated] (SAMZA-1844) Implicitly set TaskNameGrouper factory for standalone. Thu, 06 Sep, 18:05
Boris Shkolnik (JIRA) [jira] [Assigned] (SAMZA-1793) Upgrade to recent API for kafka consumer / producer. Thu, 06 Sep, 18:22
Shanthoosh Venkataraman (JIRA) [jira] [Updated] (SAMZA-1844) Implicitly set TaskNameGrouper factory for standalone. Thu, 06 Sep, 20:25
Shanthoosh Venkataraman (JIRA) [jira] [Updated] (SAMZA-1844) Implicitly set TaskNameGrouper factory for standalone. Thu, 06 Sep, 20:26
Prateek Maheshwari (JIRA) [jira] [Created] (SAMZA-1845) Require setting serde for default system in ApplicationDescriptor#setDefaultSystem Thu, 06 Sep, 22:22
Prateek Maheshwari (JIRA) [jira] [Created] (SAMZA-1846) Create EventHub System and Stream Descriptors Thu, 06 Sep, 22:22
Prateek Maheshwari (JIRA) [jira] [Created] (SAMZA-1848) Create HDFS System and Stream Descriptors Thu, 06 Sep, 22:23
Prateek Maheshwari (JIRA) [jira] [Created] (SAMZA-1847) Create Kinesis System and Stream Descriptors Thu, 06 Sep, 22:23
Yi Pan (Data Infrastructure) (JIRA) [jira] [Assigned] (SAMZA-1818) TestRunner should consolidate all constructor to use SamzaApplication and config Thu, 06 Sep, 23:18
Wei Song (JIRA) [jira] [Resolved] (SAMZA-1843) Consolidate task input generation for side input to TableConfigGenerator Thu, 06 Sep, 23:20
Yi Pan (Data Infrastructure) (JIRA) [jira] [Assigned] (SAMZA-1815) Use TableDescriptors to generate configurations during planning phase Thu, 06 Sep, 23:24
Yi Pan (Data Infrastructure) (JIRA) [jira] [Assigned] (SAMZA-1815) Use TableDescriptors to generate configurations during planning phase Thu, 06 Sep, 23:25
Prateek Maheshwari (JIRA) [jira] [Created] (SAMZA-1849) Table Descriptors should take Serde at construction time so that descriptors can be typed Thu, 06 Sep, 23:29
Yi Pan (Data Infrastructure) (JIRA) [jira] [Assigned] (SAMZA-1714) Creating shared context factory for shared context objects in high-level API Thu, 06 Sep, 23:31
Prateek Maheshwari (JIRA) [jira] [Created] (SAMZA-1850) Create new Descriptor APIs for specifying task job and app level configs Thu, 06 Sep, 23:32
Prateek Maheshwari (JIRA) [jira] [Created] (SAMZA-1851) Switch precedence of configs and descriptors in ExecutionPlanner Thu, 06 Sep, 23:34
Prateek Maheshwari (JIRA) [jira] [Assigned] (SAMZA-1851) Switch precedence of configs and descriptors in ExecutionPlanner Thu, 06 Sep, 23:35
Yi Pan (Data Infrastructure) (JIRA) [jira] [Updated] (SAMZA-1814) System, Stream and Table configuration generation for low-level task application Thu, 06 Sep, 23:39
Yi Pan (Data Infrastructure) (JIRA) [jira] [Assigned] (SAMZA-1814) System, Stream and Table configuration generation for low-level task application Thu, 06 Sep, 23:39
Yi Pan (Data Infrastructure) (JIRA) [jira] [Commented] (SAMZA-1814) System, Stream and Table configuration generation for low-level task application Thu, 06 Sep, 23:39
Jagadish (JIRA) [jira] [Created] (SAMZA-1852) Clean up TestRunner APIs to auto-generate configs Fri, 07 Sep, 00:40
Jagadish (JIRA) [jira] [Created] (SAMZA-1853) Automate grid setup + clean up on-boarding process Fri, 07 Sep, 01:22
Jagadish (JIRA) [jira] [Created] (SAMZA-1854) Caching table descriptor should not take run-time objects Fri, 07 Sep, 01:29
Jagadish (JIRA) [jira] [Created] (SAMZA-1855) Clean up overall java-docs for Samza 1.0 release Fri, 07 Sep, 01:30
Jagadish (JIRA) [jira] [Created] (SAMZA-1856) Implement system descriptors for Eventhubs Fri, 07 Sep, 01:34
Jagadish (JIRA) [jira] [Created] (SAMZA-1857) Implement System Descriptors for Kinesis Fri, 07 Sep, 01:34
nickpa...@apache.org [1/9] samza git commit: SAMZA-1789: unify ApplicationDescriptor and ApplicationRunner for high- and low-level APIs in YARN and standalone environment Fri, 07 Sep, 06:36
nickpa...@apache.org [2/9] samza git commit: SAMZA-1789: unify ApplicationDescriptor and ApplicationRunner for high- and low-level APIs in YARN and standalone environment Fri, 07 Sep, 06:36
nickpa...@apache.org [3/9] samza git commit: SAMZA-1789: unify ApplicationDescriptor and ApplicationRunner for high- and low-level APIs in YARN and standalone environment Fri, 07 Sep, 06:36
nickpa...@apache.org [4/9] samza git commit: SAMZA-1789: unify ApplicationDescriptor and ApplicationRunner for high- and low-level APIs in YARN and standalone environment Fri, 07 Sep, 06:36
nickpa...@apache.org [5/9] samza git commit: SAMZA-1789: unify ApplicationDescriptor and ApplicationRunner for high- and low-level APIs in YARN and standalone environment Fri, 07 Sep, 06:36
nickpa...@apache.org [6/9] samza git commit: SAMZA-1789: unify ApplicationDescriptor and ApplicationRunner for high- and low-level APIs in YARN and standalone environment Fri, 07 Sep, 06:36
nickpa...@apache.org [7/9] samza git commit: SAMZA-1789: unify ApplicationDescriptor and ApplicationRunner for high- and low-level APIs in YARN and standalone environment Fri, 07 Sep, 06:36
nickpa...@apache.org [8/9] samza git commit: SAMZA-1789: unify ApplicationDescriptor and ApplicationRunner for high- and low-level APIs in YARN and standalone environment Fri, 07 Sep, 06:36
nickpa...@apache.org [9/9] samza git commit: SAMZA-1789: unify ApplicationDescriptor and ApplicationRunner for high- and low-level APIs in YARN and standalone environment Fri, 07 Sep, 06:36
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1789) Refactor the application runtime classes so that we have a unified pattern to write and launch applications in high- and low-level APIs in YARN and standalone Fri, 07 Sep, 06:37
Jake Maes (JIRA) [jira] [Commented] (SAMZA-1855) Clean up overall java-docs for Samza 1.0 release Fri, 07 Sep, 15:40
Cameron Lee (JIRA) [jira] [Created] (SAMZA-1858) Public APIs for shared context Fri, 07 Sep, 17:59
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1858) Public APIs for shared context Fri, 07 Sep, 18:16
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1841) Add broadcast feature to InputDescriptor Fri, 07 Sep, 18:37
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1845) Require setting serde for default system in ApplicationDescriptor#setDefaultSystem Fri, 07 Sep, 20:48
Shanthoosh Venkataraman (JIRA) [jira] [Created] (SAMZA-1859) Zookeeper MetadataStore implementation. Fri, 07 Sep, 21:08
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1859) Zookeeper MetadataStore implementation. Fri, 07 Sep, 21:08
Prateek Maheshwari (JIRA) [jira] [Updated] (SAMZA-1849) Table Descriptors should take Serde at construction time so that descriptors can be typed Fri, 07 Sep, 21:10
Ahmed Abdul Hamid (JIRA) [jira] [Created] (SAMZA-1860) Modularize Join input validation in ExecutionPlanner Fri, 07 Sep, 21:19
Ahmed Abdul Hamid (JIRA) [jira] [Assigned] (SAMZA-1860) Modularize Join input validation in ExecutionPlanner Fri, 07 Sep, 21:21
Prateek Maheshwari (JIRA) [jira] [Created] (SAMZA-1861) Create HDFS System and Stream Descriptors Fri, 07 Sep, 22:20
bor...@apache.org samza git commit: SAMZA-1817: Long classpath support for non-split deployments Fri, 07 Sep, 22:44
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1817) Long classpath support Fri, 07 Sep, 22:46
Ahmed Abdul Hamid (JIRA) [jira] [Created] (SAMZA-1862) Flaky test: TestStreamProcessor testStreamProcessorWithAsyncStreamTaskFactory Sat, 08 Sep, 03:05
Ahmed Abdul Hamid (JIRA) [jira] [Created] (SAMZA-1863) Flaky test: TestZkLocalApplicationRunner shouldStopNewProcessorsJoiningGroupWhenNumContainersIsGreaterThanNumTasks Sat, 08 Sep, 03:08
Ahmed Abdul Hamid (JIRA) [jira] [Created] (SAMZA-1864) Flaky test: TestZkLocalApplicationRunner testRollingUpgradeOfStreamApplicationsShouldGenerateSameJobModel Sat, 08 Sep, 03:10
Ahmed Abdul Hamid (JIRA) [jira] [Created] (SAMZA-1865) Flaky test: TestZkLocalApplicationRunner shouldReElectLeaderWhenLeaderDies Sat, 08 Sep, 03:13
Voronenko Dmitriy (JIRA) [jira] [Created] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer Mon, 10 Sep, 08:56
Voronenko Dmitriy (JIRA) [jira] [Commented] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer Mon, 10 Sep, 12:22
Voronenko Dmitriy (JIRA) [jira] [Resolved] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer Mon, 10 Sep, 12:24
Jake Maes (JIRA) [jira] [Commented] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer Mon, 10 Sep, 15:10
Voronenko Dmitriy (JIRA) [jira] [Commented] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer Mon, 10 Sep, 15:29
Dong Lin (JIRA) [jira] [Commented] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer Mon, 10 Sep, 16:18
Dong Lin (JIRA) [jira] [Assigned] (SAMZA-839) KafkaSystemProducer should use the same partitioning hash function as Kafka's producer Mon, 10 Sep, 16:18
Jake Maes (JIRA) [jira] [Commented] (SAMZA-1866) Invalid partition calculation in KafkaSystemProducer Mon, 10 Sep, 16:45
jagad...@apache.org samza git commit: SAMZA-1824: Handle errors from the async-NMClient when launching containers Mon, 10 Sep, 16:48
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1824) Samza AM does not handle some failures during container launch Mon, 10 Sep, 16:49
Shanthoosh Venkataraman (JIRA) [jira] [Assigned] (SAMZA-1865) Flaky test: TestZkLocalApplicationRunner shouldReElectLeaderWhenLeaderDies Mon, 10 Sep, 17:08
Boris Shkolnik (JIRA) [jira] [Created] (SAMZA-1867) make KafkaSystemAdmin compareOffset method static Mon, 10 Sep, 17:09
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1865) Flaky test: TestZkLocalApplicationRunner shouldReElectLeaderWhenLeaderDies Mon, 10 Sep, 17:10
Boris Shkolnik (JIRA) [jira] [Created] (SAMZA-1868) Refactor KafkaSystemAdmin from using SimpleConsumer Mon, 10 Sep, 17:31
Prateek Maheshwari (JIRA) [jira] [Assigned] (SAMZA-1852) Clean up TestRunner APIs to auto-generate configs Mon, 10 Sep, 17:31
Boris Shkolnik (JIRA) [jira] [Created] (SAMZA-1869) Refactor KafkaSystemConsumer from using SImpleConsumer Mon, 10 Sep, 17:32
Boris Shkolnik (JIRA) [jira] [Updated] (SAMZA-1868) Refactor KafkaSystemAdmin from using SimpleConsumer Mon, 10 Sep, 17:34
Boris Shkolnik (JIRA) [jira] [Updated] (SAMZA-1868) Refactor KafkaSystemAdmin from using SimpleConsumer Mon, 10 Sep, 19:10
Prateek Maheshwari (JIRA) [jira] [Resolved] (SAMZA-1806) Configuring task.broadcast.inputs to an empty string raises IllegalArgumentException Mon, 10 Sep, 20:16
Prateek Maheshwari (JIRA) [jira] [Resolved] (SAMZA-1803) Make InMemoryManager system aware Mon, 10 Sep, 20:16
Prateek Maheshwari (JIRA) [jira] [Resolved] (SAMZA-1782) Make getTableSpecs API in TableConfigGenerator util class public Mon, 10 Sep, 20:18
Hai (JIRA) [jira] [Created] (SAMZA-1870) HDFS system admin not handling END_OF_STREAM offset Tue, 11 Sep, 15:47
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1870) HDFS system admin not handling END_OF_STREAM offset Tue, 11 Sep, 15:52
xi...@apache.org samza git commit: SAMZA-1870: hdfs offset comparator to handle end of stream offset Tue, 11 Sep, 16:58
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1870) HDFS system admin not handling END_OF_STREAM offset Tue, 11 Sep, 16:59
nickpa...@apache.org samza git commit: SAMZA-1837: Fix TestLocalTableWithSideInputs failures. Tue, 11 Sep, 18:12
ASF GitHub Bot (JIRA) [jira] [Commented] (SAMZA-1837) Fix TestLocalTableWithSideInputs failures. Tue, 11 Sep, 18:13
Yi Pan (Data Infrastructure) (JIRA) [jira] [Resolved] (SAMZA-1837) Fix TestLocalTableWithSideInputs failures. Tue, 11 Sep, 18:14
bor...@apache.org samza git commit: SAMZA-1865: Increase coordination timeouts in zookeeper integration tests. Tue, 11 Sep, 18:39
Message list1 · 2 · 3 · 4 · 5 · Next »Thread · Author · Date
Box list
Nov 202090
Oct 202043
Sep 202090
Aug 2020265
Jul 2020152
Jun 2020267
May 2020257
Apr 2020194
Mar 2020325
Feb 2020431
Jan 2020521
Dec 2019350
Nov 2019473
Oct 2019382
Sep 2019334
Aug 2019253
Jul 2019363
Jun 2019624
May 2019903
Apr 2019540
Mar 2019417
Feb 2019168
Jan 2019226
Dec 2018328
Nov 2018314
Oct 2018416
Sep 2018413
Aug 2018201
Jul 2018145
Jun 2018148
May 2018363
Apr 2018322
Mar 2018212
Feb 201894
Jan 2018368
Dec 2017152
Nov 2017230
Oct 2017251
Sep 2017150
Aug 2017270
Jul 2017133
Jun 2017297
May 2017481
Apr 2017463
Mar 2017311
Feb 2017220
Jan 201773
Dec 2016119
Nov 201678
Oct 2016171
Sep 2016214
Aug 2016245
Jul 2016118
Jun 2016139
May 201689
Apr 2016201
Mar 2016277
Feb 2016269
Jan 2016100
Dec 2015288
Nov 2015253
Oct 2015175
Sep 2015185
Aug 2015248
Jul 2015432
Jun 2015407
May 2015329
Apr 2015504
Mar 2015574
Feb 2015439
Jan 2015531
Dec 2014335
Nov 2014366
Oct 2014258
Sep 2014405
Aug 2014476
Jul 2014518
Jun 2014491
May 2014243
Apr 2014394
Mar 2014500
Feb 2014296
Jan 2014174
Dec 2013137
Nov 2013148
Oct 2013139
Sep 201373
Aug 2013368