|
11 | 11 | import java.util.stream.Collectors;
|
12 | 12 |
|
13 | 13 | import org.apache.calcite.plan.Convention;
|
14 |
| -import org.apache.calcite.plan.RelOptUtil; |
15 | 14 | import org.apache.calcite.rel.RelNode;
|
16 | 15 | import org.apache.calcite.rel.type.RelDataType;
|
17 | 16 | import org.apache.calcite.rel.type.RelDataTypeField;
|
18 |
| -import org.apache.calcite.util.Litmus; |
19 | 17 | import org.apache.calcite.util.Pair;
|
20 | 18 |
|
21 | 19 | import com.google.common.annotations.VisibleForTesting;
|
@@ -135,7 +133,6 @@ public Pipeline pipeline(String name) throws SQLException {
|
135 | 133 | Sink sink = new Sink(sinkDatabase, sinkPath, sinkOptions);
|
136 | 134 | ConnectionService.configure(sink, Sink.class);
|
137 | 135 | Job job = new Job(name, sink, sql());
|
138 |
| - RelOptUtil.equal(sink.table(), targetRowType, "pipeline", query.getRowType(), Litmus.THROW); |
139 | 136 | deployables.addAll(DeploymentService.deployables(sink, Sink.class));
|
140 | 137 | deployables.addAll(DeploymentService.deployables(job, Job.class));
|
141 | 138 | return new Pipeline(deployables);
|
@@ -163,7 +160,6 @@ public Function<SqlDialect, String> sql() throws SQLException {
|
163 | 160 | script = script.database(sink.schema());
|
164 | 161 | script = script.connector(sink.schema(), sink.table(), targetRowType, sinkConfigs);
|
165 | 162 | script = script.insert(sink.schema(), sink.table(), query, targetFields);
|
166 |
| - RelOptUtil.equal(sink.table(), targetRowType, "pipeline", query.getRowType(), Litmus.THROW); |
167 | 163 | return script.seal();
|
168 | 164 | }
|
169 | 165 |
|
|
0 commit comments