shouldn't you send to dev-subscr...@samza.apache.org ? :)
Fang, Yan
yanfang...@gmail.com
On Wed, Aug 12, 2015 at 12:33 PM, Eli Reisman
wrote:
> subscribe
>
subscribe
Hi, Jordi,
I see your use case now. Essentially, you want to have an adjunct data
bootstrap into a Samza job which will consume a stream and do a
stream-table join w/ the pre-loaded adjunct data in the store. We have
plenty of these kind of use case in LinkedIn. If your adjunct data set is
small a
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36006/#review94992
---
samza-autoscaling/src/main/java/org/apache/samza/autoscaling/deploy
Dear All:
I am trying to install Amazon on AWS. I do some research online. It
looks like I could deploy Kafka, Zookeeper, and YARN and then Samza job on
AWS or
I could deploy confluence platform and then zookeeper, Kafkaand the
Samza.
Can any tell me Which way you use? which way is bette
Hi,
What I am trying to develop is (I think) an evolution of the Stream-table join.
For every message processed, depending on the value a variable contained on it
go to the store and decide to which topic it must be sent. It is some kind of
workflow manager (very simple). I can read from a stor
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34974/#review94980
---
Ship it!
Ship It!
- Navina Ramesh
On July 29, 2015, 10:49 p.m.,
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34974/#review93553
---
Lgtm, overall! I was able to test it as well.
Some feedback: Would i
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/36006/
---
(Updated Aug. 11, 2015, 6:38 p.m.)
Review request for samza, Yi Pan (Data Infra
Hi, Jordi,
The local KV-store is meant to be accessed by the Samza container locally
on the machine. If you were referring to the use case that the local
KV-store is accessed by a container from a different Samza job, it is not
supported. And what does it exactly mean when you say "load the DB to
InitableTask tas kwas missing. That responds to another problem that I was
experiencing (and left for later). Anyway the exception was still there until I
commented the changelog definition line in the properties file:
#stores.test12db.changelog=kafka.test12db-changelog
As I understand it in ca
11 matches
Mail list logo