dev  

Messages by Thread

• • [GitHub] samza pull request #628: SAMZA-1845: Require providing serde for default sys... prateekm
• [GitHub] samza pull request #627: SAMZA-1841: Added support for marking an input stre... prateekm
  • [GitHub] samza pull request #627: SAMZA-1841: Added support for marking an input stre... prateekm
• [GitHub] samza pull request #626: SAMZA-1858: Public APIs for shared context cameronlee314
  • [GitHub] samza pull request #626: SAMZA-1858: Public APIs for shared context asfgit
• [GitHub] samza pull request #625: Samza SQL: Code re-org to accomodate 'INSERT INTO' ... atoomula
  • [GitHub] samza pull request #625: Samza SQL: Code re-org to accomodate Samza SQL engi... atoomula
• [GitHub] samza pull request #624: New consumer for kafka system sborya
  • [GitHub] samza pull request #624: New consumer for kafka system asfgit
• [GitHub] samza pull request #623: SAMZA-1838: Make some minor improvements to Executi... ahmedahamid
  • [GitHub] samza pull request #623: SAMZA-1838: Make some minor improvements to Executi... asfgit
• [GitHub] samza pull request #622: Handle Repartitioning of Streams MayureshGharat
  • [GitHub] samza pull request #622: [EXPERIMENTAL] : Handle Repartitioning of Streams MayureshGharat
• [GitHub] samza pull request #621: SAMZA-1837: Fix TestLocalTableWithSideInputs failur... shanthoosh
  • [GitHub] samza pull request #621: SAMZA-1837: Fix TestLocalTableWithSideInputs failur... asfgit
• [GitHub] samza pull request #620: Samza 1836: StreamManager created before ExecutionP... nickpan47
  • [GitHub] samza pull request #620: Samza 1836: StreamManager created before ExecutionP... asfgit
• [GitHub] samza pull request #619: Samza 1817: Long classpath support for non-split de... Sanil15
  • [GitHub] samza pull request #619: Samza 1817: Long classpath support for non-split de... asfgit
• [GitHub] samza pull request #618: SAMZA-1795 table: add common retry for IO functions pdu-mn1
  • [GitHub] samza pull request #618: SAMZA-1795 table: add common retry for IO functions asfgit
• [GitHub] samza pull request #617: SAMZA-1826: Fix unit test failure in table tests nickpan47
  • [GitHub] samza pull request #617: SAMZA-1826: Fix unit test failure in table tests asfgit
• [GitHub] samza pull request #616: SAMZA-1821: fix the IllegalStateException complaini... weiqingy
  • [GitHub] samza pull request #616: SAMZA-1821: fix the IllegalStateException complaini... asfgit
• [GitHub] samza pull request #615: SAMZA-1824: Handle errors from the async-NMClient w... vjagadish1989
  • [GitHub] samza pull request #615: SAMZA-1824: Handle errors from the async-NMClient w... asfgit
• [GitHub] samza pull request #614: SAMZA 1820: Support for all the calcite timestamp f... srinipunuru
  • [GitHub] samza pull request #614: SAMZA 1820: Support for all the calcite timestamp f... asfgit
• Samza 0.14.1 not correctly handling OffsetOutOfRangeException exception? Gaurav Agarwal
  • Re: Samza 0.14.1 not correctly handling OffsetOutOfRangeException exception? Gaurav Agarwal
  • Re: Samza 0.14.1 not correctly handling OffsetOutOfRangeException exception? Gaurav Agarwal
  • Re: Samza 0.14.1 not correctly handling OffsetOutOfRangeException exception? Debraj Manna
  • Re: Samza 0.14.1 not correctly handling OffsetOutOfRangeException exception? Yi Pan
  • Re: Samza 0.14.1 not correctly handling OffsetOutOfRangeException exception? Debraj Manna
  • Re: Samza 0.14.1 not correctly handling OffsetOutOfRangeException exception? Debraj Manna
  • Re: Samza 0.14.1 not correctly handling OffsetOutOfRangeException exception? Yi Pan
• [GitHub] samza pull request #613: String format params fix. sborya
  • [GitHub] samza pull request #613: String format params fix. asfgit
• [GitHub] samza pull request #612: SAMZA-1813: ApplicationRunner should use Planner ge... prateekm
  • [GitHub] samza pull request #612: SAMZA-1813: ApplicationRunner should use Planner ge... asfgit
• [GitHub] samza pull request #611: SAMZA-1812: Added configuration for changelog to lo... weisong44
  • [GitHub] samza pull request #611: SAMZA-1812: Added configuration for changelog to lo... asfgit
• Samza/Yarn cluster having issue with OffsetOutOfRangeException Will Schneider
  • Re: Samza/Yarn cluster having issue with OffsetOutOfRangeException Jagadish Venkatraman
  • Re: Samza/Yarn cluster having issue with OffsetOutOfRangeException Yi Pan
• [GitHub] samza pull request #610: SAMZA-1733 : Adding comments, adding emptyness chec... rmatharu
  • [GitHub] samza pull request #610: SAMZA-1733 : Adding comments, adding emptyness chec... asfgit
• [GitHub] samza pull request #609: SAMZA-1733: Bugfix: Moving to use string for type i... rmatharu
  • [GitHub] samza pull request #609: SAMZA-1733: Bugfix: Moving to use string for type i... asfgit
• [GitHub] samza pull request #608: SAMZA-1807 table-api: inline async helpers pdu-mn1
• [GitHub] samza pull request #607: SAMZA-1809: Add more logging to intermediate topic ... bharathkk
  • [GitHub] samza pull request #607: SAMZA-1809: Add more logging to intermediate topic ... asfgit
• [GitHub] samza pull request #606: SAMZA-1789: unify ApplicationDescriptor and Applica... nickpan47
  • [GitHub] samza pull request #606: SAMZA-1789: unify ApplicationDescriptor and Applica... asfgit
• [GitHub] samza pull request #605: Enabling auto-discovery of regex input topics rmatharu
  • [GitHub] samza pull request #605: Enabling auto-discovery of regex input topics rmatharu
• [GitHub] samza pull request #604: SAMZA-1806: Allow `task.broadcast.inputs` to be set... abhishekshivanna
  • [GitHub] samza pull request #604: SAMZA-1806: Allow `task.broadcast.inputs` to be set... asfgit
• [DISCUSS] SEP-14: System and Stream Descriptors Prateek Maheshwari
  • Re: [DISCUSS] SEP-14: System and Stream Descriptors Prateek Maheshwari
• [GitHub] samza pull request #603: SAMZA-1804: System and Stream Descriptors prateekm
  • [GitHub] samza pull request #603: SAMZA-1804: System and Stream Descriptors asfgit
• [GitHub] samza pull request #602: Create diagnostic topic and ACLs if diagnostics ena... rmatharu
  • [GitHub] samza pull request #602: SAMZA-1733: Create diagnostic topic if diagnostics ... asfgit
• [GitHub] samza pull request #601: SAMZA-1803: Make InMemoryManager system aware bharathkk
  • [GitHub] samza pull request #601: SAMZA-1803: Make InMemoryManager system aware asfgit
• [GitHub] samza pull request #600: SAMZA-1802: Enable host affinity when RocksDB is pr... weisong44
  • [GitHub] samza pull request #600: SAMZA-1802: Enable host affinity when RocksDB is pr... asfgit
• [GitHub] samza pull request #599: Fix for transient error failure -- concurrent evict... rmatharu
  • [GitHub] samza pull request #599: Fix for transient error failure -- concurrent evict... asfgit
• [GitHub] samza pull request #598: SAMZA-1754: Improve validation error messages in St... rgroothuijsen
• [GitHub] samza pull request #597: SAMZA-1769. Remote app runner status sborya
  • [GitHub] samza pull request #597: SAMZA-1769. Remote app runner status asfgit
• Using dynamodb as source stream Anoop Krishnakumar
  • Re: Using dynamodb as source stream Jagadish Venkatraman
• [GitHub] samza pull request #596: SAMZA-1733: Defaulting to non-null serde, in case n... rmatharu
  • [GitHub] samza pull request #596: SAMZA-1733: Defaulting to non-null serde, in case n... asfgit
• [GitHub] samza pull request #595: SAMZA-1796: PassthroughJobCoordinator doesn't creat... xinyuiscool
  • [GitHub] samza pull request #595: SAMZA-1796: PassthroughJobCoordinator doesn't creat... asfgit
• [GitHub] samza pull request #594: SideInput: Added tests and fixed serde issue during... bharathkk
  • [GitHub] samza pull request #594: SideInput: Added tests and fixed serde issue during... asfgit
• [GitHub] samza pull request #593: SAMZA-1763: Add async methods to Table API pdu-mn1
  • [GitHub] samza pull request #593: SAMZA-1763: Add async methods to Table API asfgit
• [GitHub] samza pull request #592: SAMZA-1794: setting application acl in launch conte... lhaiesp
  • [GitHub] samza pull request #592: SAMZA-1794: setting application acl in launch conte... asfgit
• [GitHub] samza pull request #591: Adding filter mechanism to MetricsSnapshotReporter rmatharu
  • [GitHub] samza pull request #591: SAMZA-1733: Adding filter mechanism to MetricsSnaps... asfgit
• [GitHub] samza pull request #590: Fixing problem with Serde of StackTraceElement, was... rmatharu
  • [GitHub] samza pull request #590: SAMZA-1791: Fixing problem with Serde of StackTrace... asfgit
• [GitHub] samza pull request #589: Fix to test, for added field containerid in metrics... rayman7718
  • [GitHub] samza pull request #589: Fix to test, for added field containerid in metrics... rayman7718
• [DISCUSS] SEP-13: refactor application runtime classes to unify describe and launch the low- and high-level applications in YARN and standalone Yi Pan
  • Re: [DISCUSS] SEP-13: refactor application runtime classes to unify describe and launch the low- and high-level applications in YARN and standalone Yi Pan
  • Re: [DISCUSS] SEP-13: refactor application runtime classes to unify describe and launch the low- and high-level applications in YARN and standalone Yi Pan
• [GitHub] samza pull request #588: SAMZA-1768: Handle corrupted OFFSET file xinyuiscool
  • [GitHub] samza pull request #588: SAMZA-1768: Handle corrupted OFFSET file asfgit
• [GitHub] samza pull request #587: add retry logic in eventhubs system consumer for no... lhaiesp
  • [GitHub] samza pull request #587: SAMZA-1785: add retry logic in eventhubs system con... asfgit
• [GitHub] samza pull request #586: SAMZA-1790: LocalContainerRunner should not extend ... prateekm
  • [GitHub] samza pull request #586: SAMZA-1790: LocalContainerRunner should not extend ... asfgit
• [VOTE] SEP-13: refactor application runtime classes to unify describe and launch the low- and high-level applications in YARN and standalone Yi Pan
• [GitHub] samza pull request #585: SAMZA-1788: Add LocationIdProvider abstraction. shanthoosh
  • [GitHub] samza pull request #585: SAMZA-1788: Add LocationIdProvider abstraction. asfgit
• [GitHub] samza pull request #584: SAMZA-1787: Refactor TaskStorageManager to use SSPM... cameronlee314
  • [GitHub] samza pull request #584: SAMZA-1787: Refactor TaskStorageManager to use SSPM... cameronlee314
• [GitHub] samza pull request #583: SAMZA-1786: Introduce metadata store abstraction. shanthoosh
  • [GitHub] samza pull request #583: SAMZA-1786: Introduce metadata store abstraction. asfgit
• [GitHub] samza pull request #582: Handle end of stream in BootstrapChooser bharathkk
  • [GitHub] samza pull request #582: Handle end of stream in BootstrapChooser asfgit
• [GitHub] samza pull request #581: SAMZA-1785: ignore timeout exception during receive... lhaiesp
  • [GitHub] samza pull request #581: SAMZA-1785: ignore timeout exception during receive... lhaiesp
• [GitHub] samza pull request #580: Side inputs: Bug fixes bharathkk
  • [GitHub] samza pull request #580: Side inputs: Bug fixes asfgit
• [GitHub] samza pull request #579: SAMZA-1784: Update committers.md weisong44
  • [GitHub] samza pull request #579: SAMZA-1784: Update committers.md asfgit
• [GitHub] samza pull request #578: SAMZA-1783: Add Log4j2 functionality in Samza PawasChhokra
  • [GitHub] samza pull request #578: SAMZA-1783: Add Log4j2 functionality in Samza asfgit
• [GitHub] samza pull request #577: SAMZA-1782: Making getTableSpecs API in TableConfig... atoomula
  • [GitHub] samza pull request #577: SAMZA-1782: Making getTableSpecs API in TableConfig... asfgit
• Welcome Wei Song and Srinivasulu Punuru as committers to Samza! Yi Pan
• [GitHub] samza pull request #576: Minor: Disable flaky samza-yarn test. Fix tracked i... vjagadish1989
  • [GitHub] samza pull request #576: Minor: Disable flaky samza-yarn test. Fix tracked i... asfgit
• [GitHub] samza pull request #575: SAMZA-1779: Fix SamzaSql AvroRelConverter to handle... atoomula
  • [GitHub] samza pull request #575: SAMZA-1779: Fix SamzaSql AvroRelConverter to handle... asfgit
• [GitHub] samza pull request #574: Fix SamzaSql AvroRelConverter to handle BYTES and F... atoomula
  • [GitHub] samza pull request #574: SAMZA-1779: Fix SamzaSql AvroRelConverter to handle... atoomula
• [GitHub] samza pull request #573: NO-TICKET: Change instances of "is catched up" to "... tbutterwith
  • [GitHub] samza pull request #573: NO-JIRA: Change instances of "is catched up" to "is... asfgit
• [GitHub] samza pull request #572: Adding containerID to metric header rmatharu
  • [GitHub] samza pull request #572: SAMZA-1733: Adding containerID to metric header asfgit
• [GitHub] samza pull request #571: SAMZA-1775: add some delay before renew under trans... lhaiesp
  • [GitHub] samza pull request #571: SAMZA-1775: add some delay before renew under trans... asfgit
• [GitHub] samza pull request #570: SAMZA-1773: Side inputs for local stores bharathkk
  • [GitHub] samza pull request #570: SAMZA-1773: Side inputs for local stores asfgit
• [GitHub] samza pull request #569: Initial implementation of side input stores bharathkk
  • [GitHub] samza pull request #569: Initial implementation of side input stores bharathkk
• [GitHub] samza pull request #568: Samza 1759: Stream Assert utilities for low level a... Sanil15
  • [GitHub] samza pull request #568: Samza 1759: Stream Assert utilities for low level a... asfgit
• Register now for ApacheCon and save $250 Rich Bowen
• Samza 0.14.1 : OffsetOutOfRangeException even with auto.offset.reset=smallest Thunder Stumpges
  • Re: Samza 0.14.1 : OffsetOutOfRangeException even with auto.offset.reset=smallest Prateek Maheshwari
  • RE: Samza 0.14.1 : OffsetOutOfRangeException even with auto.offset.reset=smallest Thunder Stumpges
• [VOTE] Committership for Wei and Srini Xinyu Liu
  • Re: [VOTE] Committership for Wei and Srini Xinyu Liu
• Question regarding Samza's Kafka consumer Thomas Becker
  • Re: Question regarding Samza's Kafka consumer Thomas Becker
  • Re: Question regarding Samza's Kafka consumer Jagadish Venkatraman
  • Re: Question regarding Samza's Kafka consumer Thomas Becker
• [GitHub] samza pull request #567: JIRA 1735 Adding ListGaugeMBean, to enable MBean va... rmatharu
  • [GitHub] samza pull request #567: JIRA 1735 Adding ListGaugeMBean, to enable MBean va... asfgit
• [GitHub] samza pull request #566: SAMZA-1762: Fix Memory link in the Timer Registry M... xinyuiscool
  • [GitHub] samza pull request #566: SAMZA-1762: Fix Memory link in the Timer Registry M... asfgit
• [GitHub] samza pull request #565: SAMZA-1761: Reduce runTime of TestZkUtils test from... shanthoosh
  • [GitHub] samza pull request #565: SAMZA-1761: Reduce runTime of TestZkUtils test from... asfgit
• [GitHub] samza pull request #564: SAMZA-1760: SystemAdmin is not started properly in ... cameronlee314
• [GitHub] samza pull request #563: SAMZA-1758: Configuring a timeout for TestRunner to... Sanil15
  • [GitHub] samza pull request #563: SAMZA-1758: Configuring a timeout for TestRunner to... asfgit
• [GitHub] samza pull request #562: Minor: Changing tests which use resource files to u... cameronlee314
  • [GitHub] samza pull request #562: Minor: Changing tests which use resource files to u... asfgit
• [GitHub] samza pull request #561: SAMZA-1756: System exit calls in ApplicationRunnerM... cameronlee314
  • [GitHub] samza pull request #561: SAMZA-1756: System exit calls in ApplicationRunnerM... asfgit
• [GitHub] samza pull request #560: Fixed failed unit tests in TestCachingTable weisong44
  • [GitHub] samza pull request #560: Fixed failed unit tests in TestCachingTable asfgit
• [GitHub] samza pull request #559: Added timestamp to Incoming message envelope. sborya
  • [GitHub] samza pull request #559: SAMZA-1753: Added timestamp to Incoming message env... asfgit
• [GitHub] samza pull request #558: Fix JsonRelConverter to recursively convert relReco... atoomula
  • [GitHub] samza pull request #558: SAMZA-1755: Fix JsonRelConverter to recursively con... asfgit
• [GitHub] samza pull request #557: Pass full config to the IO resolver srinipunuru
  • [GitHub] samza pull request #557: Samza-1752: Pass full config to the IO resolver asfgit
• [GitHub] samza pull request #556: Table API: support table in low level API atoomula
  • [GitHub] samza pull request #556: SAMZA-1774: Support table API in low level asfgit
• NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10 Debraj Manna
  • Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10 Debraj Manna
  • Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10 Yi Pan
  • Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10 Yi Pan
  • Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10 Debraj Manna
  • Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10 Yi Pan
• [GitHub] samza pull request #555: Refactored metrics for table API weisong44
  • [GitHub] samza pull request #555: SAMZA-1751: Refactored metrics for table API asfgit
• ClassNotFoundException when loading classes via Util#getObj Tom Davis
  • Re: ClassNotFoundException when loading classes via Util#getObj Yi Pan
  • Re: ClassNotFoundException when loading classes via Util#getObj Yi Pan
• [GitHub] samza pull request #554: SAMZA-1748: Standalone failure tests. shanthoosh
  • [GitHub] samza pull request #554: SAMZA-1748: Standalone failure tests. asfgit
• Announce of the next stream processing meetup @LinkedIn Yi Pan
  • Re: Announce of the next stream processing meetup @LinkedIn Yi Pan
  • Re: Announce of the next stream processing meetup @LinkedIn Yi Pan
• [GitHub] samza pull request #553: Add metric to measure effectiveness of host-affinit... vjagadish1989
  • [GitHub] samza pull request #553: SAMZA-1747: Add metric to measure effectiveness of ... asfgit
• [GitHub] samza pull request #552: SAMZA-1745: Remove all usages of StreamSpec and App... prateekm
  • [GitHub] samza pull request #552: SAMZA-1745: Remove all usages of StreamSpec and App... asfgit
• Urgent : Help with latency / backlog / topic lag Thunder Stumpges
  • Re: Urgent : Help with latency / backlog / topic lag Prateek Maheshwari
  • RE: Urgent : Help with latency / backlog / topic lag Thunder Stumpges
  • Re: Urgent : Help with latency / backlog / topic lag Prateek Maheshwari
  • RE: Urgent : Help with latency / backlog / topic lag Thunder Stumpges
  • Re: Urgent : Help with latency / backlog / topic lag Prateek Maheshwari
• [GitHub] samza pull request #551: Fix loadDefaults error msg. sborya
  • [GitHub] samza pull request #551: Fix loadDefaults error msg. asfgit

• Earlier messages
• Later messages