Skip to content

Commit ba4782a

Browse files
authored
[Fix] Fix MaxCompute use not exist SCHEMA option (#5708)
1 parent 9944684 commit ba4782a

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/catalog/MaxComputeCatalogFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525

2626
import com.google.auto.service.AutoService;
2727

28-
import static org.apache.seatunnel.api.table.catalog.CatalogTableUtil.SCHEMA;
28+
import static org.apache.seatunnel.api.table.catalog.schema.TableSchemaOptions.SCHEMA;
2929
import static org.apache.seatunnel.connectors.seatunnel.maxcompute.config.MaxcomputeConfig.ACCESS_ID;
3030
import static org.apache.seatunnel.connectors.seatunnel.maxcompute.config.MaxcomputeConfig.ACCESS_KEY;
3131
import static org.apache.seatunnel.connectors.seatunnel.maxcompute.config.MaxcomputeConfig.ENDPOINT;

seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/source/MaxcomputeSource.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
import com.google.auto.service.AutoService;
3434
import lombok.extern.slf4j.Slf4j;
3535

36-
import static org.apache.seatunnel.api.table.catalog.CatalogTableUtil.SCHEMA;
36+
import static org.apache.seatunnel.api.table.catalog.schema.TableSchemaOptions.SCHEMA;
3737
import static org.apache.seatunnel.connectors.seatunnel.maxcompute.config.MaxcomputeConfig.PLUGIN_NAME;
3838

3939
@Slf4j

seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/source/MaxcomputeSourceFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424

2525
import com.google.auto.service.AutoService;
2626

27-
import static org.apache.seatunnel.api.table.catalog.CatalogTableUtil.SCHEMA;
27+
import static org.apache.seatunnel.api.table.catalog.schema.TableSchemaOptions.SCHEMA;
2828
import static org.apache.seatunnel.connectors.seatunnel.maxcompute.config.MaxcomputeConfig.ACCESS_ID;
2929
import static org.apache.seatunnel.connectors.seatunnel.maxcompute.config.MaxcomputeConfig.ACCESS_KEY;
3030
import static org.apache.seatunnel.connectors.seatunnel.maxcompute.config.MaxcomputeConfig.ENDPOINT;

0 commit comments

Comments
 (0)