Hey Jason,
If you configure log4j as described here:
http://samza.apache.org/learn/documentation/0.9/jobs/logging.html
<http://samza.apache.org/learn/documentation/0.9/jobs/logging.html>
Your log statements will wind up in the samza-container logs which you can get
to via the application master gui.
hth,
Rick
> On Jun 26, 2015, at 1:39 PM, ja...@marketingscience.co wrote:
>
> Hello,
>
>
> I am working on a basic Samza task that pulls from one Kafka topic and writes
> to another. This task runs in Yarn but the Output topic does not contain any
> data.
>
>
> In order to troubleshoot this more effectively I would like to log the
> incoming message as my example below. Ideally, I would like to be able to see
> the log messages in Yarn, maybe in the .out files in the /logs directory.
>
>
> Any advice is appreciated.
>
>
>
> Here is my task:
>
>
> package com.project.samza.tasks;
>
>
> import java.util.Map;
> import org.apache.samza.system.IncomingMessageEnvelope;
> import org.apache.samza.system.OutgoingMessageEnvelope;
> import org.apache.samza.system.SystemStream;
> import org.apache.samza.task.MessageCollector;
> import org.apache.samza.task.StreamTask;
> import org.apache.samza.task.TaskCoordinator;
>
>
> public class exampleStreamTask implements StreamTask {
> private static final SystemStream OUTPUT_STREAM = new SystemStream(“kafka”,
> “new-topic-test”);
>
>
> @Override
> public void process(IncomingMessageEnvelope envelope,
> MessageCollector collector,
> TaskCoordinator coordinator) {
> String msg = (String) envelope.getMessage();
> System.out.println(msg);
> collector.send(new OutgoingMessageEnvelope(OUTPUT_STREAM, msg));
> }
> }
>
>
> Thanks,
>
>
> Jason
