dolphinScheduler + hive + datax报错记录

1、参数错误

报错信息

[INFO] 2024-04-11 06:43:18.386  - [taskAppId=TASK-29-3301-84461]:[498] - after replace sql , preparing : insertoverwrite table mis_month partition (dt)
select  nvl(sl.slid   , '')                               as id,--水量 IDnvl(sl.hh     , '')                             as customer,--户号nvl(date_format(sl.sfyf, 'yyyy-MM') , '')         as `month`,--水费月份nvl(date_format(sl.sfyf, 'yyyy-MM-dd') , '')      as cbdate,--本期抄表日nvl(sl.sqxz , '')                                as previous,--上期行至nvl(sl.bqxz , '')                                as `current`,--本期行至nvl(sl.scsl  , '')                                as used,--实抄水量nvl(date_format(sl.sfyf, 'yyyy-MM') , '')        as dt       --  '月份'
from ods_yqmis_cb_slb_df sl
LEFT JOIN (select hh, yyqy from ods_yqmis_da_yhbk_df where dt = ?) bk on bk.hh = sl.hh
where sl.dt = ?and sl.jgbz in ('1')and bk.yyqy = '9'and substring(sl.sfyf, 0, 7) >= ?
[INFO] 2024-04-11 06:43:18.386  - [taskAppId=TASK-29-3301-84461]:[503] - Sql Params are replaced sql , parameters:2024-04-11(VARCHAR)2024-04-11(VARCHAR)2024-03(VARCHAR)
[INFO] 2024-04-11 06:43:18.387  - [taskAppId=TASK-29-3301-84461]:[498] - after replace sql , preparing : 
[INFO] 2024-04-11 06:43:18.387  - [taskAppId=TASK-29-3301-84461]:[503] - Sql Params are replaced sql , parameters:
[INFO] 2024-04-11 06:43:18.387  - [taskAppId=TASK-29-3301-84461]:[52] - can't find udf function resource
[INFO] 2024-04-11 06:43:18.450  - [taskAppId=TASK-29-3301-84461]:[414] - prepare statement replace sql : org.apache.hive.jdbc.HivePreparedStatement@68eeda69 
[INFO] 2024-04-11 06:44:06.549  - [taskAppId=TASK-29-3301-84461]:[414] - prepare statement replace sql : org.apache.hive.jdbc.HivePreparedStatement@11bbd42c 
[ERROR] 2024-04-11 06:44:06.593  - [taskAppId=TASK-29-3301-84461]:[243] - execute sql error
org.apache.hive.service.cli.HiveSQLException: Error while compiling statement: FAILED: ParseException line 1:0 cannot recognize input near '<EOF>' '<EOF>' '<EOF>'at org.apache.hive.jdbc.Utils.verifySuccess(Utils.java:264)at org.apache.hive.jdbc.Utils.verifySuccessWithInfo(Utils.java:250)at org.apache.hive.jdbc.HiveStatement.runAsyncOnServer(HiveStatement.java:309)at org.apache.hive.jdbc.HiveStatement.execute(HiveStatement.java:250)at org.apache.hive.jdbc.HiveStatement.executeUpdate(HiveStatement.java:448)at org.apache.hive.jdbc.HivePreparedStatement.executeUpdate(HivePreparedStatement.java:119)at org.apache.dolphinscheduler.server.worker.task.sql.SqlTask.postSql(SqlTask.java:307)at org.apache.dolphinscheduler.server.worker.task.sql.SqlTask.executeFuncAndSql(SqlTask.java:240)at org.apache.dolphinscheduler.server.worker.task.sql.SqlTask.handle(SqlTask.java:139)at org.apache.dolphinscheduler.server.worker.runner.TaskExecuteThread.run(TaskExecuteThread.java:133)at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)at java.util.concurrent.FutureTask.run(FutureTask.java:266)at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.hive.service.cli.HiveSQLException: Error while compiling statement: FAILED: ParseException line 1:0 cannot recognize input near '<EOF>' '<EOF>' '<EOF>'at org.apache.hive.service.cli.operation.Operation.toSQLException(Operation.java:329)at org.apache.hive.service.cli.operation.SQLOperation.prepare(SQLOperation.java:207)at org.apache.hive.service.cli.operation.SQLOperation.runInternal(SQLOperation.java:290)at org.apache.hive.service.cli.operation.Operation.run(Operation.java:260)at org.apache.hive.service.cli.session.HiveSessionImpl.executeStatementInternal(HiveSessionImpl.java:505)at org.apache.hive.service.cli.session.HiveSessionImpl.executeStatementAsync(HiveSessionImpl.java:491)at sun.reflect.GeneratedMethodAccessor40.invoke(Unknown Source)at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)at java.lang.reflect.Method.invoke(Method.java:498)at org.apache.hive.service.cli.session.HiveSessionProxy.invoke(HiveSessionProxy.java:78)at org.apache.hive.service.cli.session.HiveSessionProxy.access$000(HiveSessionProxy.java:36)at org.apache.hive.service.cli.session.HiveSessionProxy$1.run(HiveSessionProxy.java:63)at java.security.AccessController.doPrivileged(Native Method)at javax.security.auth.Subject.doAs(Subject.java:422)at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1875)at org.apache.hive.service.cli.session.HiveSessionProxy.invoke(HiveSessionProxy.java:59)at com.sun.proxy.$Proxy35.executeStatementAsync(Unknown Source)at org.apache.hive.service.cli.CLIService.executeStatementAsync(CLIService.java:295)at org.apache.hive.service.cli.thrift.ThriftCLIService.ExecuteStatement(ThriftCLIService.java:507)at org.apache.hive.service.rpc.thrift.TCLIService$Processor$ExecuteStatement.getResult(TCLIService.java:1437)at org.apache.hive.service.rpc.thrift.TCLIService$Processor$ExecuteStatement.getResult(TCLIService.java:1422)at org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39)at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:39)at org.apache.hive.service.auth.TSetIpAddressProcessor.process(TSetIpAddressProcessor.java:56)at org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:286)... 3 common frames omitted
Caused by: java.lang.RuntimeException: org.apache.hadoop.hive.ql.parse.ParseException:line 1:0 cannot recognize input near '<EOF>' '<EOF>' '<EOF>'at org.apache.hadoop.hive.ql.parse.ParseDriver.parse(ParseDriver.java:221)at org.apache.hadoop.hive.ql.parse.ParseUtils.parse(ParseUtils.java:75)at org.apache.hadoop.hive.ql.parse.ParseUtils.parse(ParseUtils.java:68)at org.apache.hadoop.hive.ql.Driver.compile(Driver.java:564)at org.apache.hadoop.hive.ql.Driver.compileInternal(Driver.java:1425)at org.apache.hadoop.hive.ql.Driver.compileAndRespond(Driver.java:1398)at org.apache.hive.service.cli.operation.SQLOperation.prepare(SQLOperation.java:205)... 26 common frames omitted
[ERROR] 2024-04-11 06:44:06.631  - [taskAppId=TASK-29-3301-84461]:[145] - sql task error
java.lang.RuntimeException: execute sql errorat org.apache.dolphinscheduler.server.worker.task.sql.SqlTask.executeFuncAndSql(SqlTask.java:244)at org.apache.dolphinscheduler.server.worker.task.sql.SqlTask.handle(SqlTask.java:139)at org.apache.dolphinscheduler.server.worker.runner.TaskExecuteThread.run(TaskExecuteThread.java:133)at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)at java.util.concurrent.FutureTask.run(FutureTask.java:266)at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)at java.lang.Thread.run(Thread.java:748)

原因后置sql为空,没有的话应该直接删除
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/bicheng/45195.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

MongoDB教程(二):mongoDB引用shell

&#x1f49d;&#x1f49d;&#x1f49d;首先&#xff0c;欢迎各位来到我的博客&#xff0c;很高兴能够在这里和您见面&#xff01;希望您在这里不仅可以有所收获&#xff0c;同时也能感受到一份轻松欢乐的氛围&#xff0c;祝你生活愉快&#xff01; 文章目录 引言一、MongoD…

了解AsyncRotationController

概述 基于android 15.0, 以从强制横屏App上滑退回桌面流程来分析 frameworks/base/services/core/java/com/android/server/wm/AsyncRotationController.javaAsyncRotationController 是一种控制器&#xff0c;用于处理设备显示屏旋转时非活动窗口的异步更新。这种控制器通过…

设计模式——适配器设计模式

设计模式——适配器设计模式 适配器设计模式1.1 基本介绍1.2 工作原理1.3 类适配器模式1.3.1 基本介绍1.3.2 示例1.3.3 代码实现1.3.4 注意事项 1.4 对象适配器模式1.4.1 基本介绍1.4.2 示例1.4.3 代码实现1.4.4 注意事项 1.5 接口适配器模式1.5.1 基本介绍1.5.2 示例1.5.3 代码…

如何处理Java中数据结构(如HashMap)导致的性能瓶颈

在Java开发过程中&#xff0c;HashMap 是一种常用的数据结构&#xff0c;它提供了高效的键值对存储和快速的查找、插入和删除操作。然而&#xff0c;在某些情况下&#xff0c;HashMap 可能会导致性能瓶颈。本文将探讨这些性能瓶颈的成因&#xff0c;并提供一些优化策略。 一、…

Webkit简介以及工作流程

Webkit简介 WebKit是一个开源的浏览器引擎&#xff0c;最初由苹果公司基于KHTML&#xff08;K Desktop Environment的HTML渲染引擎&#xff09;开发&#xff0c;并广泛应用于Safari浏览器。随着时间的推移&#xff0c;WebKit也被其他多款浏览器和应用所采用&#xff0c;成为We…

pudb: Python的图形化调试器

文章目录 pudb原理基础使用安装pudb启动pudb界面介绍常用操作 高级使用条件断点表达式求值自定义布局搜索和过滤插件和扩展 结论 pudb原理 pudb是一个基于文本的图形化Python调试器&#xff0c;它结合了pdb的强大调试功能与图形用户界面的易用性。pudb通过提供一个可视化的界面…

【操作系统】阻塞队列以及生产者消费者模型

目录 阻塞队列一. 概念二. 标准库中的阻塞队列三. 生产者消费者模型四. 阻塞队列实现 总结 阻塞队列 一. 概念 阻塞队列是⼀种特殊的队列.也遵守"先进先出"的原则. 阻塞队列能是⼀种线程安全的数据结构,并且具有以下特性: 当队列满的时候,继续⼊队列就会阻塞,直到…

Splashtop 在医疗与制药领域的业务增长近五倍

2024年7月10日 加利福尼亚州库比蒂诺 Splashtop 是安全远程访问和 IT 支持解决方案领域的领先企业&#xff0c;该公司今天宣布&#xff0c;在医疗与制药领域业务同比增长492%&#xff0c;取得了里程碑式的成就。快速发展的数字实验室环境和持续的网络安全威胁需要实施无缝、安…

Unity之VS脚本自动添加头部注释Package包开发

内容将会持续更新&#xff0c;有错误的地方欢迎指正&#xff0c;谢谢! Unity之VS脚本自动添加头部注释Package包开发 TechX 坚持将创新的科技带给世界&#xff01; 拥有更好的学习体验 —— 不断努力&#xff0c;不断进步&#xff0c;不断探索 TechX —— 心探索、心进取&…

模板语法指令语法——02

//指令语法&#xff1a; 1.什么是指定&#xff0c;有什么作用&#xff1f; 指令的职责是&#xff0c;当表达式的值改变时&#xff0c;将其产生的连带影响&#xff0c;响应式的作用语DOM 2.vue框架中的所有指令的名字都以v-开始的 3.插值是写在标签当中用的&#xff0c;指令…

WSGI 服务器教程:`execute` 方法解析

Python WSGI 服务器教程&#xff1a;execute 方法解析 在本文中&#xff0c;我们将详细解析一个用于 WSGI 服务器的 execute 方法。这个方法负责执行 WSGI 应用程序&#xff0c;处理其响应数据&#xff0c;并确保在应用程序执行过程中处理所有必要的清理工作。我们将逐行解释该…

uniapp启动图延时效果,启动图的配置

今天阐述uniapp开发中给启动图做延迟效果&#xff0c;不然启动图太快了&#xff0c;一闪就过去了&#xff1b; 一&#xff1a;修改配置文件&#xff1a;manifest.json "app-plus" : {"splashscreen" : {"alwaysShowBeforeRender" : false,"…

编程语言前途:探索未来的无限可能

编程语言前途&#xff1a;探索未来的无限可能 在科技日新月异的今天&#xff0c;编程语言作为连接人类与计算机世界的桥梁&#xff0c;其前途无疑是充满无限可能与挑战的。本文将从四个方面、五个方面、六个方面和七个方面&#xff0c;深入剖析编程语言的前途&#xff0c;带您…

vivado EDIF_EXTRA_SEARCH_PATHS、EQUALIZATION

EDIF_EXTRA_SEARCH_PATHS 此属性定义了Vivado Design Suite在当前文件集上的搜索路径&#xff0c;以 查找设计引用的EDIF文件。 提示&#xff1a;当Vivado设计套件无法执行以下操作时&#xff0c;在实现过程中会出现以下错误 定位与黑盒关联的EDIF网表。这可以通过定义 EDIF_EX…

法律咨询援助网站

1 项目介绍 1.1 摘要 随着互联网技术的飞速发展&#xff0c;公众对于便捷、高效的法律咨询服务需求日益增长。传统的法律咨询方式已难以满足人们即时性、多样化的咨询需求&#xff0c;促使法律咨询援助网站应运而生。这些平台旨在通过数字化手段&#xff0c;为用户提供法律知…

【TS】Typescript 的泛型

TypeScript 的泛型&#xff08;Generics&#xff09;是 TypeScript 的一个非常强大的特性&#xff0c;它允许你在编译时定义组件&#xff0c;这些组件可以工作于多种类型的数据上。泛型可以创建可重用的组件&#xff0c;这些组件是独立于任何特定类型的。这意味着你可以编写灵活…

apache:the requested operation has failed使用httpd -t

Apache24\bin cmd 回车 httpd -t 因为我重新压缩了&#xff0c;记住&#xff0c;重新压缩要使用原路径&#xff0c; 因为你安装的 时候使用的是原路径 还是不行就改个端口&#xff0c;切记修改配置文件httpd.conf先把Tomcat停了 Define SRVROOT "F:\Apache\Apache24&q…

C++类和对象学习笔记

1.类的定义 1.1类定义的格式 class是定义类的关键字&#xff0c;Date为类的名字&#xff0c;{ }中为类的主体&#xff0c;注意定义类结束时后面的分号不能省略。类中的内容称为类的成员&#xff1b;类中的变量称为类的属性或成员变量&#xff1b;类中的函数称为类的方法或者成…

自定义枚举对象序列化规则: 在Json中以枚举的code值表示枚举;枚举序列化时,新增枚举描述字段;String到IEnum的转换

文章目录 引言I 案例分析1.1 接口签名计算1.2 请求对象1.3 枚举对象序列化1.4 创建JavaTimeModule以支持Java 8的时间日期类型序列化和反序列化1.5 请求对象默认值处理II 在JSON中以枚举的code值来表示枚举的实现方式2.1 自定义toString方法返回code2.2 使用@JsonValue注解,只…

adminPage-vue3依赖FormPage说明文档,表单页快速开发,使用思路及范例(Ⅱ)formConfig基础配置项

adminPage-vue3依赖FormPage说明文档&#xff0c;表单页快速开发&#xff0c;使用思路及范例&#xff08;Ⅱ&#xff09;formConfig配置项 属性: formConfig&#xff08;表单项设置&#xff09;keylabelnoLabeldefaultValuebindchildSlottypeString类型数据&#xff08;除 time…