muzijiuri opened a new issue, #7417:
URL: https://github.com/apache/seatunnel/issues/7417
脚本为:
`env{
parallelism = 1
job.mode = "BATCH"
}
source {
TDengine {
url : "jdbc:TAOS-RS://xxxx:6041/"
username : "root"
password : "taosdata"
database : "datax_test"
stable : "stb1"
lower_bound : "2021-07-13 00:00:00"
upper_bound : "2021-17-14 00:00:00"
result_table_name = "tdengine_result"
}
}
sink {
TDengine {
url : "jdbc:TAOS-RS://xxxx:6041/"
username : "root"
password : "taosdata"
database : "datax_test2"
stable : "stb2"
timezone: UTC
}
}`
source数据源,包括了超级表以及子表;sink 数据源,包括了一张空的超级表,除了名字,超级表的表结构是一样的,运行出现问题:
2024-08-16 15:14:08,519 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
===============================================================================
2024-08-16 15:14:08,519 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Fatal Error,
2024-08-16 15:14:08,519 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Please submit bug report in https://github.com/apache/seatunnel/issues
2024-08-16 15:14:08,519 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Reason:SeaTunnel job executed failed
2024-08-16 15:14:08,520 ERROR [o.a.s.c.s.SeaTunnel ] [main] -
Exception
StackTrace:org.apache.seatunnel.core.starter.exception.CommandExecuteE
xception: SeaTunnel
job executed failed
at
org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:211)
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: java.lang.NullPointerException
at
org.apache.seatunnel.connectors.seatunnel.tdengine.typemapper.TDengineTypeMapper.mapping(TDengineTypeMapper.java:85)
at
org.apache.seatunnel.connectors.seatunnel.tdengine.source.TDengineSource.getStableMetadata(TDengineSource.java:151)
at
org.apache.seatunnel.connectors.seatunnel.tdengine.source.TDengineSource.prepare(TDengineSource.java:91)
at
org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSource(JobConfigParser.java:83)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:356)
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:158)
... 2 more
2024-08-16 15:14:08,520 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:211)
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: java.lang.NullPointerException
at
org.apache.seatunnel.connectors.seatunnel.tdengine.typemapper.TDengineTypeMapper.mapping(TDengineTypeMapper.java:85)
at
org.apache.seatunnel.connectors.seatunnel.tdengine.source.TDengineSource.getStableMetadata(TDengineSource.java:151)
at
org.apache.seatunnel.connectors.seatunnel.tdengine.source.TDengineSource.prepare(TDengineSource.java:91)
at
org.apache.seatunnel.engine.core.parse.JobConfigParser.parseSource(JobConfigParser.java:83)
at
org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseSource(MultipleTableJobConfigParser.java:356)
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:158)
... 2 more
--
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]