dev  

Messages by Thread

• • [GitHub] samza pull request #474: SAMZA-1656: EventHubSystemAdmin does not fetch meta... asfgit
• [GitHub] samza pull request #473: SystemConsumer and Producer benchmark tests srinipunuru
  • [GitHub] samza pull request #473: SystemConsumer and Producer benchmark tests asfgit
• [GitHub] samza pull request #472: SAMZA-1650: Fix for firing trigger at the end of tr... atoomula
  • [GitHub] samza pull request #472: SAMZA-1650: Fix for firing trigger at the end of tr... asfgit
• [GitHub] samza pull request #471: SAMZA-1649: Improve host-aware allocation to accoun... vjagadish
  • [GitHub] samza pull request #471: SAMZA-1649: Improve host-aware allocation to accoun... asfgit
• [GitHub] samza pull request #470: minor fix on eventhubs size limit for event body an... lhaiesp
  • [GitHub] samza pull request #470: minor fix on eventhubs size limit for event body an... asfgit
• Apache Samza - April 2018 Yi Pan
• [GitHub] samza pull request #469: SAMZA-1645: A few issues found by BEAM stress test xinyuiscool
  • [GitHub] samza pull request #469: SAMZA-1645: A few issues found by BEAM stress test asfgit
• [GitHub] samza pull request #468: SAMZA-1643: StreamPartitionCountMonitor should only... prateekm
  • [GitHub] samza pull request #468: SAMZA-1643: StreamPartitionCountMonitor should only... asfgit
• [GitHub] samza pull request #467: Upgrade to latest event hub version (1.0.1) srinipunuru
  • [GitHub] samza pull request #467: Upgrade to latest event hub version (1.0.1) asfgit
• [GitHub] samza pull request #466: SAMZA-1640: JobModel Json deserialization error in ... shanthoosh
  • [GitHub] samza pull request #466: SAMZA-1640: JobModel Json deserialization error in ... asfgit
• [GitHub] samza pull request #465: sql: initial insert support for table destination pdu-mn1
  • [GitHub] samza pull request #465: SAMZA-1671 sql: initial insert support for table de... asfgit
• [GitHub] samza pull request #464: SAMZA-1619: Samza-sql: Support serialization of nes... atoomula
  • [GitHub] samza pull request #464: SAMZA-1619: Samza-sql: Support serialization of nes... asfgit
• [GitHub] samza pull request #463: SAMZA-1183: Fix TestAsyncRunLoop flaky tests shanthoosh
  • [GitHub] samza pull request #463: SAMZA-1183: Fix TestAsyncRunLoop flaky tests asfgit
• [GitHub] samza pull request #462: SAMZA-1630: Move thread dump from stdout to logs prateekm
  • [GitHub] samza pull request #462: SAMZA-1630: Move thread dump from stdout to logs asfgit
• [GitHub] samza pull request #461: SAMZA-1631: Improve logging on Task callback timeou... prateekm
  • [GitHub] samza pull request #461: SAMZA-1631: Improve logging on Task callback timeou... asfgit
• [GitHub] samza pull request #460: SAMZA-1630: Log a thread dump on timeouts prateekm
  • [GitHub] samza pull request #460: SAMZA-1630: Log a thread dump on timeouts asfgit
• [GitHub] samza pull request #459: Initial version for in memory system. bharathkk
  • [GitHub] samza pull request #459: Initial version for in memory system. asfgit
• [GitHub] samza pull request #264: SAMZA-1372: Change Latch Interface to Lock Interfac... PawasChhokra
• [GitHub] samza pull request #458: Refactoring the EventHub System Producer into reusa... srinipunuru
  • [GitHub] samza pull request #458: Refactoring the EventHub System Producer into reusa... asfgit
• [GitHub] samza pull request #457: KinesisConfig: Making getProxyHost and getProxyPort... atoomula
  • [GitHub] samza pull request #457: SAMZA-1632: KinesisConfig: Making getProxyHost and ... asfgit
• [GitHub] samza pull request #214: SAMZA-1293: Enable partition expansion of input str... lindong28
• [GitHub] samza pull request #456: SAMZA-1627: Watermark broadcast enhancements xinyuiscool
  • [GitHub] samza pull request #456: SAMZA-1627: Watermark broadcast enhancements asfgit
• [GitHub] samza pull request #455: Misc. Util cleanup prateekm
  • [GitHub] samza pull request #455: Misc. Util cleanup asfgit
• [GitHub] samza pull request #454: Skipping large messages in the EventHub system prod... srinipunuru
  • [GitHub] samza pull request #454: Skipping large messages in the EventHub system prod... asfgit
• [GitHub] samza pull request #453: Making event hub configs Samza compliant srinipunuru
  • [GitHub] samza pull request #453: Making event hub configs Samza compliant asfgit
• [GitHub] samza pull request #452: SAMZA-1623: include avro as the file suffix for hdf... lhaiesp
  • [GitHub] samza pull request #452: SAMZA-1623: include avro as the file suffix for hdf... asfgit
• [GitHub] samza pull request #451: SAMZA-1621: Delete the ephemeral processor node in ... shanthoosh
  • [GitHub] samza pull request #451: SAMZA-1621: Delete the ephemeral processor node in ... asfgit
• Stream Processing Meetup @LinkedIn tomorrow (3/21) Yi Pan
  • Re: Stream Processing Meetup @LinkedIn tomorrow (3/21) Tom Davis
  • Re: Stream Processing Meetup @LinkedIn tomorrow (3/21) Jagadish Venkatraman
• [GitHub] samza pull request #450: ScheduleAfterDebounceTime should catch all Throwabl... thunderstumpges
  • [GitHub] samza pull request #450: ScheduleAfterDebounceTime should catch all Throwabl... asfgit
• please unsubscribe me from this samza list - thx Roger Sill
  • Re: please unsubscribe me from this samza list - thx Jake Maes
• [CANCEL][VOTE] SEP-11: Host affinity in standalone. santhosh venkat
• [GitHub] samza pull request #449: SAMZA-1622: avro writer to support generic record lhaiesp
  • [GitHub] samza pull request #449: SAMZA-1622: avro writer to support generic record asfgit
• [GitHub] samza pull request #448: SAMZA-1564: Host affinity in standalone. shanthoosh
  • [GitHub] samza pull request #448: SAMZA-1554: Host affinity in standalone. shanthoosh
• Old style "low level" Tasks with alternative deployment model(s) Thunder Stumpges
  • Re: Old style "low level" Tasks with alternative deployment model(s) Tom Davis
  • RE: Old style "low level" Tasks with alternative deployment model(s) Thunder Stumpges
  • Re: Old style "low level" Tasks with alternative deployment model(s) Jagadish Venkatraman
  • RE: Old style "low level" Tasks with alternative deployment model(s) Thunder Stumpges
  • Re: Old style "low level" Tasks with alternative deployment model(s) Jagadish Venkatraman
  • RE: Old style "low level" Tasks with alternative deployment model(s) Thunder Stumpges
  • RE: Old style "low level" Tasks with alternative deployment model(s) Thunder Stumpges
  • RE: Old style "low level" Tasks with alternative deployment model(s) Thunder Stumpges
  • RE: Old style "low level" Tasks with alternative deployment model(s) Thunder Stumpges
  • Re: Old style "low level" Tasks with alternative deployment model(s) Prateek Maheshwari
  • RE: Old style "low level" Tasks with alternative deployment model(s) Thunder Stumpges
  • RE: Old style "low level" Tasks with alternative deployment model(s) Thunder Stumpges
  • RE: Old style "low level" Tasks with alternative deployment model(s) Thunder Stumpges
  • Re: Old style "low level" Tasks with alternative deployment model(s) Prateek Maheshwari
  • Re: Old style "low level" Tasks with alternative deployment model(s) Jagadish Venkatraman
  • Re: Old style "low level" Tasks with alternative deployment model(s) Tom Davis
  • Re: Old style "low level" Tasks with alternative deployment model(s) Jagadish Venkatraman
  • RE: Old style "low level" Tasks with alternative deployment model(s) Thunder Stumpges
  • Re: Old style "low level" Tasks with alternative deployment model(s) Tom Davis
  • RE: Old style "low level" Tasks with alternative deployment model(s) Thunder Stumpges
• [GitHub] samza pull request #447: fix HdfsFileSystemAdapter to get files recursively lhaiesp
  • [GitHub] samza pull request #447: SAMZA-1618: fix HdfsFileSystemAdapter to get files ... asfgit
• [GitHub] samza pull request #446: sql: initial insert support for table destination pdu-mn1
• [GitHub] samza pull request #445: SAMZA-1609 Refactoring SamzaContainer to take Syste... Sanil15
  • [GitHub] samza pull request #445: SAMZA-1609 Refactoring SamzaContainer to take Syste... Sanil15
• [GitHub] samza pull request #444: SAMZA-1615: Fix a couple of issues in ControlMessag... xinyuiscool
  • [GitHub] samza pull request #444: SAMZA-1615: Fix a couple of issues in ControlMessag... asfgit
• [GitHub] samza pull request #443: Fix BootstrappingChooser to compare offsets via sys... atoomula
  • [GitHub] samza pull request #443: SAMZA-1611 : BootstrappingChooser should use system... asfgit
• [GitHub] samza pull request #442: SAMZA-1608 : Add hidden config to enable explicit s... dnishimura
  • [GitHub] samza pull request #442: SAMZA-1608 : Add hidden config to enable explicit s... asfgit
• [GitHub] samza pull request #441: SAMZA-1584: LocalApplicationRunner.waitForFinish bl... shanthoosh
  • [GitHub] samza pull request #441: SAMZA-1584: Improve logging in StreamProcessor. asfgit
• [GitHub] samza pull request #440: Infinite loop when trying to use SamzaSqlApplicatio... srinipunuru
  • [GitHub] samza pull request #440: Infinite loop when trying to use SamzaSqlApplicatio... asfgit
• [GitHub] samza pull request #439: SAMZA-1602 : Moving class StreamAssert from src/tes... Sanil15
  • [GitHub] samza pull request #439: SAMZA-1602 : Moving class StreamAssert from src/tes... asfgit
• [GitHub] samza pull request #438: SAMZA-1589: Reduce failure retry duration in KafkaC... shanthoosh
  • [GitHub] samza pull request #438: SAMZA-1589: Reduce failure retry duration in KafkaC... asfgit
• [GitHub] samza pull request #437: SAMZA-1607: Handle ZkNodeNotExistsException in zkUt... shanthoosh
  • [GitHub] samza pull request #437: SAMZA-1607: Handle ZkNoNodeExistsException in zkUti... asfgit
• [GitHub] samza pull request #436: SD-1599: Improve the efficiency of the AsynRunLoop ... jwlent55
  • [GitHub] samza pull request #436: SD-1599: Improve the efficiency of the AsynRunLoop ... asfgit
• [GitHub] samza pull request #435: SAMZA-1600: remove the combination of cleanup polic... nickpan47
  • [GitHub] samza pull request #435: SAMZA-1600: remove the combination of cleanup polic... asfgit
• [GitHub] samza pull request #434: SAMZA-1598 : Cleanup README.md file dnishimura
  • [GitHub] samza pull request #434: SAMZA-1598 : Cleanup README.md file asfgit
• Streams Meetup at LinkedIn Sunnyvale 3/21/2018 Jake Maes
  • Re: Streams Meetup at LinkedIn Sunnyvale 3/21/2018 Jagadish Venkatraman
• [GitHub] samza pull request #433: Misc. minor cleanup. prateekm
  • [GitHub] samza pull request #433: Misc. minor cleanup. asfgit
• [GitHub] samza pull request #432: Initial implementation of remote table provider pdu-mn1
  • [GitHub] samza pull request #432: Initial implementation of remote table provider asfgit
• [GitHub] samza pull request #431: Staging directory name has to be formatted in confi... Zedmor
  • [GitHub] samza pull request #431: SAMZA-1596: Staging directory name has to be format... asfgit
• [GitHub] samza pull request #430: SAMZA-1595: Fix scalacCompileOptions format to buil... shanthoosh
  • [GitHub] samza pull request #430: SAMZA-1595: Fix scalacCompileOptions format to buil... asfgit
• [GitHub] samza pull request #429: Added rate limiter interface and embedded implement... weisong44
  • [GitHub] samza pull request #429: Added rate limiter interface and embedded implement... weisong44
• [GitHub] samza pull request #428: Json file reader Zedmor
  • [GitHub] samza pull request #428: Json file reader Zedmor
• [GitHub] samza pull request #427: SAMZA-1594: Fix ScalaCompileOptions errors with hig... shanthoosh
  • [GitHub] samza pull request #427: SAMZA-1594: Remove ScalaCompileOptions to make samz... asfgit
• [GitHub] samza pull request #426: SAMZA-1593: Upgrade gradle nexus plugin. shanthoosh
  • [GitHub] samza pull request #426: SAMZA-1593: Upgrade gradle nexus plugin. asfgit
• [GitHub] samza pull request #425: Add stream-table join support for samza sql atoomula
  • [GitHub] samza pull request #425: Add stream-table join support for samza sql asfgit
• [GitHub] samza pull request #424: Fixes to get the build working with Scala 2.10 buil... srinipunuru
  • [GitHub] samza pull request #424: Fixes to get the build working with Scala 2.10 buil... asfgit
• FINAL REMINDER: CFP for Apache EU Roadshow Closes 25th February Sharan F
• [VOTE] SEP-11: Host affinity in standalone. santhosh venkat
  • Re: [VOTE] SEP-11: Host affinity in standalone. Yi Pan
  • Re: [VOTE] SEP-11: Host affinity in standalone. santhosh venkat
  • [VOTE] SEP-11: Host affinity in standalone. santhosh venkat
  • Re: [VOTE] SEP-11: Host affinity in standalone. Yi Pan
  • Re: [VOTE] SEP-11: Host affinity in standalone. xinyu liu
  • Re: [VOTE] SEP-11: Host affinity in standalone. Jagadish Venkatraman
  • Re: [VOTE] SEP-11: Host affinity in standalone. Jagadish Venkatraman
  • Re: [VOTE] SEP-11: Host affinity in standalone. santhosh venkat
  • Re: [VOTE] SEP-11: Host affinity in standalone. santhosh venkat
• Save the date: ApacheCon North America, September 24-27 in Montréal Rich Bowen
• [GitHub] samza pull request #423: SAMZA-1460: StreamAppender does not explicitly crea... dnishimura
  • [GitHub] samza pull request #423: SAMZA-1460: StreamAppender does not explicitly crea... asfgit
• [GitHub] samza pull request #422: SAMZA-1588: Add random jitter to monitor’s schedu... shanthoosh
  • [GitHub] samza pull request #422: SAMZA-1588: Add random jitter to monitor’s schedu... asfgit
• Apache EU Roadshow CFP Closing Soon (23 February) Sharan F
• [GitHub] samza pull request #421: Support source types where the last part of the sou... srinipunuru
  • [GitHub] samza pull request #421: Support source types where the last part of the sou... asfgit
• [GitHub] samza pull request #420: SAMZA-1572: Add fixed retries on failure in KafkaCh... shanthoosh
  • [GitHub] samza pull request #420: SAMZA-1572: Add fixed retries on failure in KafkaCh... asfgit
• [GitHub] samza pull request #419: SAMZA-1498: Support arbitrary system clock timer in... xinyuiscool
  • [GitHub] samza pull request #419: SAMZA-1498: Support arbitrary system clock timer in... asfgit
• [GitHub] samza pull request #63: SAMZA-1105 upgrade Kafka client version to 0.10.2.0 garlicbulb-puzhuo
• [GitHub] samza pull request #43: Merge pull request #1 from apache/master zmyer
• Re: [DISCUSS] SEP: Host affinity in standalone. Yi Pan
  • Re: [DISCUSS] SEP: Host affinity in standalone. Yi Pan
  • Re: [DISCUSS] SEP: Host affinity in standalone. santhosh venkat
  • Re: [DISCUSS] SEP: Host affinity in standalone. santhosh venkat
  • Re: [DISCUSS] SEP: Host affinity in standalone. santhosh venkat
• [GitHub] samza pull request #401: SAMZA-1552: Host affinity improvements - Improve ma... asfgit
• [GitHub] samza pull request #418: SAMZA-1579; RemoteApplicationRunner should allow us... lindong28
  • [GitHub] samza pull request #418: SAMZA-1579; RemoteApplicationRunner should allow us... lindong28
• [GitHub] samza pull request #417: SAMZA-1489; TaskInstance should commit offset befor... lindong28
  • [GitHub] samza pull request #417: SAMZA-1489; TaskInstance should commit offset befor... asfgit
• Question about custom StreamJob/Factory Tom Davis
  • Re: Question about custom StreamJob/Factory Jagadish Venkatraman
  • Re: Question about custom StreamJob/Factory Tom Davis
  • Re: Question about custom StreamJob/Factory Jagadish Venkatraman
  • Re: Question about custom StreamJob/Factory Tom Davis
  • Re: Question about custom StreamJob/Factory Jagadish Venkatraman
  • Re: Question about custom StreamJob/Factory Tom Davis
  • Re: Question about custom StreamJob/Factory Jagadish Venkatraman
• [GitHub] samza pull request #416: SAMZA-1568: Handle ZkInterruptedException in zkclie... shanthoosh
  • [GitHub] samza pull request #416: SAMZA-1568: Handle ZkInterruptedException in zkclie... asfgit
• No Metrics Emitted in new High-Level API Srujun Thanmay Gupta
  • Re: No Metrics Emitted in new High-Level API Jagadish Venkatraman
  • Re: No Metrics Emitted in new High-Level API Srujun Thanmay Gupta
  • Re: No Metrics Emitted in new High-Level API Yi Pan
  • Re: No Metrics Emitted in new High-Level API Srujun Thanmay Gupta
  • Re: No Metrics Emitted in new High-Level API Jagadish Venkatraman
  • Re: No Metrics Emitted in new High-Level API Yi Pan
  • Re: No Metrics Emitted in new High-Level API Srujun Thanmay Gupta
  • Re: No Metrics Emitted in new High-Level API Yi Pan
  • Re: No Metrics Emitted in new High-Level API Yi Pan
• SEP-11. Host Affinity in standalone discussion. Boris S
  • Re: SEP-11. Host Affinity in standalone discussion. Yi Pan
• [GitHub] samza pull request #415: SAMZA-1578: Fix watermark bug found by BEAM tests xinyuiscool
  • [GitHub] samza pull request #415: SAMZA-1578: Fix watermark bug found by BEAM tests asfgit
• [GitHub] samza pull request #414: Added some logging to stdout for easier parsing by ... prateekm
  • [GitHub] samza pull request #414: Added some logging to stdout for easier parsing by ... asfgit
• [GitHub] samza pull request #397: SAMZA-1548; Add start() and stop() to SystemAdmin asfgit
• [GitHub] samza pull request #410: SAMZA-1557: Broadcast operator asfgit
• [GitHub] samza pull request #413: SAMZA-1555: Move creation of checkpoint and changel... dnishimura
  • [GitHub] samza pull request #413: SAMZA-1555: Move creation of checkpoint and changel... asfgit
• [GitHub] samza pull request #411: Move the changelog and checkpoint stream creation t... dnishimura
• [GitHub] samza pull request #8: Inability to create configured producer should be log... vchekan
• [GitHub] samza pull request #1: [doc] remove samza-serializers maven dependency steven-aerts

• Later messages