datax 导入dolphindb 数据处理报错
请问各位大佬，
datax 版本 DATAX-OPENSOURCE-3.0
dolphindbwriter版本 130.21.5
datax 的配置json中加上如下字段以及相应的错误信息如下，麻烦大佬看看：
"saveFunctionName": "savePartitionedData1",
"saveFunctionDef": "
def rowUpdate(dbName, tbName, data, t){
dfsPath = dbName
temp = select * from t
update temp set trade_dt = datetimeParse(trade_dt,"yyyyMMdd")
loadTable(dfsPath, tbName).append!(temp)}
def savePartitionedData1(dbName, tbName, data){
dfsPath = dbName
login(\"admin\",\"123456\")
t = loadTable(dfsPath, tbName)
ds1 = sqlDS(<select * from t>)
mr(ds1, rowUpdate{dbName, tbName, data}) } "
错误信息：Server response: 'savePartitionedData1: mr(ds1, rowUpdate{dbName, tbName, data}) => The type of some tuple elements is not DATASOURCE' function: 'savePartitionedData1{'dfs://stock_daily_TSDB','ashareeodprices'}'
