---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/37817/
---
(Updated Sept. 2, 2015, 9:33 p.m.)
Review request for samza, Yan Fang, Chinmay
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/37817/#review97517
---
samza-yarn/src/test/java/org/apache/samza/job/yarn/TestSamzaTaskMan
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/37817/
---
(Updated Sept. 2, 2015, 7:17 p.m.)
Review request for samza, Yan Fang, Chinmay
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/37817/
---
(Updated Sept. 2, 2015, 7:17 p.m.)
Review request for samza, Yan Fang, Chinmay
We have one container for each partition, we are not providing any partition
key.
messageCollector.send(new OutgoingMessageEnvelope(output_stream_1, "this is for
you"));
messageCollector.send(new OutgoingMessageEnvelope(output_stream_2, "this is
for the other guy"));
this was an example, the
Hi, Elangovan,
Could you confirm how many containers in your job? And how is the outgoing
messages partitioned on? Most likely, this is related to the choice on the
outgoing message partition key, which is the only deciding factor for which
partition of a topic the message is sent to.
-Yi
On Wed
You need to fix your line endings from Windows to Unix format.
Lukas
-Original Message-
From: Raja.Aravapalli
Sent: Wednesday, September 2, 2015 6:48 AM
To: dev@samza.apache.org
Subject: run-job.sh
Hi Team,
When I submit the job using "samza-shell/src/main/bash/run-job.sh"
I am get
Hi Team,
When I submit the job using "samza-shell/src/main/bash/run-job.sh"
I am getting the error:
bash: samza-shell/src/main/bash/run-job.sh: /bin/bash^M: bad interpreter: No
such file or directory
please help me fixing this
Regards,
Raja Mahesh Aravapalli.
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/38049/
---
Review request for samza.
Repository: samza
Description
---
Replaced dep
The task consumes from one stream with 2 partitions.
-Original Message-
From: Garry Turkington [mailto:g.turking...@improvedigital.com]
Sent: Wednesday, September 02, 2015 1:12 PM
To: dev@samza.apache.org
Subject: RE: One task sending payload to multiple output streams
Hi,
How many inp
Hi,
How many input streams does this task consume and how are they partitioned?
Garry
-Original Message-
From: Balusamy, Elangovan [mailto:elangovan.balus...@altisource.com]
Sent: 02 September 2015 08:19
To: dev@samza.apache.org
Cc: Chandra, Saurabh
Subject: One task sending payload to
Folks,
We are running a multi-node Samza cluster with multiple partitions for each
task. In one of the tasks, we would like to send output to two different tasks
and the payload also is different. Below is the code that does it
messageCollector.send(new OutgoingMessageEnvelope(output_stream_1,
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/38043/
---
Review request for samza.
Repository: samza
Description
---
Updated down
13 matches
Mail list logo
