15810785091 commented on issue #9723:
URL: https://github.com/apache/seatunnel/issues/9723#issuecomment-3199046745
Change transfrom to the following. This will work ！！！250W data completed in
32 seconds！！！
But before the modification, is there a problem that the task does not
report an error and does not throw an exception, or whether this type of
implicit conversion can be adjusted?
transform {
Sql{
plugin_input = "mysql_table"
plugin_output = "sql_table"
query = """
SELECT
id
, taskname
, wxtitle
, wx_author
, paytype
, type
, plattype
, category
, FROM_UNIXTIME(cast(createtime as bigint), 'yyyy-MM-dd HH:mm:ss')
createtime
, FROM_UNIXTIME(cast(audittime as bigint), 'yyyy-MM-dd HH:mm:ss')
audittime
, FROM_UNIXTIME(cast(canceltime as bigint), 'yyyy-MM-dd HH:mm:ss')
canceltime
, FROM_UNIXTIME(cast(deltime as bigint), 'yyyy-MM-dd HH:mm:ss') deltime
, FROM_UNIXTIME(cast(starttime as bigint), 'yyyy-MM-dd HH:mm:ss')
starttime
, FROM_UNIXTIME(cast(stoptime as bigint), 'yyyy-MM-dd HH:mm:ss')
stoptime
, is_fee
, sort
, FROM_UNIXTIME(cast(endtime as bigint), 'yyyy-MM-dd HH:mm:ss') endtime
, FROM_UNIXTIME(cast(realusetime as bigint), 'yyyy-MM-dd HH:mm:ss')
realusetime
, status
, payerid
, agentid
, saleid
, managerid
, reason
, resource_status
, feestatus
, FROM_UNIXTIME(cast(feetime as bigint), 'yyyy-MM-dd HH:mm:ss') feetime
, operatorid
, mediamanagerid
, identifier
, planid
, affiliatedid
, idstr
, source
, customerid
, customer_remarksid
, pid_complex
, discount_rate
, discount_code
, coupon_id
, isonline
, isdnr
, remarks
, process_type
, bd_brand_id
, weiq_brand_id
, kf_brand_id
, purchase_name
from mysql_table
"""
}
}
--
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]
