diff --git a/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala b/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala
index d1233e69da0f2825bf44b5a05f0d3aa6c7ec4804..783d976f8da7637f93cda46ccbad0342107dc8ca 100644
--- a/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala
+++ b/flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala
@@ -88,6 +88,13 @@ class DataSet[T: ClassTag](set: JavaDataSet[T]) {
    */
   def getType: TypeInformation[T] = set.getType
 
+  /**
+   * Returns the execution environment associated with the current DataSet.
+   * @return associated execution environment
+   */
+  def getExecutionEnvironment: ExecutionEnvironment = new ExecutionEnvironment(set
+    .getExecutionEnvironment)
+
   /**
    * Returns the underlying Java DataSet.
    */