apache/seatunnel · error · DebeziumException

Couldn't initialize type registry

Error message

Couldn't initialize type registry

What it means

The TypeRegistry constructor primes the PostgreSQL type catalog by running catalog queries through SqlTypeMapper. A SQLException during priming is wrapped as DebeziumException('Couldn't initialize type registry'), failing connector initialization because decoding cannot proceed without the type map.

Solutions

1. Check the underlying SQLException for the exact catalog query failure.
2. Ensure the user can read pg_type, pg_namespace and pg_attribute.
3. Verify network stability; re-run the job if the connection was transiently lost.
4. Confirm the Postgres server version is supported by the bundled Debezium TypeRegistry.

psql "postgres://user@host:5432/mydb" -c 'SELECT count(*) FROM pg_type;'

try {
  startCdcSource(cfg);
} catch (DebeziumException e) {
  if (e.getMessage().startsWith("Couldn't initialize type registry")) {
    // check connection health and catalog permissions via e.getCause()
  }
}

When it happens

Trigger: Constructor call at connection setup: new TypeRegistry(connection) where prime()/SqlTypeMapper queries throw SQLException.

Common situations: Connection dropped between JDBC connect and type-registry load; user lacks SELECT permission on pg_type/pg_namespace; unsupported Postgres version with unexpected catalog layout.

Related errors

• Can't obtain schema for table
• Cannot determine REPLICA IDENTITY information for table
• Cannot find table schema for table
• Connection retry sleep interrupted by exception:
• Couldn't get timestamp utils from underlying connection

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

Appendix: source

Thrown at seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/io/debezium/connector/postgresql/TypeRegistry.java:145

    private int geographyOid = Integer.MIN_VALUE;
    private int citextOid = Integer.MIN_VALUE;
    private int hstoreOid = Integer.MIN_VALUE;
    private int ltreeOid = Integer.MIN_VALUE;

    private int hstoreArrayOid = Integer.MIN_VALUE;
    private int geometryArrayOid = Integer.MIN_VALUE;
    private int geographyArrayOid = Integer.MIN_VALUE;
    private int citextArrayOid = Integer.MIN_VALUE;
    private int ltreeArrayOid = Integer.MIN_VALUE;

    public TypeRegistry(PostgresConnection connection) {
        try {
            this.connection = connection;
            sqlTypeMapper = new SqlTypeMapper(this.connection);

            prime();
        } catch (SQLException e) {
            throw new DebeziumException("Couldn't initialize type registry", e);
        }
    }

    private void addType(PostgresType type) {
        oidToType.put(type.getOid(), type);
        nameToType.put(type.getName(), type);

        if (TYPE_NAME_GEOMETRY.equals(type.getName())) {
            geometryOid = type.getOid();
        } else if (TYPE_NAME_GEOGRAPHY.equals(type.getName())) {
            geographyOid = type.getOid();
        } else if (TYPE_NAME_CITEXT.equals(type.getName())) {
            citextOid = type.getOid();
        } else if (TYPE_NAME_HSTORE.equals(type.getName())) {
            hstoreOid = type.getOid();
        } else if (TYPE_NAME_LTREE.equals(type.getName())) {
            ltreeOid = type.getOid();
        } else if (TYPE_NAME_HSTORE_ARRAY.equals(type.getName())) {

View on GitHub (pinned to cf67b549a7)