GitHub user lofifnc opened a pull request:
https://github.com/apache/flink/pull/1120
Getter for wrapped StreamExecutionEnvironment by scala api
Currently it is not possible to pass an ExecutionEnvironment defined with
the scala api to a method working with the
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.
Added a getter to the scala api StreamExecutionEnvironment for java scala
interoperability.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lofifnc/flink getter-for-stream-environment
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1120.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 #1120
----
commit 6d2f16a1ce34f720f4a26ce99deb6480e29afe80
Author: Alexander Kolb <[email protected]>
Date: 2015-09-11T09:23:27Z
added getter for wrapped environment
commit a11249c66b3995083a0c91af8ba4bd168fcf0ac5
Author: Alexander Kolb <[email protected]>
Date: 2015-09-11T09:31:48Z
renamed method
----
---
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.
---
