samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Boris Shkolnik" <>
Subject Review Request 39999: SAMZA-805. use full config in case of ProcessJob
Date Fri, 06 Nov 2015 01:53:26 GMT

This is an automatically generated e-mail. To reply, visit:

Review request for samza.

Bugs: SAMZA-805

Repository: samza


Currently we strip the config of all the values, except the ones required by jobCoordinator.
But in case of ProcessJob, the process is created before the configs are read from coordinator
It causes ProcessJob process to miss all the task.opts settings (like heap size, or debug).
Fix: use full config in case of ProcessJob.
Environment for commandShell will pick only required fields from the config, including task.opts
and java.home.


  samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala 4fac154709d72ab594485dad93c912b55fb1617e



Tested manually by setting some non-default values into task.opts and verifying that the local
process picked it up.


Boris Shkolnik

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message