diff --git a/core/src/main/java/com/dtstack/flink/sql/side/BaseSideInfo.java b/core/src/main/java/com/dtstack/flink/sql/side/BaseSideInfo.java index c32e72504..8579afe8f 100644 --- a/core/src/main/java/com/dtstack/flink/sql/side/BaseSideInfo.java +++ b/core/src/main/java/com/dtstack/flink/sql/side/BaseSideInfo.java @@ -24,7 +24,12 @@ import com.google.common.base.Preconditions; import com.google.common.collect.Lists; import com.google.common.collect.Maps; -import org.apache.calcite.sql.*; +import org.apache.calcite.sql.JoinType; +import org.apache.calcite.sql.SqlBasicCall; +import org.apache.calcite.sql.SqlIdentifier; +import org.apache.calcite.sql.SqlKind; +import org.apache.calcite.sql.SqlLiteral; +import org.apache.calcite.sql.SqlNode; import org.apache.calcite.util.NlsString; import org.apache.flink.api.java.typeutils.RowTypeInfo; import org.apache.flink.table.runtime.typeutils.BaseRowTypeInfo; @@ -218,22 +223,6 @@ private void checkSupport(SqlIdentifier identifier) { Preconditions.checkState(isSide, errorMsg); } - private void checkSupport(SqlIdentifier identifier) { - String tableName = identifier.getComponent(0).getSimple(); - String sideTableName; - String sideTableAlias; - if (joinInfo.isLeftIsSideTable()) { - sideTableName = joinInfo.getLeftTableName(); - sideTableAlias = joinInfo.getLeftTableAlias(); - } else { - sideTableName = joinInfo.getRightTableName(); - sideTableAlias = joinInfo.getRightTableAlias(); - } - boolean isSide = tableName.equals(sideTableName) || tableName.equals(sideTableAlias); - String errorMsg = "only support set side table constant field, error field " + identifier; - Preconditions.checkState(isSide, errorMsg); - } - private void associateField(String sourceTableField, String sideTableField, SqlNode sqlNode) { String errorMsg = "can't deal equal field: " + sqlNode; equalFieldList.add(sideTableField); diff --git a/docs/quickStart.md b/docs/quickStart.md index a5bf1fa9a..8b5f3db24 100644 --- a/docs/quickStart.md +++ b/docs/quickStart.md @@ -1,3 +1,8 @@ +# 通知!!! +因该项目与FlinkX项目合并统一,即 2021-07-01 起, 1.12.x 版本之后,项目迁移到 FlinkX 项目中。 + +FlinkStreamSQL 项目推荐使用版本 1.10_release(为最新稳定版本)。 + ### 1.1 运行模式 * 本地模式:通常用于本地开发调试(--mode:local)