apache/seatunnel

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

Open

#10,140 opened on Dec 2, 2025

View on GitHub
 (4 comments) (0 reactions) (0 assignees)Java (1,432 forks)batch import
bughelp wanted

Repository metrics

Stars
 (6,897 stars)
PR merge metrics
 (Avg merge 13d 21h) (143 merged PRs in 30d)

Description

Search before asking

  • I had searched in the issues 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

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

./bin/seatunnel.sh --config ./config/influxdb_2_console.conf -m local

Error Exception

===============================================================================


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

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Contributor guide

Research direction
Investigate the InfluxDBSource.initColumnsIndex method in seatunnel connectors/connector influxdb. The ClassCastException indicates the query result is not parsed as expected (ImmutableMapValue). Verify that the InfluxDB query returns a valid result set with the specified fields. Check the mapping between the configured schema fields and the actual query columns.
Tech stack
java
Domain
backend
Issue type
Bug
DifficultyEstimated implementation difficulty for a new contributor, from 1 for very small changes to 5 for expert-level work.
3
Estimated timeA rough time range for an experienced contributor to investigate, implement, test, and prepare a pull request.
1-3 hours
Activity statusHow available the issue appears right now: fresh, active, stale, blocked, or waiting on maintainer input.
Active
ClarityHow clearly the issue explains the expected change, acceptance criteria, and next step.
Clear
Prerequisites
JavaInfluxDB basics
Newbie friendlinessA 1-100 score estimating how approachable this issue is for first-time contributors.
60