[Bug] [connector-influxdb] exception occur while using influxdb source

### 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)


Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

[Bug] [connector-influxdb] exception occur while using influxdb source #10140

Search before asking

What happened

SeaTunnel Version

SeaTunnel Config

Running Command

Error Exception

Zeta or Flink or Spark Version

Java or Scala Version

Screenshots

Are you willing to submit PR?

Code of Conduct

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

[Bug] [connector-influxdb] exception occur while using influxdb source #10140

Description

Search before asking

What happened

SeaTunnel Version

SeaTunnel Config

Running Command

Error Exception

Zeta or Flink or Spark Version

Java or Scala Version

Screenshots

Are you willing to submit PR?

Code of Conduct

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions