> On June 17, 2015, 12:25 a.m., Navina Ramesh wrote: > > samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamWriter.java, > > line 41 > > <https://reviews.apache.org/r/35241/diff/1/?file=981202#file981202line41> > > > > Can you add a .sh wrapper using run-job to actually run the job from > > command line? > > Take a look at samza-shell/src/main/bash/checkpoint-tool.sh. You can > > follow a similar pattern to run the CoordinatorStreamWriter class.
added run-coordinator-stream-writer.sh script - Shadi ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35241/#review88174 ----------------------------------------------------------- On June 29, 2015, 11:08 p.m., Shadi A. Noghabi wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/35241/ > ----------------------------------------------------------- > > (Updated June 29, 2015, 11:08 p.m.) > > > Review request for samza, Yi Pan (Data Infrastructure), Navina Ramesh, and > Naveen Somasundaram. > > > Repository: samza > > > Description > ------- > > In order to be able to change configurations while a job is running, a tool > for writing a message to the coordinator stream is needed. This code targets > creating such a tool that can write messages to the coordinator stream after > the bootstrap of the job. This code is related to the SAMZA-704 JIRA. > > > To run the code use the following command: > > {path to samza deployment}/samza/bin/run-coordinator-stream-writer.sh > --config-factory={config-factory} --config-path={path to config file of a > job} --type={type of the message} --key={[optional] key of the message} > --value={[optional] value of the message} > > > Diffs > ----- > > checkstyle/import-control.xml 3374f0c432e61ac4cda275377604cfd481f0cddf > > samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamMessage.java > 6c1e488d00d8593d59c89b57e673e0b6b90fd7d2 > > samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamWriter.java > PRE-CREATION > > samza-core/src/main/scala/org/apache/samza/coordinator/stream/CoordinatorStreamWriterCommandLine.scala > PRE-CREATION > > samza-core/src/test/java/org/apache/samza/coordinator/stream/MockCoordinatorStreamSystemFactory.java > 647cadb3a4e51bec8204197d77ad35a6b29afcec > > samza-core/src/test/java/org/apache/samza/coordinator/stream/TestCoordinatorStreamSystemProducer.java > 68e32554c18f443565284b807f43f4a5b05afbce > > samza-core/src/test/java/org/apache/samza/coordinator/stream/TestCoordinatorStreamWriter.java > PRE-CREATION > samza-shell/src/main/bash/run-coordinator-stream-writer.sh PRE-CREATION > > Diff: https://reviews.apache.org/r/35241/diff/ > > > Testing > ------- > > To run the code use the following command: > > {path to samza deployment}/samza/bin/run-coordinator-stream-writer.sh > --config-factory={config-factory} --config-path={path to config file of a > job} --type={type of the message} --key={[optional] key of the message} > --value={[optional] value of the message} > > > Thanks, > > Shadi A. Noghabi > >
