我的代码如下
ts=<select * from loadTable("dfs://Quotes",`Quotes)>
ds=repartitionDS(ts,`Date,RANGE,2021.01.01..2021.01.31)
def WriteDS(data){
tse=loadTable("dfs://QuotesTSE",`QuotesTSE)
tfe=loadTable("dfs://QuotesTFE",`QuotesTFE)
tse.append!(select * from data where Code < `99999)
tfe.append!(select * from data where Code > `99999)
}
mr(ds,WriteDS,,,false)
请问下这是怎么回事?
可能是整个任务的执行时间太长,导致客户端连接出现了异常。推荐长任务在dolphindb中通过submitJob函数,提交到后台执行,这样就不会造成前端GUI的阻塞。