luckyliush opened a new issue, #7054: URL: https://github.com/apache/seatunnel/issues/7054
### 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 If there is no data in the specified partition of the extracted hive data table, seatunnel will throw a field not found exception. If the specified partition has data, it will be executed normally. ### SeaTunnel Version 2.3.5 ### SeaTunnel Config ```conf env { execution.parallelism = 20 job.mode = "BATCH" } source { Hive { table_name = "${hive_db}.table_name" metastore_uri = "${metastore_uri}" #read_partitions = ["task_partition_version""=""${partition_version}"] result_table_name = "Table_test" hdfs_site_path = "/hdfs-site.xml" hive_site_path = "/hive-site.xml" } } transform { sql { source_table_name="Table_test" query = "select xxx ,xxx from Table_test where task_partition_version = '${partition_version}'" result_table_name = "Table_test2" } } sink { Jdbc { url = "${url}" driver = "${driver}" user = "${user}" password = "${password}" database = "${mysql_db}" table = "tabel_name" query = "insert into tabel_name (xxx,xxx) values(?,?)" } } ``` ### Running Command ```shell Seatunnel node of dolphinscheduler used, cluster mode ``` ### Error Exception ```log 2024-06-24 18:09:11,213 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel1] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is CLIENT_DISCONNECTED 2024-06-24 18:09:11,215 INFO [c.h.c.LifecycleService ] [main] - hz.client_1 [seatunnel1] [5.1] HazelcastClient 5.1 (20220228 - 21f20e7) is SHUTDOWN 2024-06-24 18:09:11,215 INFO [s.c.s.s.c.ClientExecuteCommand] [main] - Closed SeaTunnel client...... 2024-06-24 18:09:11,215 ERROR [o.a.s.c.s.SeaTunnel ] [main] - =============================================================================== 2024-06-24 18:09:11,215 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Fatal Error, 2024-06-24 18:09:11,215 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Please submit bug report in https://github.com/apache/seatunnel/issues 2024-06-24 18:09:11,215 ERROR [o.a.s.c.s.SeaTunnel ] [main] - Reason:SeaTunnel job executed failed 2024-06-24 18:09:11,217 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:202) 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.IllegalArgumentException: can't find field [pn] at org.apache.seatunnel.transform.sql.zeta.ZetaSQLType.getExpressionType(ZetaSQLType.java:125) at org.apache.seatunnel.transform.sql.zeta.ZetaSQLEngine.typeMapping(ZetaSQLEngine.java:206) at org.apache.seatunnel.transform.sql.SQLTransform.transformTableSchema(SQLTransform.java:122) at org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform.transformCatalogTable(AbstractCatalogSupportTransform.java:50) at org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform.getProducedCatalogTable(AbstractCatalogSupportTransform.java:40) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseTransform(MultipleTableJobConfigParser.java:434) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseTransforms(MultipleTableJobConfigParser.java:362) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:193) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:88) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:156) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:149) ... 2 more 2024-06-24 18:09:11,217 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:202) 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.IllegalArgumentException: can't find field [pn] at org.apache.seatunnel.transform.sql.zeta.ZetaSQLType.getExpressionType(ZetaSQLType.java:125) at org.apache.seatunnel.transform.sql.zeta.ZetaSQLEngine.typeMapping(ZetaSQLEngine.java:206) at org.apache.seatunnel.transform.sql.SQLTransform.transformTableSchema(SQLTransform.java:122) at org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform.transformCatalogTable(AbstractCatalogSupportTransform.java:50) at org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform.getProducedCatalogTable(AbstractCatalogSupportTransform.java:40) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseTransform(MultipleTableJobConfigParser.java:434) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parseTransforms(MultipleTableJobConfigParser.java:362) at org.apache.seatunnel.engine.core.parse.MultipleTableJobConfigParser.parse(MultipleTableJobConfigParser.java:193) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.getLogicalDag(ClientJobExecutionEnvironment.java:88) at org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment.execute(ClientJobExecutionEnvironment.java:156) at org.apache.seatunnel.core.starter.seatunnel.command.ClientExecuteCommand.execute(ClientExecuteCommand.java:149) ... 2 more [INFO] 2024-06-24 18:09:12.026 +0800 - FINALIZE_SESSION ``` ### Zeta or Flink or Spark Version Zeta ### Java or Scala Version java8 ### Screenshots _No response_ ### 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]
