Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/227#discussion_r20788430
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/CollectionEnvironment.java
---
@@ -24,13 +24,11 @@
public class CollectionEnvironment extends ExecutionEnvironment {
- private boolean mutableObjectSafeMode = true;
--- End diff --
We actually want to make the execution mode configurable with a setter
method, so this would actually be god to stay.
We are thinking about how to do the configuration:
- A set of setters
- A configuration/parameter object
I am leaning towards the second option, because we will have many more
things to configure (closure cleaning, custom serializers, file system modes,
mutable object modes)
---
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.
---
