samza-dev mailing list archives: May 2016

Site index · List index
Message list1 · 2 · Next »Thread · Author · Date
Re: Samza task not receiving on one partition
Jason Erickson   Re: Samza task not receiving on one partition Sun, 01 May, 21:41
Re: [Discuss] Moving Samza to Java 1.8 source compatibility.
Jacob Maes   Re: [Discuss] Moving Samza to Java 1.8 source compatibility. Mon, 02 May, 15:36
Monal     Re: [Discuss] Moving Samza to Java 1.8 source compatibility. Mon, 09 May, 22:49
Re: SAMZA-870 & SAMZA-41
José Barrueta   Re: SAMZA-870 & SAMZA-41 Mon, 02 May, 21:38
Yi Pan     Re: SAMZA-870 & SAMZA-41 Mon, 02 May, 21:55
José Barrueta       Re: SAMZA-870 & SAMZA-41 Mon, 02 May, 22:17
Re: Review Request 44422: SAMZA-41 Update current patch to targe v0.10.0.
Yi Pan \(Data Infrastructure\)   Re: Review Request 44422: SAMZA-41 Update current patch to targe v0.10.0. Mon, 02 May, 21:52
Bae, Jae Hyeon How to implement broadcasted KeyValueStorage with 0.9 Tue, 03 May, 02:58
Jagadish Venkatraman   Re: How to implement broadcasted KeyValueStorage with 0.9 Tue, 03 May, 06:26
Bae, Jae Hyeon     Re: How to implement broadcasted KeyValueStorage with 0.9 Tue, 03 May, 14:48
Jacob Maes       Re: How to implement broadcasted KeyValueStorage with 0.9 Tue, 03 May, 19:46
Boris Shkolnik         Re: How to implement broadcasted KeyValueStorage with 0.9 Wed, 04 May, 16:25
Jagadish Venkatraman           Re: How to implement broadcasted KeyValueStorage with 0.9 Wed, 04 May, 16:29
Re: Review Request 46732: SAMZA-930 fix issue with json deserialisation in YarnUtil
Boris Shkolnik   Re: Review Request 46732: SAMZA-930 fix issue with json deserialisation in YarnUtil Tue, 03 May, 17:00
Re: Review Request 46856: SAMZA-943 Occasional test failure: TestStreamPartitionCountMonitor.testStartStopBehavior
Chris Pettitt   Re: Review Request 46856: SAMZA-943 Occasional test failure: TestStreamPartitionCountMonitor.testStartStopBehavior Tue, 03 May, 17:23
Jake Maes     Re: Review Request 46856: SAMZA-943 Occasional test failure: TestStreamPartitionCountMonitor.testStartStopBehavior Tue, 03 May, 21:55
Chris Pettitt     Re: Review Request 46856: SAMZA-943 Occasional test failure: TestStreamPartitionCountMonitor.testStartStopBehavior Tue, 03 May, 22:05
Jake Maes     Re: Review Request 46856: SAMZA-943 Occasional test failure: TestStreamPartitionCountMonitor.testStartStopBehavior Tue, 03 May, 23:45
Jake Maes     Re: Review Request 46856: SAMZA-943 Occasional test failure: TestStreamPartitionCountMonitor.testStartStopBehavior Wed, 04 May, 00:20
Jake Maes   Re: Review Request 46856: SAMZA-943 Occasional test failure: TestStreamPartitionCountMonitor.testStartStopBehavior Wed, 04 May, 00:18
Jake Maes     Re: Review Request 46856: SAMZA-943 Occasional test failure: TestStreamPartitionCountMonitor.testStartStopBehavior Wed, 04 May, 00:30
Jake Maes       Re: Review Request 46856: SAMZA-943 Occasional test failure: TestStreamPartitionCountMonitor.testStartStopBehavior Thu, 05 May, 20:41
Navina Ramesh         Re: Review Request 46856: SAMZA-943 Occasional test failure: TestStreamPartitionCountMonitor.testStartStopBehavior Fri, 06 May, 17:19
Jake Maes Review Request 46952: SAMZA-944 Broadcast stream is not added properly in the prioritized tiers in the DefaultChooser Wed, 04 May, 00:41
Jake Maes   Re: Review Request 46952: SAMZA-944 Broadcast stream is not added properly in the prioritized tiers in the DefaultChooser Wed, 04 May, 00:42
Jagadish Venkatraman     Re: Review Request 46952: SAMZA-944 Broadcast stream is not added properly in the prioritized tiers in the DefaultChooser Wed, 04 May, 02:00
Jake Maes       Re: Review Request 46952: SAMZA-944 Broadcast stream is not added properly in the prioritized tiers in the DefaultChooser Wed, 04 May, 03:34
Jake Maes     Re: Review Request 46952: SAMZA-944 Broadcast stream is not added properly in the prioritized tiers in the DefaultChooser Wed, 04 May, 03:34
Jagadish Venkatraman       Re: Review Request 46952: SAMZA-944 Broadcast stream is not added properly in the prioritized tiers in the DefaultChooser Wed, 04 May, 06:43
Navina Ramesh       Re: Review Request 46952: SAMZA-944 Broadcast stream is not added properly in the prioritized tiers in the DefaultChooser Thu, 05 May, 17:13
Jack Huang Recover from SamzaException thrown by KeyValueIterator.all() Wed, 04 May, 18:43
Yi Pan   Re: Recover from SamzaException thrown by KeyValueIterator.all() Wed, 04 May, 23:29
Re: Review Request 46644: SAMZA-889 - Change log not working properly with In memory Store
Chris Pettitt   Re: Review Request 46644: SAMZA-889 - Change log not working properly with In memory Store Thu, 05 May, 15:22
Navina Ramesh     Re: Review Request 46644: SAMZA-889 - Change log not working properly with In memory Store Thu, 05 May, 21:16
Jake Maes   Re: Review Request 46644: SAMZA-889 - Change log not working properly with In memory Store Thu, 05 May, 16:18
Navina Ramesh     Re: Review Request 46644: SAMZA-889 - Change log not working properly with In memory Store Thu, 05 May, 21:14
Jake Maes     Re: Review Request 46644: SAMZA-889 - Change log not working properly with In memory Store Thu, 05 May, 21:27
Yi Pan \(Data Infrastructure\)     Re: Review Request 46644: SAMZA-889 - Change log not working properly with In memory Store Fri, 06 May, 21:58
Navina Ramesh   Re: Review Request 46644: SAMZA-889 - Change log not working properly with In memory Store Thu, 05 May, 21:13
Chris Pettitt     Re: Review Request 46644: SAMZA-889 - Change log not working properly with In memory Store Thu, 05 May, 21:19
Navina Ramesh       Re: Review Request 46644: SAMZA-889 - Change log not working properly with In memory Store Fri, 06 May, 02:08
Chris Pettitt       Re: Review Request 46644: SAMZA-889 - Change log not working properly with In memory Store Fri, 06 May, 14:17
Navina Ramesh     Re: Review Request 46644: SAMZA-889 - Change log not working properly with In memory Store Fri, 06 May, 02:07
Yi Pan \(Data Infrastructure\)       Re: Review Request 46644: SAMZA-889 - Change log not working properly with In memory Store Fri, 06 May, 21:58
Jake Maes Review Request 47029: SAMZA-932 port collisions in JmxServer Thu, 05 May, 16:50
Boris Shkolnik   Re: Review Request 47029: SAMZA-932 port collisions in JmxServer Fri, 06 May, 16:25
Jake Maes     Re: Review Request 47029: SAMZA-932 port collisions in JmxServer Fri, 06 May, 16:40
Boris Shkolnik   Re: Review Request 47029: SAMZA-932 port collisions in JmxServer Fri, 06 May, 16:27
Jake Maes     Re: Review Request 47029: SAMZA-932 port collisions in JmxServer Fri, 06 May, 16:42
Yi Pan \(Data Infrastructure\)   Re: Review Request 47029: SAMZA-932 port collisions in JmxServer Fri, 06 May, 17:16
Yi Pan \(Data Infrastructure\) Review Request 47042: SAMZA-915: libear pipeline programming APIs - part 1 Thu, 05 May, 21:46
Yi Pan \(Data Infrastructure\)   Re: Review Request 47042: SAMZA-915: linear pipeline programming APIs - part 1 Thu, 05 May, 21:49
Yi Pan \(Data Infrastructure\) Review Request 47043: SAMZA-915: operator implementation - part 2 Thu, 05 May, 22:03
Jake Maes Review Request 47073: SAMZA-946 - ConcurrentModificationException in TaskAssignmentManager Fri, 06 May, 17:30
Navina Ramesh   Re: Review Request 47073: SAMZA-946 - ConcurrentModificationException in TaskAssignmentManager Fri, 06 May, 18:08
Liu Bo samza job start takes 20 minutes to figure out the Checkpointed offset Sat, 07 May, 09:35
Jagadish Venkatraman   Re: samza job start takes 20 minutes to figure out the Checkpointed offset Sat, 07 May, 18:25
Liu Bo     Re: samza job start takes 20 minutes to figure out the Checkpointed offset Mon, 09 May, 04:00
Yi Pan       Re: samza job start takes 20 minutes to figure out the Checkpointed offset Mon, 09 May, 17:24
Liu Bo         Re: samza job start takes 20 minutes to figure out the Checkpointed offset Tue, 10 May, 04:05
Yi Pan           Re: samza job start takes 20 minutes to figure out the Checkpointed offset Thu, 12 May, 15:27
Re: Review Request 37026: SAMZA-727: Support for Kerberos
Chen Song   Re: Review Request 37026: SAMZA-727: Support for Kerberos Sat, 07 May, 22:37
Chen Song   Re: Review Request 37026: SAMZA-727: Support for Kerberos Sat, 07 May, 22:38
Chen Song     Re: Review Request 37026: SAMZA-727: Support for Kerberos Sun, 08 May, 00:50
Yi Pan \(Data Infrastructure\)       Re: Review Request 37026: SAMZA-727: Support for Kerberos Tue, 24 May, 03:31
Yi Pan \(Data Infrastructure\)         Re: Review Request 37026: SAMZA-727: Support for Kerberos Tue, 24 May, 17:09
Yi Pan \(Data Infrastructure\)         Re: Review Request 37026: SAMZA-727: Support for Kerberos Tue, 24 May, 18:40
Yi Pan \(Data Infrastructure\)       Re: Review Request 37026: SAMZA-727: Support for Kerberos Tue, 24 May, 18:42
Chen Song   Re: Review Request 37026: SAMZA-727: Support for Kerberos Tue, 24 May, 00:38
Andy Chambers Can a job write to output topic that is also input topic Sun, 08 May, 18:08
Jagadish Venkatraman   Re: Can a job write to output topic that is also input topic Sun, 08 May, 18:38
SSHOU help me about samza metrics Tue, 10 May, 07:54
SSHOU   Re: help me about samza metrics Tue, 10 May, 08:25
Yi Pan     Re: help me about samza metrics Wed, 11 May, 19:05
Fwd: Howto Use The Elasticsearch Producer
Tim Washington   Fwd: Howto Use The Elasticsearch Producer Tue, 10 May, 15:36
Jacob Maes     Re: Howto Use The Elasticsearch Producer Tue, 10 May, 16:08
Tim Washington       Re: Howto Use The Elasticsearch Producer Tue, 10 May, 17:16
Jacob Maes         Re: Howto Use The Elasticsearch Producer Tue, 10 May, 17:25
Re: Review Request 46287: Add a double serde.
Yi Pan \(Data Infrastructure\)   Re: Review Request 46287: Add a double serde. Tue, 10 May, 16:59
Yi Pan \(Data Infrastructure\)   Re: Review Request 46287: Add a double serde. Wed, 11 May, 17:24
Nick Quinn Kafka dependency Tue, 10 May, 17:28
Yi Pan   Re: Kafka dependency Tue, 10 May, 18:22
Nick Quinn     RE: Kafka dependency Tue, 10 May, 18:24
Robert Crim       Re: Kafka dependency Tue, 10 May, 18:37
Yi Pan       Re: Kafka dependency Tue, 10 May, 18:39
Jake Maes Review Request 47197: SAMZA-948 CoordinatorSystemStreamConsumer is not threadsafe Tue, 10 May, 23:07
Chris Pettitt   Re: Review Request 47197: SAMZA-948 CoordinatorSystemStreamConsumer is not threadsafe Wed, 11 May, 18:28
Jake Maes     Re: Review Request 47197: SAMZA-948 CoordinatorSystemStreamConsumer is not threadsafe Wed, 11 May, 20:15
Jake Maes   Re: Review Request 47197: SAMZA-948 CoordinatorSystemStreamConsumer is not threadsafe Wed, 11 May, 20:13
Yi Pan \(Data Infrastructure\)     Re: Review Request 47197: SAMZA-948 CoordinatorSystemStreamConsumer is not threadsafe Wed, 11 May, 20:21
Chris Pettitt     Re: Review Request 47197: SAMZA-948 CoordinatorSystemStreamConsumer is not threadsafe Wed, 11 May, 23:11
Jake Maes     Re: Review Request 47197: SAMZA-948 CoordinatorSystemStreamConsumer is not threadsafe Wed, 11 May, 23:49
Jake Maes       Re: Review Request 47197: SAMZA-948 CoordinatorSystemStreamConsumer is not threadsafe Wed, 11 May, 23:55
Jake Maes         Re: Review Request 47197: SAMZA-948 CoordinatorSystemStreamConsumer is not threadsafe Thu, 12 May, 00:32
Re: Review Request 44920: SAMZA-680 Refactor the Samza AppMaster to support other cluster managers
Jagadish Venkatraman   Re: Review Request 44920: SAMZA-680 Refactor the Samza AppMaster to support other cluster managers Tue, 10 May, 23:50
Re: Review Request 45258: Abandon producer retry after a certain # of errors : SAMZA-911
Jagadish Venkatraman   Re: Review Request 45258: Abandon producer retry after a certain # of errors : SAMZA-911 Wed, 11 May, 17:51
Jake Maes Review Request 47247: SAMZA-947 - TaskAssignmentManager registration exception when partition count changes. Wed, 11 May, 18:19
Yi Pan \(Data Infrastructure\)   Re: Review Request 47247: SAMZA-947 - TaskAssignmentManager registration exception when partition count changes. Wed, 11 May, 20:07
Jake Maes     Re: Review Request 47247: SAMZA-947 - TaskAssignmentManager registration exception when partition count changes. Wed, 11 May, 20:23
Jake Maes     Re: Review Request 47247: SAMZA-947 - TaskAssignmentManager registration exception when partition count changes. Wed, 11 May, 20:34
Yi Pan \(Data Infrastructure\)     Re: Review Request 47247: SAMZA-947 - TaskAssignmentManager registration exception when partition count changes. Wed, 11 May, 21:13
Jake Maes   Re: Review Request 47247: SAMZA-947 - TaskAssignmentManager registration exception when partition count changes. Wed, 11 May, 20:26
Yi Pan \(Data Infrastructure\)     Re: Review Request 47247: SAMZA-947 - TaskAssignmentManager registration exception when partition count changes. Wed, 11 May, 21:18
Jake Maes       Re: Review Request 47247: SAMZA-947 - TaskAssignmentManager registration exception when partition count changes. Wed, 11 May, 23:37
Re: Review Request 40934: SAMZA-827: Handle null offsets when writing state store OFFSET file
Jagadish Venkatraman   Re: Review Request 40934: SAMZA-827: Handle null offsets when writing state store OFFSET file Wed, 11 May, 18:21
Jagadish Venkatraman     Re: Review Request 40934: SAMZA-827: null offsets when writing state store OFFSET file cause container stalls Wed, 11 May, 18:25
Jake Maes Review Request 47251: SAMZA-852 - Better logging when system can not be created Always log the exception when we cant instantiate a producer or consumer Wed, 11 May, 18:53
Jagadish Venkatraman   Re: Review Request 47251: SAMZA-852 - Better logging when system can not be created Always log the exception when we cant instantiate a producer or consumer Wed, 11 May, 19:19
Yi Pan \(Data Infrastructure\)   Re: Review Request 47251: SAMZA-852 - Better logging when system can not be created Always log the exception when we cant instantiate a producer or consumer Thu, 12 May, 00:21
Boris Shkolnik   Re: Review Request 47251: SAMZA-852 - Better logging when system can not be created Always log the exception when we cant instantiate a producer or consumer Wed, 18 May, 23:26
Jagadish Venkatraman Review Request 47283: SamzaCoordinator Refactor Part 2: UI related changes, dead code removal Thu, 12 May, 02:57
Andy Throgmorton 0.10.1 Release Thu, 12 May, 16:56
Yi Pan   Re: 0.10.1 Release Thu, 12 May, 17:53
Louis Calisi Java 8, RocksDB and Samza 0.10.0 Tue, 17 May, 19:08
Jason Erickson   Re: Java 8, RocksDB and Samza 0.10.0 Wed, 18 May, 15:25
Louis Calisi     Re: Java 8, RocksDB and Samza 0.10.0 Wed, 18 May, 15:29
Yi Pan       Re: Java 8, RocksDB and Samza 0.10.0 Thu, 19 May, 21:24
Jason Erickson         Re: Java 8, RocksDB and Samza 0.10.0 Fri, 20 May, 15:52
Louis Calisi     Re: Java 8, RocksDB and Samza 0.10.0 Fri, 20 May, 17:09
Yi Pan       Re: Java 8, RocksDB and Samza 0.10.0 Mon, 23 May, 17:17
Louis Calisi         Re: Java 8, RocksDB and Samza 0.10.0 Mon, 23 May, 17:36
Yi Pan           Re: Java 8, RocksDB and Samza 0.10.0 Mon, 23 May, 21:25
David Yu Samza job killed by left orphaned on YARN Wed, 18 May, 06:54
Jacob Maes   Re: Samza job killed by left orphaned on YARN Wed, 18 May, 14:08
David Yu     Re: Samza job killed by left orphaned on YARN Wed, 18 May, 17:21
David Yu       Re: Samza job killed by left orphaned on YARN Wed, 18 May, 17:32
Jacob Maes         Re: Samza job killed by left orphaned on YARN Wed, 18 May, 18:53
David Yu           Re: Samza job killed by left orphaned on YARN Thu, 19 May, 21:33
Yi Pan             Re: Samza job killed by left orphaned on YARN Thu, 19 May, 21:55
Nick Quinn Enabling Core Dumps Wed, 18 May, 16:47
Jagadish Venkatraman   Re: Enabling Core Dumps Wed, 18 May, 18:25
Chris Pettitt     Re: Enabling Core Dumps Wed, 18 May, 18:29
Nick Quinn       RE: Enabling Core Dumps Wed, 18 May, 18:36
Review Request 47542: SAMZA-950 - Add backward-compatible KafkaSystemProducer constructor for Java clients
Jake Maes   Review Request 47542: SAMZA-950 - Add backward-compatible KafkaSystemProducer constructor for Java clients Wed, 18 May, 17:02
Jake Maes   Re: Review Request 47542: SAMZA-950 - Add backward-compatible KafkaSystemProducer constructor for Java clients Wed, 18 May, 17:19
Jake Maes     Re: Review Request 47542: SAMZA-950 - Add backward-compatible KafkaSystemProducer constructor for Java clients Wed, 18 May, 18:39
Joshua Hartman       Re: Review Request 47542: SAMZA-950 - Add backward-compatible KafkaSystemProducer constructor for Java clients Wed, 18 May, 18:50
Navina Ramesh       Re: Review Request 47542: SAMZA-950 - Add backward-compatible KafkaSystemProducer constructor for Java clients Wed, 18 May, 23:57
Jake Maes Review Request 47620: SAMZA-951 - Improve event loop timing metrics * Exclude choose-ns from the active time, thereby removing the associated poll() waiting from the event-loop-utilization metric * Add poll-ns and deserialization-ns metrics to SystemConsumers to help users understand the time spent during choose * Fix so Thu, 19 May, 23:58
Jake Maes   Re: Review Request 47620: SAMZA-951 - Improve event loop timing metrics Fri, 20 May, 00:04
Jake Maes     Re: Review Request 47620: SAMZA-951 - Improve event loop timing metrics Fri, 20 May, 00:31
Jake Maes       Re: Review Request 47620: SAMZA-951 - Improve event loop timing metrics Fri, 20 May, 00:40
Yi Pan \(Data Infrastructure\)         Re: Review Request 47620: SAMZA-951 - Improve event loop timing metrics Mon, 23 May, 18:31
Jake Maes           Re: Review Request 47620: SAMZA-951 - Improve event loop timing metrics Mon, 23 May, 21:04
Jake Maes         Re: Review Request 47620: SAMZA-951 - Improve event loop timing metrics Mon, 23 May, 21:03
Yi Pan \(Data Infrastructure\)           Re: Review Request 47620: SAMZA-951 - Improve event loop timing metrics Mon, 23 May, 23:16
Re: Review Request 45324: SAMZA-914: Initial draft for Java programming APIs on operators supporting DAGs
Jake Maes   Re: Review Request 45324: SAMZA-914: Initial draft for Java programming APIs on operators supporting DAGs Fri, 20 May, 23:56
Yi Pan \(Data Infrastructure\)     Re: Review Request 45324: SAMZA-914: Initial draft for Java programming APIs on operators supporting DAGs Sun, 22 May, 16:17
Jagadish Venkatraman Review Request 47684: Replay patch on top of current master Sat, 21 May, 01:05
Jagadish Venkatraman   Re: Review Request 47684: Replay patch RB:44920 on top of current master Sat, 21 May, 01:07
Re: Review Request 47687: Merged patch 44920
Jagadish Venkatraman   Re: Review Request 47687: Merged patch 44920 Sat, 21 May, 01:39
Jagadish Venkatraman     Re: Review Request 47687: Merged patch 44920 Mon, 23 May, 18:34
Yi Pan \(Data Infrastructure\)       Re: Review Request 47687: Merged patch 44920 Fri, 27 May, 23:17
Re: Review Request 46282: SAMZA-928 document Kerberos on YARN
Chen Song   Re: Review Request 46282: SAMZA-928 document Kerberos on YARN Mon, 23 May, 15:22
Chen Song   Re: Review Request 46282: SAMZA-928 document Kerberos on YARN Tue, 24 May, 01:02
Yi Pan \(Data Infrastructure\)   Re: Review Request 46282: SAMZA-928 document Kerberos on YARN Tue, 24 May, 03:43
Chen Song   Re: Review Request 46282: SAMZA-928 document Kerberos on YARN Wed, 25 May, 20:07
Chen Song   Re: Review Request 46282: SAMZA-928 document Kerberos on YARN Wed, 25 May, 20:11
Yi Pan \(Data Infrastructure\)     Re: Review Request 46282: SAMZA-928 document Kerberos on YARN Thu, 26 May, 21:37
Sriram Ramachandrasekaran Samza / Kafka Streams Future Mon, 23 May, 17:28
Radoslaw Gruchalski   Re: Samza / Kafka Streams Future Mon, 23 May, 17:58
Kartik Paramasivam   Re: Samza / Kafka Streams Future Tue, 24 May, 05:28
Branislav Cogic Review Request 47761: SAMZA-856: Optionally automatically commit based on number of processed messages Tue, 24 May, 08:04
Message list1 · 2 · Next »Thread · Author · Date
Box list
May 201937
Apr 2019122
Mar 2019578
Feb 2019291
Jan 2019111
Dec 201879
Nov 2018114
Oct 2018269
Sep 2018123
Aug 201872
Jul 201863
Jun 201873
May 2018129
Apr 201877
Mar 201889
Feb 201848
Jan 201886
Dec 201773
Nov 201781
Oct 2017111
Sep 201775
Aug 2017132
Jul 201759
Jun 2017141
May 2017193
Apr 2017148
Mar 2017177
Feb 2017100
Jan 201764
Dec 201653
Nov 2016120
Oct 2016189
Sep 2016263
Aug 2016239
Jul 2016183
Jun 2016185
May 2016171
Apr 2016173
Mar 2016270
Feb 2016195
Jan 2016121
Dec 2015130
Nov 2015177
Oct 2015137
Sep 2015162
Aug 2015207
Jul 2015437
Jun 2015267
May 2015280
Apr 2015264
Mar 2015310
Feb 2015266
Jan 2015287
Dec 2014186
Nov 2014183
Oct 2014121
Sep 2014174
Aug 2014181
Jul 2014158
Jun 2014139
May 201457
Apr 2014140
Mar 2014275
Feb 2014218
Jan 201447
Dec 201362
Nov 201337
Oct 201373
Sep 201361
Aug 201399