seatunnel
seatunnel copied to clipboard
apache
[Bug] [connector-influxdb] exception occur while using influxdb source
Search before asking
- [x] 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
- [x] I agree to follow this project's Code of Conduct
Hi, what is the format of the field value corresponding to the field key of this point data? Could you please provide the command for writing the data?
write data by using the ui website
writing success above
Hi, it would be best to try using the influxdb-1.x version.