Skip to content

Commit 824f5f1

Browse files
committed
fix
1 parent 982f128 commit 824f5f1

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/ModelImpl.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,6 @@ public static ModelImpl createModel(
5252
return new ModelImpl(tableEnvironment, model);
5353
}
5454

55-
@Override
5655
public ContextResolvedModel getModel() {
5756
return model;
5857
}

flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/ApiExpressionUtils.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -305,7 +305,7 @@ public static TableReferenceExpression tableRef(
305305

306306
public static ModelReferenceExpression modelRef(String name, Model model) {
307307
return new ModelReferenceExpression(
308-
name, model.getModel(), ((ModelImpl) model).getTableEnvironment());
308+
name, ((ModelImpl) model).getModel(), ((ModelImpl) model).getTableEnvironment());
309309
}
310310

311311
public static LookupCallExpression lookupCall(String name, Expression... args) {

0 commit comments

Comments
 (0)