Re: [ANNOUNCE] Please welcome Boris Shkolnik to the Samza PMC

Yaay, Boris! Congrats!  From: Daniel Nishimura Sent: Friday, June 7, 2019 3:40 PM To: dev@samza.apache.org Subject: Re: [ANNOUNCE] Please welcome Boris Shkolnik to the Samza PMC Congrats! On Fri, Jun 7, 2019 at 3:35 PM Ignacio Solis wrote: > Congrats Boris! >

Re: [VOTE] Migration of Samza git repo to gitbox.apache.org

It looks like a mandatory migration. Why do we need a vote for this? Thanks! Navina From: Pawas Chhokra Sent: Wednesday, January 23, 2019 11:50:32 AM To: dev@samza.apache.org Subject: [VOTE] Migration of Samza git repo to gitbox.apache.org Hi all

Re: [VOTE] SEP-12: Integration Test Framework

+1 can't wait to have this in! :) From: Jacob Maes Sent: Thursday, May 17, 2018 10:13:57 AM To: dev@samza.apache.org Subject: Re: [VOTE] SEP-12: Integration Test Framework +1 On Thu, May 17, 2018 at 9:56 AM, Jagadish Venkatraman <

Re: Welcome Xinyu as new Samza PMC!

Congratulations, Xinyu! Thanks for all your contribution and looking forward to more  Cheers! Navina From: Yi Pan <nickpa...@gmail.com> Sent: Wednesday, January 17, 2018 10:26:54 AM To: dev@samza.apache.org Subject: Welcome Xinyu as new Samza PMC! Final

Re: [VOTE] Apache Samza 0.14.0 RC5

+1 on RC5. Verified signature and checksum. Ran ./bin/check-all.sh Cheers! Navina From: xinyu liu <xinyuliu...@gmail.com> Sent: Friday, December 22, 2017 2:50:48 PM To: dev@samza.apache.org Subject: [VOTE] Apache Samza 0.14.0 RC5 This is a call for

[GitHub] samza pull request #379: SAMZA-1523 Cleanup table entries before shutting do...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/379 SAMZA-1523 Cleanup table entries before shutting down the processor Modified the `TableUtils#deleteProcessorEntity` to provide an option to disable optimistic locking during a call to Azure Table

Re: [DISCUSS] Samza 0.14.0 release

The list looks awesome! :) From: Jacob Maes Sent: Tuesday, November 28, 2017 10:03:58 AM To: dev@samza.apache.org Subject: Re: [DISCUSS] Samza 0.14.0 release +1 On Mon, Nov 27, 2017 at 8:15 PM, Fred Haifeng Ji wrote:

Re: Historical container logs in YARN UI

+Jon (Adding Jon to cc) From: Yi Pan Sent: Monday, October 2, 2017 2:10:27 AM To: dev@samza.apache.org Subject: Re: Historical container logs in YARN UI Hi, XiaoChuan, Our SRE team have been using timeline server in YARN at LinkedIn to get

[GitHub] samza pull request #302: Fixing broken link between Yarn Host Affinity and R...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/302 Fixing broken link between Yarn Host Affinity and Resource Localizati… Fixing broken link between Yarn Host Affinity and Resource Localization pages under Documentation Patch needs

[GitHub] samza pull request #301: Samza versioned Release Notes

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/301 Samza versioned Release Notes Adding a versioned page for release/upgrade notes. We can start this process from the next major version release, aka 0.14.0. Please update this page

Re: Connection timed out error while installing "Hello Samza"

oads samza from your server. Is it possible for you try on another clean host and see if it works or fails for you? Navina From: Anantharaman, Srinatha (Contractor) <srinatha_ananthara...@comcast.com> Sent: Thursday, September 14, 2017 12:33:26 PM To:

Re: Connection timed out error while installing "Hello Samza"

"localhost" or firewall that prevents communication between ports. Navina From: Yi Pan <nickpa...@gmail.com> Sent: Thursday, September 14, 2017 11:37:46 AM To: dev@samza.apache.org Subject: Re: Connection timed out error while installing "Hello Sam

Re: Connection timed out error while installing "Hello Samza"

-dist.tar.gz -C deploy/samza After this, you can follow steps in the tutorial to "Run" the example Samza job. HTH! Let me know if you need further help. Navina From: Anantharaman, Srinatha (Contractor) <srinatha_ananthara...@comcast.com> Sent: Tuesday, Se

Re: Connection timed out error while installing "Hello Samza"

le to connect. Is it possible you are behind a firewall or something? Can you try to ping "git.apache.org" ? Or try the setup on a different box? Navina From: Anantharaman, Srinatha (Contractor) <srinatha_ananthara...@comcast.com> Sen

Re: Connection timed out error while installing "Hello Samza"

uot; branch of samza-hello-samza. Thanks! Navina From: Anantharaman, Srinatha (Contractor) <srinatha_ananthara...@comcast.com> Sent: Tuesday, September 12, 2017 7:45:37 AM To: dev@samza.apache.org Subject: Connection timed out error while installing "

Re: [VOTE] SEP-8: Add in-memory system consumer & producer

t;Usage Example" Overall, +1 on this. We need this asap!!  Thanks! Navina From: xinyu liu <xinyuliu...@gmail.com> Sent: Wednesday, September 6, 2017 2:06:45 PM To: dev@samza.apache.org Subject: Re: [VOTE] SEP-8: Add in-memory system consumer

[VOTE] Apache Samza 0.13.1 RC0

Ran check-all on my Mac and it passes. +1 (binding) Thanks! Navina On Tue, Aug 22, 2017 at 4:20 PM, Fred Haifeng Ji <haifeng...@gmail.com> wrote: > +cc nav...@apache.org > > > On Tue, Aug 22, 2017 at 11:19 AM, Fred Haifeng Ji <haifeng...@gmail.com> > wrote: >

Re: [VOTE] Apache Samza 0.13.1 RC0

Ran check-all on Mac. Build looks good. +1 (binding) Thanks! Navina From: Fred Haifeng Ji <haifeng...@gmail.com> Sent: Tuesday, August 22, 2017 11:19 AM To: dev@samza.apache.org Subject: Re: [VOTE] Apache Samza 0.13.1 RC0 [You don't often get emai

[GitHub] samza pull request #274: SAMZA-1396 TestZkLocalApplicationRunner tests fails...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/274 SAMZA-1396 TestZkLocalApplicationRunner tests fails after SAMZA-1385 * Fixes ZkPath issues * Fixes appname / jobname mismatch You can merge this pull request into a Git repository by running

Re: [Discuss] Samza 0.13.1 release

Fred, Thanks for starting the release process. I am unable to open the link you have provided, though. It opens the JIRA SAMZA-1165, instead of the entire list of 0.13.1 bug fixes. Can you please re-check? Navina On 8/11/17, 6:13 PM, "ignacio.so...@gmail.com on behalf of Ignacio

Re: Kafka client.id collision

won't lose the kafka-client related metrics and there will be no overlap between the client ids. Thoughts? Thanks! Navina On Thu, Jul 20, 2017 at 9:13 AM, Jagadish Venkatraman < jagadish1...@gmail.com> wrote: > Can you share the entire log file if that's okay? The warning should be a >

Re: Samza Meetup

No worries. We would love to meet you in person too. Keep an eye out on the mailing list for the Meetup link. Cheers! Navina On Jul 20, 2017 08:37, "Renato Marroquín Mogrovejo" < renatoj.marroq...@gmail.com> wrote: > Thanks Jagadish and Navina! > I am really intereste

Re: Samza Meetup

Hi Renato, We are planning for mid-August as a tentative target for the next meetup. If you are interested in participating or speaking at the meetup, please let us know. Thanks! Navina On Tue, Jul 18, 2017 at 10:36 AM, Renato Marroquín Mogrovejo < renatoj.marroq...@gmail.com> wrote:

Re: [VOTE] SEP-5: Enable partition expansion of input streams

After a lot of Q, let's get this done :) +1 (binding) Thanks! Navina On Tue, Jun 20, 2017 at 10:31 AM, xinyu liu <xinyuliu...@gmail.com> wrote: > +1 (non-binding) on this design. > > To me the task-count based groupers should work well in practice for > partition expansion of

Re: [VOTE] SEP-5: Enable partition expansion of input streams

After a lot of Q, let's get this done :) +1 (binding) Thanks! Navina On Tue, Jun 20, 2017 at 10:31 AM, xinyu liu <xinyuliu...@gmail.com> wrote: > +1 (non-binding) on this design. > > To me the task-count based groupers should work well in practice for > partition expansion of

Re: [DISCUSS] SEP-5: Enable partition expansion of input streams

update it whenever you get to it. Thanks a bunch for your patience! Cheers! Navina On Thu, Jun 22, 2017 at 3:36 PM, Dong Lin <lindon...@gmail.com> wrote: > Hey Yi, > > Thanks for the detailed comment and the summary! > > To address your comments: >

[GitHub] samza pull request #230: SAMZA-1340 - StreamProcessor does not propagate con...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/230 SAMZA-1340 - StreamProcessor does not propagate container failures from StreamTask Storing the exception seen from the container in the `SamzaContainerListener#onFailure(Throwable

Re: [DISCUSS] SEP-5: Enable partition expansion of input streams

e why a feature needs to be "utmost priority" in order to be accepted. Can you explain a bit on that? I don't think I ever claimed that the feature needs to be of "utmost priority" to be accepted. I was just stating my opinion. Thanks! Navina On Wed, Jun 21, 2017 at 3:52 P

Re: [DISCUSS] SEP-5: Enable partition expansion of input streams

ecause it is not clear for open-source, who or which use-cases stand to benefit. I am not convinced that this problem is of utmost priority for the Samza community *at this point of time*. I am on the same page as Jake on this one. Not a +1, just a 0 (if that even matters). Thanks! Navina On Sun,

Re: [VOTE] Apache Samza 0.13.0 RC6

+1 (binding) Thanks to everyone for diligently testing out the RCs and getting this release out! Cheers! Navina On Thu, Jun 8, 2017 at 9:09 AM, Chris Riccomini <criccom...@apache.org> wrote: > +1 (binding) > > On Wed, Jun 7, 2017 at 8:55 AM, Yi Pan <nickpa...@gmail.co

Re: Wiki Spam

ns revoked except for viewing. > > > > - A samza-dev user has been created and configured to watch the Samza > > wiki space for changes > > > > Additionally, the spam pages will shortly be removed. > > > > Mark > > on behalf of the ASF infrastructure team > > > > [1] https://cwiki.apache.org/confluence/display/SAMZA/Apache+Samza > > <https://cwiki.apache.org/confluence/display/SAMZA/Apache+Samza> > > > > > > -- Navina R.

Re: Wiki Spam

Hi Mark, Thanks for letting us know. We will re-asses our permissions and set them up. Should we reach out to Gavin to set them up? It will be great to have one or more of the PMCs have access to assign permission to reduce the turn-over time. Please let us know the procedure. Thanks! Navina

Re: [DISCUSS] SEP-5: Enable partition expansion of input streams

o automatically detect new partition of the topic and reassign all (both old and new) partitions across consumers in the consumer group IF you tell consumer the topic to be subscribed. But consumer in Samza's container uses another way of subscription. Got it. Thanks! Navina On Wed, May 31, 2

Re: [DISCUSS] SEP-5: Enable partition expansion of input streams

olution for all input systems. That's my two cents. I would like to hear alternative points of view for this from other devs. Please make sure you have enough eyes on this SEP. If you do, please start a VOTE thread to approve this SEP. Thanks! Navina On Mon, May 29, 2017 at 12:32 AM, Dong Lin <l

[VOTE] Apache Samza 0.13.0 RC1

Hi everyone, This is a call for a vote on a release of Apache Samza 0.13.0. Thanks to everyone who has contributed to this release. We are very glad to see some new contributors and features in this release. The release candidate can be downloaded from here: *http://home.apache.org/~navina/samza

[GitHub] samza pull request #202: SAMZA-1307 - Fix ZkKeyBuilder null checks for pathP...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/202 SAMZA-1307 - Fix ZkKeyBuilder null checks for pathPrefix You can merge this pull request into a Git repository by running: $ git pull https://github.com/navina/samza SAMZA-1307 Alternatively

[GitHub] samza pull request #201: Updating committer page on samza.apache.org

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/201 Updating committer page on samza.apache.org Giving more screen time for currently active Apache Samza committers (no JIRA) You can merge this pull request into a Git repository by running

[GitHub] samza pull request #195: SAMZA-1128 : Remove dependency of debounce timer fr...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/195 SAMZA-1128 : Remove dependency of debounce timer from the CoordinationUtils This patch addresses the following: * Removes CoordinationUtils#getBarrier, BarrierForVersionUpgrade interface

Re: [VOTE] Apache Samza 0.13.0 RC0

tion above, can we officially cancel this vote? > > Thanks! > > -Yi > > On Mon, May 15, 2017 at 9:31 AM, Ignacio Solis <iso...@igso.net> wrote: > > > Thanks! > > > > On Mon, May 15, 2017 at 8:00 AM, Navina Ramesh > > <nram...@linkedin.com.inva

Re: [VOTE] Apache Samza 0.13.0 RC0

tion above, can we officially cancel this vote? > > Thanks! > > -Yi > > On Mon, May 15, 2017 at 9:31 AM, Ignacio Solis <iso...@igso.net> wrote: > > > Thanks! > > > > On Mon, May 15, 2017 at 8:00 AM, Navina Ramesh > > <nram...@linkedin.com.inva

Re: [DISCUSS] SEP-4: Adjunct Data Store for Unbounded DataSets

Thanks for trying 3 times, Wei. Sorry about the trouble. Not sure where the problem lies. Looking forward to review your design. Navina On Tue, May 16, 2017 at 8:56 AM, Wei Song <ws...@linkedin.com> wrote: > Hey everyone, > > I created a proposal for SAMZA-1278 > <https://i

Re: [VOTE] Apache Samza 0.13.0 RC0

I will try to get the patch out today. Work doesn't look trivial. I am on it. Navina On May 14, 2017 23:10, "Ignacio Solis" <iso...@igso.net> wrote: > We should hold off until it is solved. How long will it take to fix this? > > On Sun, May 14, 2017 at 10:13 PM, Navi

Re: [VOTE] Apache Samza 0.13.0 RC0

testing release candidate" for this release until we complete all pending tasks (includes docs, tests etc). It will also be useful to share the pending tasks and their progress. In case you have already shared it, I might have missed it since some emails are bouncing off my inbox. Thanks! Navina

[GitHub] samza pull request #179: SAMZA-1276 : Adding customReporters passed by Strea...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/179 SAMZA-1276 : Adding customReporters passed by StreamProcessor into SamzaContainer SamzaContainer is not adding custom reporters along side class-loaded reporters from config. This was missed

[GitHub] samza pull request #173: SAMZA-1272 : ZkCoordinationUtils deletes the entire...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/173 SAMZA-1272 : ZkCoordinationUtils deletes the entire Zk tree on reset * ZkCoordinationUtils has a reset interface that deletes the entire Zk tree. This is not desirable. * Also, fixed flakiness

[GitHub] samza pull request #166: SAMZA-1150 : Handling Error propagation between ZkJ...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/166 SAMZA-1150 : Handling Error propagation between ZkJobCoordinator & DebounceTimer * Treats all errors in jobcoordinator as FATAL and shuts-down the streamprocessor * [Bug] Fixed bug repo

[GitHub] samza pull request #162: SAMZA-1228 : StreamProcessor should stop JmxServer

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/162 SAMZA-1228 : StreamProcessor should stop JmxServer This is not the solution posted in SAMZA-1228. For now, we are moving jmxserver lifecycle to be within the container. Ideally, it should be within

Re: [VOTE] SEP 3 : Heart-beat mechanism between JobCoordinator and all running containers

+1 (binding) Awesome work. Cheers! Navina On Wed, May 3, 2017 at 12:01 PM, Jagadish Venkatraman < jagadish1...@gmail.com> wrote: > +1 from my side (as described in my previous email). > > Thanks for incorporating all feedback from my previous review. > > Nice work! &g

[GitHub] samza pull request #54: SAMZA-1084 - User thread does not see errors from th...

Github user navina closed the pull request at: https://github.com/apache/samza/pull/54 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

Re: [DISCUSS] SEP-3: Heart-beat mechanism between JobCoordinator and all running containers

lks about adding to container and the other about the ContainerRunner. Design looks pretty elegant and easily portable. Thanks! Navina On Wed, May 3, 2017 at 9:52 AM, Abhishek Shivanna <abks...@gmail.com> wrote: > Hey Jagadish, > > Thank you for taking the time to review the

Re: Review Request 58866: fixed SAMZA-1248. use processor id for stand alone barrier

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/58866/#review173529 --- Ship it! - Navina Ramesh On May 1, 2017, 11:24 p.m., Boris

[GitHub] samza pull request #153: SAMZA-1251 - Remove DebounceTimer dependency from Z...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/153 SAMZA-1251 - Remove DebounceTimer dependency from ZkLeaderElector Fyi: This PR depends on PR #148 You can merge this pull request into a Git repository by running: $ git pull https://github.com

Re: Review Request 58866: fixed SAMZA-1248. use processor id for stand alone barrier

/ZkJobCoordinator.java Line 65 (original), 65 (patched) <https://reviews.apache.org/r/58866/#comment246410> Why is newJobModel useful? Please add some comments as it is not very obvious. - Navina Ramesh On April 28, 2017, 11:54 p.m., Boris Shkolnik

Re: Review Request 58851: SAMZA-1212 - Refactor interaction between StreamProcessor, JobCoordinator and SamzaContainer

://reviews.apache.org/r/58851/diff/1/ Testing --- unit tests and ./gradlew clean build Thanks, Navina Ramesh

Review Request 58851: SAMZA-1212 - Refactor interaction between StreamProcessor, JobCoordinator and SamzaContainer

f37a224f64eec162e60e3a891b257175dbf4ec3c samza-test/src/test/scala/org/apache/samza/test/integration/StreamTaskTestUtil.scala 29fb6d3f6e07f356d4a25556221fa76ecdc7bf77 Diff: https://reviews.apache.org/r/58851/diff/1/ Testing --- unit tests and ./gradlew clean build Thanks, Navina Ramesh

[GitHub] samza pull request #148: SAMZA-1212 - Refactor interaction between StreamPro...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/148 SAMZA-1212 - Refactor interaction between StreamProcessor, JobCoordinator and SamzaContainer See SAMZA-1212 for motivation toward this refactoring. Changes here are: * Removed awaitStart

[GitHub] samza pull request #146: SAMZA-1224 : Revert job coordinator factory config ...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/146 SAMZA-1224 : Revert job coordinator factory config to the old format We didn't release since adding this config. So, it is ok to change the format now. You can merge this pull request into a Git

[GitHub] samza pull request #139: SAMZA-1220 : Add thread name to SamzaContainer shut...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/139 SAMZA-1220 : Add thread name to SamzaContainer shutdown hook and prevent shutdown deadlock * SamzaContainerExceptionHandler is written in Java and used by LocalContainerRunner.java You can merge

Re: [DISCUSS] SEP-2: ApplicationRunner Design

a servlet/jetty container model with its own lifecycle. If ApplicationRunner(s) is the unified interface, doesn't that prohibit Samza from being integrated with such frameworks? Thanks! Navina On Thu, Apr 20, 2017 at 10:06 AM, Jacob Maes <jacob.m...@gmail.com> wrote: > Thanks for the SEP! > &

Re: [VOTE] Samza Logo

@Renato: Thanks for your feedback. Always appreciate help from our contributors :) @Jagadish: Thanks for stating your points. It is clear that you are against the butterfly ones. But are you in support of any of the others? Please vote :) Thanks! Navina On Tue, Apr 18, 2017 at 10:38 AM

[GitHub] samza pull request #125: SAMZA-1213 - StreamProcessorLifeCycleAware interfac...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/125 SAMZA-1213 - StreamProcessorLifeCycleAware interface should not use processorId Refactoring LocalApplicationRunner s.t. each processor has its own listener instance, instead of a single listener

Re: [VOTE] Samza Logo

s an extreme change from the current one. I couldn't relate to the circular one. What are are trying to portray/imply here. That we are a bunch of disconnected links? Thanks! Navina On Fri, Apr 14, 2017 at 3:16 PM, Ignacio Solis <iso...@igso.net> wrote: > Vote directly at design crow

Re: [VOTE] Samza Logo

Hi Nacho, Do you want us to vote on this mail thread or directly at design crowd? Thanks! Navina On Fri, Apr 14, 2017 at 2:19 PM, Ignacio Solis <iso...@igso.net> wrote: > Hi folks. > > After some feedback and culling, we are down to 4 candidates. Please > vote on your fa

[GitHub] samza pull request #121: SAMZA-1208 - IllegalFormatConversionException in Lo...

GitHub user navina reopened a pull request: https://github.com/apache/samza/pull/121 SAMZA-1208 - IllegalFormatConversionException in LocalContainerRunner You can merge this pull request into a Git repository by running: $ git pull https://github.com/navina/samza SAMZA-1208

[GitHub] samza pull request #121: SAMZA-1208 - IllegalFormatConversionException in Lo...

Github user navina closed the pull request at: https://github.com/apache/samza/pull/121 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] samza pull request #121: SAMZA-1208 - IllegalFormatConversionException in Lo...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/121 SAMZA-1208 - IllegalFormatConversionException in LocalContainerRunner You can merge this pull request into a Git repository by running: $ git pull https://github.com/navina/samza SAMZA-1208

Re: Samza Logo designs

e response. Thanks! Navina On Sun, Apr 9, 2017 at 1:11 PM, Ignacio Solis <iso...@igso.net> wrote: > I'll leave this open one more day for feedback. Then wait a couple of > days for redesigns, then do a final round. > > On Fri, Apr 7, 2017 at 1:11 PM, Ignacio Solis <iso..

[GitHub] samza pull request #112: Samza-1187 : TestZkProcessorLatch tests share state...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/112 Samza-1187 : TestZkProcessorLatch tests share state causing transient failures in CI builds * Removed testSingleCountdown - didn't understand what was being tested * The timeout behavior

[RESULT] [VOTE] SEP-1: Semantics of ProcessorId in Samza

Hi everyone, The vote on SEP-1 passes with 7 +1 votes (3 binding) and no -1. Votes are as follows: +1 (binding) - Navina Ramesh, Yi Pan, Yan Fang +1 (non-binding) - Boris Shkolnik, Xinyu Liu, Renato Marroquin Mogrovejo, Ignacio Solis The following are the discuss and vote mail threads: DISCUSS

Re: [VOTE] SEP-1: Semantics of ProcessorId in Samza

+1 (binding) from me :) Navina On Sun, Apr 2, 2017 at 9:31 PM, Ignacio Solis <iso...@igso.net> wrote: > +1 (non binding) > > May this be the first of many SEPs... I mean just as many as needed. :-) > > Nacho > > On Sat, Apr 1, 2017 at 1:03 PM, Kart

[GitHub] samza pull request #107: SAMZA-1182 - Commenting out some of the flaky tests

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/107 SAMZA-1182 - Commenting out some of the flaky tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/navina/samza SAMZA-1182 Alternatively you

Re: [VOTE] SEP-1: Semantics of ProcessorId in Samza

ally well for stateless applications, I believe. Cheers! Navina On Thu, Mar 30, 2017 at 1:23 PM, Renato Marroquín Mogrovejo < renatoj.marroq...@gmail.com> wrote: > Hi Navina, > > Thanks for the great proposal! Having the big proposals documented on SEPs > is really great t

Re: Steps to Upgrading Samza (0.9 to 0.12)

upgrade without any issues. Upgrade from 0.9 to 0.10 is an exceptional case. Happy to help you out in case you encounter more issues. Cheers! Navina On Thu, Mar 30, 2017 at 11:04 AM, XiaoChuan Yu <xiaochuan...@kik.com> wrote: > Is there some sort of document on how to upgrade Samza t

Re: [VOTE] SEP-1: Semantics of ProcessorId in Samza

to a runtime environment. Hence, it seems more appropriate to move it to a lower abstraction layer that deals with the underlying execution environment. Let me know if you have a different perspective on this. Cheers! Navina On Thu, Mar 30, 2017 at 9:42 AM, Yi Pan <nickpa...@gmail.com> wrote: >

Re: [VOTE] SEP-1: Semantics of ProcessorId in Samza

Good to hear from you, Yan. Thanks! :) On Wed, Mar 29, 2017 at 7:48 PM, Yan Fang <yanfang...@gmail.com> wrote: > +1 . Thanks for the proposal, Navina. :) > > Fang, Yan > yanfang...@gmail.com > > On Thu, Mar 30, 2017 at 4:24 AM, Prateek Maheshwari < > pmaheshw.

[GitHub] samza pull request #103: SAMZA-1126 - Semantics of processorId in Samza

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/103 SAMZA-1126 - Semantics of processorId in Samza Implementation based on [SEP-1](https://cwiki.apache.org/confluence/display/SAMZA/SEP-1%3A+Semantics+of+ProcessorId+in+Samza) You can merge

[GitHub] samza pull request #102: SAMZA-1175 - Removing CoordinationService from JobC...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/102 SAMZA-1175 - Removing CoordinationService from JobCoordinatorFactory interface @sborya I have made the changes. Please review. Thanks! You can merge this pull request into a Git repository

Re: [VOTE] SEP-1: Semantics of ProcessorId in Samza

Thanks, Xinyu. I have already implemented a draft. Waiting for the voting to close soon. Navina On Tue, Mar 28, 2017 at 2:17 PM, Boris S <bor...@gmail.com> wrote: > +1 Looks good to me. > > On Tue, Mar 28, 2017 at 2:00 PM, xinyu liu <xinyuliu...@gmail.com> wrote: > >

[VOTE] SEP-1: Semantics of ProcessorId in Samza

/201703.mbox/%3CCANazzuuHiO%3DvZQyFbTiYU-0Sfh3riK%3Dz4j_AdCicQ8rBO%3DXuYQ%40mail.gmail.com%3E Please vote on this SEP asap. :) Thanks! Navina

Re: Steps to Upgrading Samza (0.9 to 0.12)

managers, the migration may be more involved. Please let us know and we can try to help you out. Feel free to email us if you have more questions. Cheers! Navina On Mon, Mar 27, 2017 at 10:07 AM, Jagadish Venkatraman < jagadish1...@gmail.com> wrote: > Good observation Jake! > > The cod

Re: [DISCUSS] SEP-1: Semantics of ProcessorId in Samza

ing and instance creation? Cheers! Navina On Fri, Mar 24, 2017 at 11:06 AM, Prateek Maheshwari < pmaheshw...@linkedin.com> wrote: > Hi Navina, > > 1. Assuming the environment can put the processor ID in the config, > ProcessorIdGenerator#generateProcessorId(Config config) makes

Re: [DISCUSS] SEP-1: Semantics of ProcessorId in Samza

Hi everyone, I have updated the SEP <https://cwiki.apache.org/confluence/display/SAMZA/SEP-1%3A+Semantics+of+ProcessorId+in+Samza> based on all the feedback. Feel free to comment. I will start the [vote] mail thread, if there are no further questions within the next 24 hours. Thanks!

Re: [DISCUSS] SEP-1: Semantics of ProcessorId in Samza

Hi everyone, I have updated the SEP <https://cwiki.apache.org/confluence/display/SAMZA/SEP-1%3A+Semantics+of+ProcessorId+in+Samza> based on all the feedback. Feel free to comment. I will start the [vote] mail thread, if there are no further questions within the next 24 hours. Thanks!

Re: [DISCUSS] SEP-1: Semantics of ProcessorId in Samza

120. <https://issues.apache.org/jira/browse/SAMZA-1120> I will send out an update once I change the SEP based on yesterday's meeting and Jagadish's idea. Thanks! Navina On Mon, Mar 20, 2017 at 5:22 PM, Jagadish Venkatraman < jagadish1...@gmail.com> wrote: > Thanks for writ

Re: [DISCUSS] Support Scala 2.12

Thanks for creating the DISCUSS email! This is good. It's a good idea to update to 2.12 since it looks like we are fully backward compatible with older versions. +1 from me. Cheers! Navina On Fri, Mar 17, 2017 at 1:34 PM, Jagadish Venkatraman < jagadish1...@gmail.com> wrote: &g

Re: [DISCUSS] SEP-1: Semantics of ProcessorId in Samza

e client to use. > > I am working on the ApplicationRunner SEP right now. Will send out the > discussion email once I am done. > > Thanks, > Xinyu > > On Thu, Mar 16, 2017 at 4:50 PM, Navina Ramesh (Apache) <nav...@apache.org > > > wrote: > > > > One m

Re: [DISCUSS] SEP-1: Semantics of ProcessorId in Samza

r design. It will be great if you can put it out in an SEP :) I can add the static factory method for it. Just to clarify, the static method simply class loads the ProcessorIdGenerator ? It uses reflection to create the instance ? Thanks! Navina On Thu, Mar 16, 2017 at 4:31 PM, xinyu liu <

Re: [DISCUSS] SAMZA-1141 - Apache Samza Development Process Improvements

Xinyu, I considered doing that as an example. But I want to keep SEP to be only for technical discussions and not process related proposals. Navina On Mar 14, 2017 17:23, "xinyu liu" <xinyuliu...@gmail.com> wrote: > +1 on this proposal too. Could you actually put this pr

Re: [DISCUSS] SAMZA-1141 - Apache Samza Development Process Improvements

Just to clarify: The proposal for code and design process change is attached as a PDF/markdown to the JIRA - SAMZA-1141. Also, please show your support specifically for code and design process. My bad for not calling it out earlier :) Thanks! Navina On Tue, Mar 14, 2017 at 3:30 PM, Jagadish

[GitHub] samza pull request #54: SAMZA-1084 - User thread does not see errors from th...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/54 SAMZA-1084 - User thread does not see errors from the processor thread Adding a ProcessorLifecycleCallback for specifying user-defined error handling You can merge this pull request into a Git

Re: [VOTE] Apache Samza 0.12.0 RC2

I ran check-all against Mac and integration tests on Linux. Looks good with no concerning issues. +1 (binding) Thanks! Navina On Fri, Feb 10, 2017 at 9:25 AM, Boris S <bor...@gmail.com> wrote: > I also successfully ran the integration tests on Linux. All passed. > +1 non-bindin

[GitHub] samza pull request #48: SAMZA-1082 : Implement Leader Election using ZK

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/48 SAMZA-1082 : Implement Leader Election using ZK Simple implementation of leader election recipe along with unit tests You can merge this pull request into a Git repository by running: $ git pull

Re: Review Request 52570: SAMZA-1025: documentation for hdfs system consumer

an emphasize the reserved term note by doing -> **note** , when it is outside the code block docs/learn/documentation/versioned/jobs/configuration-table.html (line 1822) <https://reviews.apache.org/r/52570/#comment234763> Look like a typo. It should "systems.*, instead of &quo

Re: Review Request 52570: SAMZA-1025: documentation for hdfs system consumer

't matter. (X & whitelist) - blacklist == (X - blacklist) > & whitelist This is assuming that whitelist and blacklist are mutually exclusive, right? - Navina --- This is an automatically

Re: Review Request 52570: SAMZA-1025: documentation for hdfs system consumer

> On Jan. 25, 2017, 10:50 p.m., Navina Ramesh wrote: > > docs/learn/documentation/versioned/hdfs/consumer.md, line 26 > > <https://reviews.apache.org/r/52570/diff/2/?file=1613256#file1613256line26> > > > > Can you include the diagram from your design doc

Re: Review Request 52570: SAMZA-1025: documentation for hdfs system consumer

Looks like there are more configurations that are mentioned in the configuration table. Can you please add the link to configuration table to imply that? docs/learn/documentation/versioned/hdfs/consumer.md (line 105) <https://reviews.apache.org/r/52570/#comment234466> You can add

Upcoming Stream Processing Meetup in February!

Benchmarks for Apache Kafka (Mingmin Chen, Uber) - 7:55-8:30 PM: Batching to Streaming Analytics at Optimizely (Vignesh Sukumar, Optimizely) Hope to see you there! Cheers! -- Navina R.

[GitHub] samza pull request #44: Initial Standalone JobCoordinator and StreamProcesso...

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/44 Initial Standalone JobCoordinator and StreamProcessor API This patch contains changes associated with the Standalone StreamProcessor, where there is no coordination. This will work for load-balanced

Re: [DISCUSS] Samza 0.12.0 release

+1 Navina On Fri, Dec 23, 2016 at 2:53 PM, xinyu liu <xinyuliu...@gmail.com> wrote: > +1 on the new release. > > Thanks, > Xinyu > > On Fri, Dec 23, 2016 at 2:50 PM, Yi Pan <nickpa...@gmail.com> wrote: > > > Yep! Thanks for pointing it out! @Shanthoosh,

[GitHub] samza pull request #27: Adding Build Status to README.md

GitHub user navina opened a pull request: https://github.com/apache/samza/pull/27 Adding Build Status to README.md I setup a Jenkins Build Job to get triggered every time changes are pushed to samza repository. https://builds.apache.org/view/S-Z/view/Samza/job/samza-freestyle

  1   2   3   4   5   >