[ https://issues.apache.org/jira/browse/BEAM-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kasia Kucharczyk resolved BEAM-6397. ------------------------------------ Resolution: Fixed Fix Version/s: 2.10.0 > Add KeyValue attribute to SyntheticDataPubSubPublisher > ------------------------------------------------------ > > Key: BEAM-6397 > URL: https://issues.apache.org/jira/browse/BEAM-6397 > Project: Beam > Issue Type: Improvement > Components: testing > Reporter: Kasia Kucharczyk > Assignee: Kasia Kucharczyk > Priority: Minor > Fix For: 2.10.0 > > Time Spent: 40m > Remaining Estimate: 0h > > Currently SyntheticDataPubSubPublisher sends only synthetic elements > converted to ByteArray to PubSub. To perform KeyValue tranforms (such us > GroupByKey) on PubSub source I propose to send generated synthetic data as > Map via attributes parameter in PubsubMessage object. > Also it is required to fix NoClassDefFoundError (details in comment). -- This message was sent by Atlassian JIRA (v7.6.3#76005)