[
https://issues.apache.org/jira/browse/SAMZA-197?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jakob Homan updated SAMZA-197:
------------------------------
Attachment: SAMZA-197-2.patch
bq. The JSON work is probably only a few lines of work.
Yeah, but those fine lines sucked. Jackson really, really hates Scala.
Here's a patch that switches to JSON encoding. Unit tests pass, although I had
two failures of TestStatefulTask. After running clean and jumping back and
forth from master to the branch, it worked again. I don't see how this fix
would make TestStatefulTask flakey, as this code is quite deterministic, so I'm
thinking the flakiness is already there.
> Use JSON rather than custom encoding for container SSPs
> -------------------------------------------------------
>
> Key: SAMZA-197
> URL: https://issues.apache.org/jira/browse/SAMZA-197
> Project: Samza
> Issue Type: Bug
> Components: hello-samza
> Reporter: Martin Kleppmann
> Assignee: Jakob Homan
> Attachments: SAMZA-197-2.patch, SAMZA-197.patch
>
>
> {noformat}
> Exception in thread "main" java.lang.IllegalArgumentException:
> SystemStreamPartition [partition=Partition [partition=0], system=wikipedia,
> stream=#en.wiktionary] contains illegal character #
> {noformat}
> SAMZA-194 broke hello-samza, since the wikipedia-feed job has the following
> config:
> {noformat}
> task.inputs=wikipedia.#en.wikipedia,wikipedia.#en.wiktionary,wikipedia.#en.wikinews
> {noformat}
> and hashes are now _verboten_. :(
--
This message was sent by Atlassian JIRA
(v6.2#6252)