{"record":{"id":"ffb61267aa5c3b8f","repo":"apache/seatunnel","slug":"connect-failed-ffb612","errorCode":"CONNECT_FAILED","errorMessage":"Unable to initialize a NebulaGraph session pool for space '${space}'.","messagePattern":"Unable to initialize a NebulaGraph session pool for space '(.+?)'\\.","errorType":"error_code","errorClass":"NebulaGraphConnectorException","httpStatus":null,"severity":"critical","filePath":"seatunnel-connectors-v2/connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/client/SessionPoolNebulaGraphClient.java","lineNumber":53,"sourceCode":"    public SessionPoolNebulaGraphClient(NebulaGraphSinkConfig config) {\n        SessionPoolConfig poolConfig =\n                new SessionPoolConfig(\n                                config.getHosts(),\n                                config.getSpace(),\n                                config.getUsername(),\n                                config.getPassword())\n                        .setMinSessionSize(1)\n                        .setMaxSessionSize(1)\n                        .setTimeout(config.getTimeoutMillis())\n                        .setWaitTime(config.getTimeoutMillis())\n                        .setRetryTimes(config.getMaxRetries())\n                        .setIntervalTime(\n                                config.getMaxRetries() == 0 ? 0 : config.getRetryIntervalMillis())\n                        .setReconnect(true);\n        try {\n            this.sessionPool = new SessionPool(poolConfig);\n        } catch (RuntimeException e) {\n            throw new NebulaGraphConnectorException(\n                    NebulaGraphConnectorErrorCode.CONNECT_FAILED,\n                    \"Unable to initialize a NebulaGraph session pool for space '\"\n                            + config.getSpace()\n                            + \"'.\",\n                    e);\n        }\n    }\n\n    @Override\n    public void execute(String statement, Map<String, Object> parameters) throws IOException {\n        try {\n            ResultSet result = sessionPool.execute(statement, parameters);\n            if (!result.isSucceeded()) {\n                throw new IOException(\n                        \"NebulaGraph rejected the write with code \"\n                                + result.getErrorCode()\n                                + \": \"\n                                + result.getErrorMessage());","sourceCodeStart":35,"sourceCodeEnd":71,"githubUrl":"https://github.com/apache/seatunnel/blob/cf67b549a7a6c35fa0beb12d83c62892427ea919/seatunnel-connectors-v2/connector-nebulagraph/src/main/java/org/apache/seatunnel/connectors/seatunnel/nebulagraph/client/SessionPoolNebulaGraphClient.java#L35-L71","documentation":"SessionPoolNebulaGraphClient's constructor creates a NebulaGraph Java SessionPool. If SessionPool construction throws a RuntimeException (auth failure, unreachable graphd, bad space name), it is wrapped as NebulaGraphConnectorException with CONNECT_FAILED naming the configured space. The sink cannot operate without a valid session pool.","triggerScenarios":"new SessionPool(poolConfig) fails at writer init: wrong host/port, invalid username/password, space does not exist, or graph service unreachable.","commonSituations":"Typo in graphAddress/graphd host; NebulaGraph cluster down or still electing leaders; wrong credentials; space name mismatch (case-sensitive) or space not yet created with 'CREATE SPACE'.","solutions":["Verify NebulaGraph hosts/ports are reachable (telnet/nc to graphd 9669)","Test credentials and space with nebula-console: USE <space>; run a trivial query","Confirm the space exists (SHOW SPACES) and the name matches config exactly","Check NebulaGraph service health (graphd/metad/storaged status) and retry"],"exampleFix":"// before\nspace = \"my_Space\"\n// after (space must exist and match exactly)\nspace = \"my_space\"","handlingStrategy":"validation","validationCode":"// preflight with nebula-console before running the job\n// SHOW SPACES;            -> confirm space exists\n// USE my_space; DESCRIBE TAG my_tag;  -> confirm schema\n// also: nc -zv <graphd-host> 9669","typeGuard":null,"tryCatchPattern":"try {\n    client = new SessionPoolNebulaGraphClient(config);\n} catch (NebulaGraphConnectorException e) {\n    LOG.error(\"Session pool init failed for space {}. Check address/credentials/space.\", space, e.getCause());\n    throw e;\n}","preventionTips":["Validate graphd address/port reachability before job start","Verify username/password against Nebula ACLs","CREATE SPACE and schema must exist before the sink runs","Space names are case-sensitive — match config exactly"],"tags":["nebulagraph","connect-failed","session-pool","config"],"backgroundTag":"connection-refused","analyzedSha":"cf67b549a7a6c35fa0beb12d83c62892427ea919","analyzedAt":"2026-09-10T21:44:55.265Z","contentChangedAt":"2026-09-10T21:44:55.265Z","schemaVersion":2},"datasetVersion":"2026-09-23T08:17:48.524Z"}