apache/seatunnel · error · IllegalStateException

Failed to read Fluss table info for

Error message

Failed to read Fluss table info for %s

What it means

FlussAdminClient.getTableInfo fetches table metadata (schema, descriptors) from the Fluss cluster via admin.getTableInfo(...).get(). Any exception — connectivity, unknown table, timeout, or interrupted wait — is wrapped as 'Failed to read Fluss table info for <db.table>' preserving the cause.

Solutions

1. Verify the table exists: connect to Fluss and list databases/tables for the exact name in the message
2. Check Fluss connectivity config (bootstrap servers) and network reachability from the client
3. Look at the wrapped cause for the definitive error (TableNotExistException vs timeout vs auth)
4. If transient, retry the job after confirming cluster health

Example fix

// before
"database" = "mydb", "table" = "orders"   // table actually named 'order'
// after
"database" = "mydb", "table" = "order"

// before job: verify table exists via Fluss client
if (admin.tableExists(TablePath.of(db, table)) == false)
    throw new IllegalArgumentException(db + "." + table + " does not exist");

try {
    TableInfo info = getTableInfo(tablePath);
} catch (SeaTunnelRuntimeException e) {
    if (e.getCause() instanceof TableNotExistException) { /* fix table name */ }
    else if (isTransient(e.getCause())) { /* retry with backoff */ }
    throw e;
}

When it happens

Trigger: admin.getTableInfo(toFlussTablePath(tablePath)).get() completing exceptionally: Fluss coordinator unreachable, table/database does not exist, authentication failure, or the future times out/is interrupted.

Common situations: Typo in database.table name, Fluss cluster not running or wrong bootstrap server config, network/firewall blocking the coordinator port, or reading a table that was dropped between planning and execution.

Understand the failure class

Background: "API request failed": what wrapped HTTP errors from external APIs mean and how to find the real cause — this error's family across 29 libraries.

Related errors

• Failed to close Fluss admin for
• Failed to list offsets for table
• A decoding format must override this method to apply…
• Cannot determine REPLICA IDENTITY information for table
• CLUSTER_LIST_GET_FAILED

AI-assisted analysis of apache/seatunnel@cf67b549a7 (2026-09-10). Data as JSON: /api/errors/08c468e51b293422. Report an issue: GitHub.

Appendix: source

Thrown at seatunnel-connectors-v2/connector-fluss/src/main/java/org/apache/seatunnel/connectors/seatunnel/fluss/source/FlussAdminClient.java:80

     * connector's. The connection's authenticator is loaded once here and reused by every later
     * admin / scan call, so pinning only the connection setup is enough.
     */
    private static Connection createConnection(Configuration flussConfig) {
        try (TemporaryClassLoaderContext ignored =
                TemporaryClassLoaderContext.of(FlussAdminClient.class.getClassLoader())) {
            return ConnectionFactory.createConnection(flussConfig);
        }
    }

    Connection connection() {
        return connection;
    }

    TableInfo getTableInfo(TablePath tablePath) {
        try {
            return admin.getTableInfo(toFlussTablePath(tablePath)).get();
        } catch (Exception e) {
            throw wrap(
                    String.format(
                            "Failed to read Fluss table info for %s", tablePath.getFullName()),
                    e);
        }
    }

    Map<Integer, Long> earliestOffsets(TablePath tablePath, List<Integer> buckets) {
        CompletableFuture<Map<Integer, Long>> earliest =
                listOffsetsAsync(tablePath, buckets, new OffsetSpec.EarliestSpec());
        return awaitOffsets(earliest, tablePath, buckets);
    }

    Map<Integer, Long> latestOffsets(TablePath tablePath, List<Integer> buckets) {
        CompletableFuture<Map<Integer, Long>> latest =
                listOffsetsAsync(tablePath, buckets, new OffsetSpec.LatestSpec());
        return awaitOffsets(latest, tablePath, buckets);
    }

View on GitHub (pinned to cf67b549a7)