Chris Riccomini created SAMZA-145:
-------------------------------------
Summary: Bootstrap config doesn't work
Key: SAMZA-145
URL: https://issues.apache.org/jira/browse/SAMZA-145
Project: Samza
Issue Type: Bug
Components: container
Affects Versions: 0.6.0
Reporter: Chris Riccomini
Assignee: Chris Riccomini
Setting a stream as a bootstrap stream is ignored by Samza. This is because of
this line in DefaultChooserConfig:
{code}
def getBootstrapStreams = config
.getInputStreams
.map(systemStream => (systemStream, getOrElse(BOOTSTRAP format
(systemStream.getSystem, systemStream.getStream), "false").equals("true")))
.filter(_._2.equals("true"))
.map(_._1)
{code}
The filter should be .equals(true), not as a string.
--
This message was sent by Atlassian JIRA
(v6.1.5#6160)
