Flutemr commented on issue #10540:
URL:
https://github.com/apache/dolphinscheduler/issues/10540#issuecomment-1163852803
> 有错误日志吗？
>
> BTW，请用英文描述，以便其他人理解。
2.0.5-release
error log
[LOG-PATH]: /opt/dolphinscheduler/logs/5858213194912_5/1315/2510.log,
[HOST]: 10.60.0.49
[INFO] 2022-06-23 06:00:31.251 TaskLogLogger-class
org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[118] - Full sql
parameters: SqlParameters{type='HIVE', datasource=3, sql='INSERT overwrite
table yyt_dwd.dwd_gy_ykt_xsyktzpxx partition(dt='${bizdate1}')
select distinct
ecode
,UPPER(REGEXP_REPLACE(outid,'[^0-9a-zA-Z]+','')) as outid
,photo
,updateflag
,updatedt
,downdt
,ver
from yyt_ods.ods_card_m_base_ecardphotos
where dt='${bizdate1}' and outid <>''', sqlType=1, sendEmail=false,
displayRows=10, limit=0, udfs='', showType='null', connParams='', groupId='0',
title='', preStatements=[CREATE TABLE if not exists
`yyt_dwd.dwd_gy_ykt_xsyktzpxx`(
`ecode` string COMMENT '企业IDECARD-T4.0等多客户版本必填，其它版本不用填',
`outid` string COMMENT '学工号',
`photo` binary COMMENT '照片',
`updateflag` string COMMENT '更新状态1：新增；2：修改；99：已同步',
`updatedt` string COMMENT '更新时间',
`downdt` string COMMENT '读取时间',
`ver` string COMMENT '记录版本，用于增量同步')
COMMENT '一卡通照片信息'
PARTITIONED BY (
`dt` string COMMENT 'ods层分区字段,如20220321')
stored as orc], postStatements=[]}
[INFO] 2022-06-23 06:00:31.251 TaskLogLogger-class
org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[119] - sql type : HIVE,
datasource : 3, sql : INSERT overwrite table yyt_dwd.dwd_gy_ykt_xsyktzpxx
partition(dt='${bizdate1}')
select distinct
ecode
,UPPER(REGEXP_REPLACE(outid,'[^0-9a-zA-Z]+','')) as outid
,photo
,updateflag
,updatedt
,downdt
,ver
from yyt_ods.ods_card_m_base_ecardphotos
where dt='${bizdate1}' and outid <>'' , localParams :
[Property{prop='bizdate1', direct=IN, type=VARCHAR,
value='${system.biz.date}'}],udfs : ,showType : null,connParams : ,varPool : []
,query max result limit 0
[INFO] 2022-06-23 06:00:31.252 TaskLogLogger-class
org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[94] - setSqlParamsMap:
Property with paramName: bizdate1 put in sqlParamsMap of content INSERT
overwrite table yyt_dwd.dwd_gy_ykt_xsyktzpxx partition(dt='${bizdate1}')
select distinct
ecode
,UPPER(REGEXP_REPLACE(outid,'[^0-9a-zA-Z]+','')) as outid
,photo
,updateflag
,updatedt
,downdt
,ver
from yyt_ods.ods_card_m_base_ecardphotos
where dt='${bizdate1}' and outid <>'' successfully.
[INFO] 2022-06-23 06:00:31.252 TaskLogLogger-class
org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[94] - setSqlParamsMap:
Property with paramName: bizdate1 put in sqlParamsMap of content INSERT
overwrite table yyt_dwd.dwd_gy_ykt_xsyktzpxx partition(dt='${bizdate1}')
select distinct
ecode
,UPPER(REGEXP_REPLACE(outid,'[^0-9a-zA-Z]+','')) as outid
,photo
,updateflag
,updatedt
,downdt
,ver
from yyt_ods.ods_card_m_base_ecardphotos
where dt='${bizdate1}' and outid <>'' successfully.
[INFO] 2022-06-23 06:00:31.252 TaskLogLogger-class
org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[418] - after replace sql ,
preparing : INSERT overwrite table yyt_dwd.dwd_gy_ykt_xsyktzpxx
partition(dt=?)
select distinct
ecode
,UPPER(REGEXP_REPLACE(outid,'[^0-9a-zA-Z]+','')) as outid
,photo
,updateflag
,updatedt
,downdt
,ver
from yyt_ods.ods_card_m_base_ecardphotos
where dt=? and outid <>''
[INFO] 2022-06-23 06:00:31.252 TaskLogLogger-class
org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[427] - Sql Params are
replaced sql , parameters:20220622(VARCHAR)20220622(VARCHAR)
[INFO] 2022-06-23 06:00:31.252 TaskLogLogger-class
org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[418] - after replace sql ,
preparing : CREATE TABLE if not exists `yyt_dwd.dwd_gy_ykt_xsyktzpxx`(
`ecode` string COMMENT '企业IDECARD-T4.0等多客户版本必填，其它版本不用填',
`outid` string COMMENT '学工号',
`photo` binary COMMENT '照片',
`updateflag` string COMMENT '更新状态1：新增；2：修改；99：已同步',
`updatedt` string COMMENT '更新时间',
`downdt` string COMMENT '读取时间',
`ver` string COMMENT '记录版本，用于增量同步')
COMMENT '一卡通照片信息'
PARTITIONED BY (
`dt` string COMMENT 'ods层分区字段,如20220321')
stored as orc
[INFO] 2022-06-23 06:00:31.252 TaskLogLogger-class
org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[427] - Sql Params are
replaced sql , parameters:
[INFO] 2022-06-23 06:00:31.252 TaskLogLogger-class
org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[496] - can't find udf
function resource
[ERROR] 2022-06-23 06:01:08.356 TaskLogLogger-class
org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[209] - execute sql error:
SQL task prepareStatementAndBind error
[ERROR] 2022-06-23 06:01:08.356 TaskLogLogger-class
org.apache.dolphinscheduler.plugin.task.sql.SqlTask:[160] - sql task error:
org.apache.dolphinscheduler.plugin.task.api.TaskException: SQL task
prepareStatementAndBind error
--
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]
