From 53949d13a4a336ab7faaff39e4177a9049c9a32f Mon Sep 17 00:00:00 2001 From: Fabian Hueske Date: Mon, 23 May 2016 14:05:09 +0200 Subject: [PATCH] [hotfix] [tableAPI] Throw helpful exception for unsupported outer joins. --- .../flink/api/table/plan/rules/dataSet/DataSetJoinRule.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetJoinRule.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetJoinRule.scala index f3bd402fd01ac..a4aa0a8746a91 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/plan/rules/dataSet/DataSetJoinRule.scala +++ b/flink-libraries/flink-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