[
https://issues.apache.org/jira/browse/SAMZA-1247?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15995975#comment-15995975
]
ASF GitHub Bot commented on SAMZA-1247:
---------------------------------------
GitHub user prateekm opened a pull request:
https://github.com/apache/samza/pull/159
SAMZA-1247: MessageStreamImpl#merge shouldn't mutate input collection
Also fixes
SAMZA-1253: MessageStream.merge operator broken for nested types
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/prateekm/samza merge-fixes
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/159.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #159
----
commit fe3700e04baa68e90dd14efdba136a39ac3be61f
Author: Prateek Maheshwari <[email protected]>
Date: 2017-05-04T00:40:15Z
SAMZA-1247: MessageStreamImpl#merge shouldn't assume that the input
collection is mutable
----
> MessageStreamImpl#merge shouldn't assume that the input collection is mutable
> -----------------------------------------------------------------------------
>
> Key: SAMZA-1247
> URL: https://issues.apache.org/jira/browse/SAMZA-1247
> Project: Samza
> Issue Type: Bug
> Reporter: Prateek Maheshwari
> Assignee: Prateek Maheshwari
> Fix For: 0.13.0
>
>
> {code}
> Exception in thread "main" org.apache.samza.SamzaException: Failed to run
> application
> at
> org.apache.samza.runtime.RemoteApplicationRunner.run(RemoteApplicationRunner.java:64)
> at
> org.apache.samza.runtime.ApplicationRunnerMain.main(ApplicationRunnerMain.java:67)
> Caused by: java.lang.UnsupportedOperationException
> at java.util.AbstractList.add(AbstractList.java:148)
> at java.util.AbstractList.add(AbstractList.java:108)
> at
> org.apache.samza.operators.MessageStreamImpl.merge(MessageStreamImpl.java:189)
> at
> samza.examples.wikipedia.application.WikipediaApplication.init(WikipediaApplication.java:39)
> at
> org.apache.samza.runtime.AbstractApplicationRunner.getExecutionPlan(AbstractApplicationRunner.java:100)
> at
> org.apache.samza.runtime.RemoteApplicationRunner.run(RemoteApplicationRunner.java:52)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
