apache/seatunnel · error · CatalogException
Failed Connection JDBC error
Error message
Failed Connection JDBC error %s
What it means
Thrown by StarRocksCatalog.dropDatabase when executing the DROP DATABASE statement over the JDBC connection fails; despite the 'Connection JDBC' wording it wraps any SQL/exception failure of the drop operation, naming the default URL context.
Solutions
- Verify FE connectivity and credentials
- Ensure the database can be dropped (empty or permitted) and privileges suffice
- Inspect the wrapped exception for the StarRocks error
Defensive patterns
Strategy: try-catch
When it happens
Trigger: Thrown at seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/catalog/StarRocksCatalog.java:308 when the library encounters an invalid state.
Common situations: See trigger scenarios.
AI-assisted analysis of apache/seatunnel@cf67b549a7 (2026-09-10).
Data as JSON: /api/errors/70cc34a66b8dde6a.
Report an issue: GitHub.
Appendix: source
Thrown at seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/catalog/StarRocksCatalog.java:308
tablePath.getDatabaseName(), ignoreIfExists));
}
} catch (Exception e) {
throw new CatalogException(
String.format("Failed listing database in catalog %s", catalogName), e);
}
}
@Override
public void dropDatabase(TablePath tablePath, boolean ignoreIfNotExists)
throws DatabaseNotExistException, CatalogException {
try {
try (Statement stmt = conn.createStatement()) {
stmt.execute(
StarRocksSaveModeUtil.INSTANCE.getDropDatabaseSql(
tablePath.getDatabaseName(), ignoreIfNotExists));
}
} catch (Exception e) {
throw new CatalogException(
String.format("Failed listing database in catalog %s", catalogName), e);
}
}
/** @see com.mysql.cj.MysqlType */
private SeaTunnelDataType<?> fromJdbcType(ResultSetMetaData metadata, int colIndex)
throws SQLException {
MysqlType starrocksType = MysqlType.getByName(metadata.getColumnTypeName(colIndex));
switch (starrocksType) {
case NULL:
return BasicType.VOID_TYPE;
case BOOLEAN:
return BasicType.BOOLEAN_TYPE;
case BIT:
case TINYINT:
return BasicType.BYTE_TYPE;
case TINYINT_UNSIGNED:
case SMALLINT:View on GitHub (pinned to cf67b549a7)