18270704097 opened a new issue, #10140: URL: https://github.com/apache/seatunnel/issues/10140
### Search before asking - [x] I had searched in the [issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened i am trying to make a connection from influxdb to console but it always reports the same errors ### SeaTunnel Version 2.3.8 ### SeaTunnel Config ```conf env { parallelism = 1 job.mode = "BATCH" } source { InfluxDB { url = "http://32g005:18086"; sql = "select num, time from parking" database = "example" schema { fields { num = STRING time = BIGINT } } } } sink { Console {} } ``` ### Running Command ```shell ./bin/seatunnel.sh --config ./config/influxdb_2_console.conf -m local ``` ### Error Exception ```log =============================================================================== 2025-12-02 14:48:16,915 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error, 2025-12-02 14:48:16,915 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues 2025-12-02 14:48:16,915 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed 2025-12-02 14:48:16,916 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Exception StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:213) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: org.apache.seatunnel.connectors.seatunnel.influxdb.exception.InfluxdbConnectorException: ErrorCode:[API-01], ErrorDescription:[Configuration item validate failed] - PluginName: InfluxDB, PluginType: SOURCE, Message: org.apache.seatunnel.connectors.seatunnel.influxdb.exception.InfluxdbConnectorException: ErrorCode:[INFLUXDB-02], ErrorDescription:[Get column index of query result exception] - Get column index of query result exception at org.apache.seatunnel.connectors.seatunnel.influxdb.source.InfluxDBSource.initColumnsIndex(InfluxDBSource.java:154) at org.apache.seatunnel.connectors.seatunnel.influxdb.source.InfluxDBSource.prepare(InfluxDBSource.java:93) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSource(JobConfigParser.java:83) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:370) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:209) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:114) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:182) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:160) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: org.influxdb.InfluxDBException: java.lang.ClassCastException: org.msgpack.value.impl.ImmutableLongValueImpl cannot be cast to org.msgpack.value.ImmutableMapValue at org.influxdb.InfluxDBException.buildExceptionForErrorState(InfluxDBException.java:192) at org.influxdb.impl.InfluxDBImpl.execute(InfluxDBImpl.java:835) at org.influxdb.impl.InfluxDBImpl.executeQuery(InfluxDBImpl.java:824) at org.influxdb.impl.InfluxDBImpl.query(InfluxDBImpl.java:559) at org.apache.seatunnel.connectors.seatunnel.influxdb.source.InfluxDBSource.initColumnsIndex(InfluxDBSource.java:145) ... 9 more Caused by: java.lang.ClassCastException: org.msgpack.value.impl.ImmutableLongValueImpl cannot be cast to org.msgpack.value.ImmutableMapValue at org.influxdb.InfluxDBException.buildExceptionForErrorState(InfluxDBException.java:188) ... 13 more at org.apache.seatunnel.connectors.seatunnel.influxdb.source.InfluxDBSource.prepare(InfluxDBSource.java:97) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSource(JobConfigParser.java:83) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:370) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:209) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:114) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:182) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:160) ... 2 more 2025-12-02 14:48:16,916 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== Exception in thread "main" org.apache.seatunnel.core.starter.exception.CommandExecuteException: SeaTunnel job executed failed at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:213) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: org.apache.seatunnel.connectors.seatunnel.influxdb.exception.InfluxdbConnectorException: ErrorCode:[API-01], ErrorDescription:[Configuration item validate failed] - PluginName: InfluxDB, PluginType: SOURCE, Message: org.apache.seatunnel.connectors.seatunnel.influxdb.exception.InfluxdbConnectorException: ErrorCode:[INFLUXDB-02], ErrorDescription:[Get column index of query result exception] - Get column index of query result exception at org.apache.seatunnel.connectors.seatunnel.influxdb.source.InfluxDBSource.initColumnsIndex(InfluxDBSource.java:154) at org.apache.seatunnel.connectors.seatunnel.influxdb.source.InfluxDBSource.prepare(InfluxDBSource.java:93) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSource(JobConfigParser.java:83) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:370) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:209) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:114) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:182) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:160) at org.apache.seatunnel.core.starter.SeaTunnel.run(SeaTunnel.java:40) at org.apache.seatunnel.core.starter.seatunnel.SeaTunnelClient.main(SeaTunnelClient.java:34) Caused by: org.influxdb.InfluxDBException: java.lang.ClassCastException: org.msgpack.value.impl.ImmutableLongValueImpl cannot be cast to org.msgpack.value.ImmutableMapValue at org.influxdb.InfluxDBException.buildExceptionForErrorState(InfluxDBException.java:192) at org.influxdb.impl.InfluxDBImpl.execute(InfluxDBImpl.java:835) at org.influxdb.impl.InfluxDBImpl.executeQuery(InfluxDBImpl.java:824) at org.influxdb.impl.InfluxDBImpl.query(InfluxDBImpl.java:559) at org.apache.seatunnel.connectors.seatunnel.influxdb.source.InfluxDBSource.initColumnsIndex(InfluxDBSource.java:145) ... 9 more Caused by: java.lang.ClassCastException: org.msgpack.value.impl.ImmutableLongValueImpl cannot be cast to org.msgpack.value.ImmutableMapValue at org.influxdb.InfluxDBException.buildExceptionForErrorState(InfluxDBException.java:188) ... 13 more at org.apache.seatunnel.connectors.seatunnel.influxdb.source.InfluxDBSource.prepare(InfluxDBSource.java:97) at org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSource(JobConfigParser.java:83) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:370) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:209) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:114) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:182) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:160) ... 2 more ``` ### Zeta or Flink or Spark Version _No response_ ### Java or Scala Version jdk 1.8 ### Screenshots <img width="1990" height="1015" alt="Image" src="https://github.com/user-attachments/assets/3c5a7bfd-3870-4cd5-919f-8e89decfd498"; /> ### Are you willing to submit PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
