[hotfix] [tableAPI] Throw helpful exception for unsupported outer joins.

is · May 23, 2016 · 53949d1 · 53949d1
1 parent 905ac6e
commit 53949d1
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetJoinRule.scala b/...-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetJoinRule.scala
@@ -24,6 +24,7 @@ import org.apache.calcite.rel.convert.ConverterRule
 import org.apache.calcite.rel.core.JoinRelType
 import org.apache.calcite.rel.logical.LogicalJoin
 import org.apache.flink.api.java.operators.join.JoinType
+import org.apache.flink.api.table.TableException
 import org.apache.flink.api.table.plan.nodes.dataset.{DataSetJoin, DataSetConvention}
 
 import scala.collection.JavaConversions._
@@ -44,6 +45,9 @@ class DataSetJoinRule
  val hasValidCondition = !joinInfo.pairs().isEmpty
  // only inner joins are supported at the moment
  val isInnerJoin = join.getJoinType.equals(JoinRelType.INNER)
+ if (!isInnerJoin) {
+ throw new TableException("OUTER JOIN is currently not supported.")
+ }
 
  // check that condition is valid and inner join
  hasValidCondition && isInnerJoin