[
https://issues.apache.org/jira/browse/SAMZA-1167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jake Maes resolved SAMZA-1167.
------------------------------
Resolution: Fixed
Fix Version/s: 0.13.0
Issue resolved by pull request 101
[https://github.com/apache/samza/pull/101]
> New streamId-specific configs do not override equivalent system-scoped configs
> ------------------------------------------------------------------------------
>
> Key: SAMZA-1167
> URL: https://issues.apache.org/jira/browse/SAMZA-1167
> Project: Samza
> Issue Type: Bug
> Reporter: Jake Maes
> Assignee: Jake Maes
> Fix For: 0.13.0
>
>
> Thanks to [[email protected]] for finding this.
> Test Case:
> With the following config, the json key serde is not used
> {noFormat}
> job.factory.class=org.apache.samza.job.local.ThreadJobFactory
> job.name=wikipedia-parser
> app.class=org.apache.samza.test.integration.TestSessionizerApplication
> serializers.registry.json.class=org.apache.samza.serializers.JsonSerdeFactory
> serializers.registry.string.class=org.apache.samza.serializers.StringSerdeFactory
> streams.page-views.samza.key.serde=json
> streams.page-views.samza.msg.serde=string
> streams.page-views.samza.system=kafka
> systems.kafka.samza.factory=org.apache.samza.system.kafka.KafkaSystemFactory
> systems.kafka.consumer.zookeeper.connect=localhost:54567
> systems.kafka.consumer.auto.offset.reset=largest
> systems.kafka.producer.bootstrap.servers=localhost:54570
> systems.kafka.samza.msg.serde=string
> systems.kafka.samza.key.serde=string
> systems.kafka.samza.offset.default=oldest
> job.coordinator.system=kafka
> job.coordinator.replication.factor=1
> task.window.ms=1000
> {noFormat}
> {noFormat}
> StreamSpec streamSpec = new StreamSpec("page-views", "PageViewEvent",
> "kafka");
> {noFormat}
> Bug:
> SamzaContainer uses getSerdeStreams() to get a list of the streams that have
> custom serdes and that method doesn’t pick up the overrides. So, it never
> asks for the system specific properties.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
