{"record":{"id":"3e5e8e820822ee27","repo":"apache/seatunnel","slug":"connect-failed-3e5e8e","errorCode":"CONNECT_FAILED","errorMessage":"connect influxdb failed, due to influxdb version info is unknown, the url is: {%s}","messagePattern":"connect influxdb failed, due to influxdb version info is unknown, the url is: (.+?)","errorType":"error_code","errorClass":"InfluxdbConnectorException","httpStatus":null,"severity":"critical","filePath":"seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/source/InfluxdbSourceReader.java","lineNumber":76,"sourceCode":"\n    InfluxdbSourceReader(\n            InfluxDBConfig config,\n            Context readerContext,\n            SeaTunnelRowType seaTunnelRowType,\n            List<Integer> columnsIndexList) {\n        this.config = config;\n        this.pendingSplits = new LinkedList<>();\n        this.context = readerContext;\n        this.seaTunnelRowType = seaTunnelRowType;\n        this.columnsIndexList = columnsIndexList;\n    }\n\n    public void connect() throws ConnectException {\n        if (influxdb == null) {\n            influxdb = InfluxDBClient.getInfluxDB(config);\n            String version = influxdb.version();\n            if (!influxdb.ping().isGood()) {\n                throw new InfluxdbConnectorException(\n                        InfluxdbConnectorErrorCode.CONNECT_FAILED,\n                        String.format(\n                                \"connect influxdb failed, due to influxdb version info is unknown, the url is: {%s}\",\n                                config.getUrl()));\n            }\n            log.info(\"connect influxdb successful. sever version :{}.\", version);\n        }\n    }\n\n    @Override\n    public void open() throws Exception {\n        connect();\n    }\n\n    @Override\n    public void close() {\n        if (influxdb != null) {\n            influxdb.close();","sourceCodeStart":58,"sourceCodeEnd":94,"githubUrl":"https://github.com/apache/seatunnel/blob/cf67b549a7a6c35fa0beb12d83c62892427ea919/seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/source/InfluxdbSourceReader.java#L58-L94","documentation":"InfluxdbSourceReader.connect() obtains a read client via InfluxDBClient.getInfluxDB(config) and pings the server. If ping().isGood() is false, the source cannot reach a healthy InfluxDB and throws CONNECT_FAILED with the configured URL.","triggerScenarios":"Source reader open() -> connect() when the InfluxDB endpoint is down, misconfigured, unreachable over the network, or responding unhealthily to ping.","commonSituations":"Wrong source URL/port config, InfluxDB service stopped, k8s network policy or firewall blocking the workers, TLS/protocol mismatch, or wrong version endpoint (1.x vs 2.x).","solutions":["Test the URL manually with curl against the InfluxDB /ping endpoint.","Verify source config url, database/retention and auth settings.","Ensure network reachability from all SeaTunnel nodes to InfluxDB.","Match client protocol/auth to the actual InfluxDB version."],"exampleFix":"// before\nurl = \"https://influx.internal:8086\" // TLS not enabled on server\n// after\nurl = \"http://influx.internal:8086\"","handlingStrategy":"retry","validationCode":"// preflight ping\nHttpResponse<String> resp = client.send(HttpRequest.newBuilder(URI.create(url + \"/ping\")).build(), HttpResponse.BodyHandlers.ofString());\nif (resp.statusCode() >= 400) throw new IllegalStateException(\"InfluxDB ping failed: \" + resp.statusCode());","typeGuard":null,"tryCatchPattern":"try {\n    reader.connect();\n} catch (ConnectException | InfluxdbConnectorException e) {\n    // retry with backoff before failing the job\n    retryWithBackoff(() -> reader.connect(), 3);\n}","preventionTips":["Monitor InfluxDB health from the cluster network.","Confirm http/https and auth per InfluxDB version.","Add retry with backoff around reader open."],"tags":["influxdb","connectivity","source"],"backgroundTag":"connection-refused","analyzedSha":"cf67b549a7a6c35fa0beb12d83c62892427ea919","analyzedAt":"2026-09-10T21:44:55.265Z","contentChangedAt":"2026-09-10T21:44:55.265Z","schemaVersion":2},"datasetVersion":"2026-09-14T11:17:12.474Z"}