GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/1297
[hotfix] Fix Mutable Object window aggregator/Disable Object Copy
This fixes the aggregators to make copies of the objects so that it
works with window operators that are not mutable-object safe.
This also disables object copy in WindowOperator and
NonKeyedWindowOperator.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink window-mut-agg-fix
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1297.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 #1297
----
commit b834ce2fb94960f869009b96a4042ea989b38baf
Author: Aljoscha Krettek <[email protected]>
Date: 2015-10-23T10:48:02Z
Add copy() to Tuple base class.
commit 93eb97d42264f931615b5905d041cf0fe2822e12
Author: Aljoscha Krettek <[email protected]>
Date: 2015-10-23T11:08:35Z
[hotfix] Fix Mutable Object window aggregator/Disable Object Copy
This fixes the aggregators to make copies of the objects so that it
works with window operators that are not mutable-object safe.
This also disables object copy in WindowOperator and
NonKeyedWindowOperator.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
