使用数据模型的sql查询抽取数据时抽取失败,执行sql是可以正常查询出数据的 报错信息
dataSetId=I8a8a8aa401904d824d823d79019058d30c7f0031 Error Message: dataSetId=I8a8a8aa401904d824d823d79019058d30c7f0031 28cf3993-b66e-463f-86cc-1e748735820e move error: dataSetId=I8a8a8aa401904d824d823d79019058d30c7f0031 subTaskId=28cf3993-b66e-463f-86cc-1e748735820e executeTask: Error Message: Error Message: Failed to import table 'o_457dbfed12fc695b871ea0951402f255_0_5', line 41: incomplete record at end of file Stack trace: org.monetdb.jdbc.MonetConnection$ResponseList.executeQuery(MonetConnection.java:3205) org.monetdb.jdbc.MonetConnection$ResponseList.processQuery(MonetConnection.java:2993) org.monetdb.jdbc.MonetStatement.internalExecute(MonetStatement.java:450) org.monetdb.jdbc.MonetStatement.execute(MonetStatement.java:284) org.monetdb.jdbc.MonetPreparedStatement.execute(MonetPreparedStatement.java:280) org.monetdb.jdbc.MonetPreparedStatement.executeUpdate(MonetPreparedStatement.java:324) org.apache.commons.dbcp.DelegatingPreparedStatement.executeUpdate(DelegatingPreparedStatement.java:105) org.apache.commons.dbcp.DelegatingPreparedStatement.executeUpdate(DelegatingPreparedStatement.java:105) org.apache.commons.dbcp.DelegatingPreparedStatement.executeUpdate(DelegatingPreparedStatement.java:105) smartbix.smartcube.import2.mppservice.MonetDBMppService.uploadCsvFile(MonetDBMppService.scala:38) smartbix.smartcube.import2.DataMoveService.csv2Db$$anonfun$1(DataMoveService.scala:417) scala.runtime.function.JProcedure1.apply(JProcedure1.java:15) scala.runtime.function.JProcedure1.apply(JProcedure1.java:10) scala.util.Using$.resource(Using.scala:261) smartbix.smartcube.import2.DataMoveService.csv2Db(DataMoveService.scala:418) smartbix.smartcube.import2.DataMoveService.$anonfun$4(DataMoveService.scala:350) smartbix.smartcube.import2.CsvLevelFuture$.apply$$anonfun$2(DataMoveService.scala:60) scala.concurrent.Future$.$anonfun$apply$1(Future.scala:678) scala.concurrent.impl.Promise$Transformation.run(Promise.scala:467) smartbi.executor.SmartbiExecutorService.lambda$execute$0(SmartbiExecutorService.java:53) smartbi.executor.extension.SmartbiExtensionChain.doExtend(SmartbiExtensionChain.java:47) smartbix.util.RequestCxtExtension.doExtend(RequestCxtExtension.java:106) smartbi.executor.extension.SmartbiExtensionChain.doExtend(SmartbiExtensionChain.java:45) smartbi.executor.extension.MonitorExtension.doExtend(MonitorExtension.java:48) smartbi.executor.extension.SmartbiExtensionChain.doExtend(SmartbiExtensionChain.java:45) smartbi.executor.SmartbiExecutorService.lambda$execute$1(SmartbiExecutorService.java:71) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)
Stack trace: smartbix.smartcube.import2.util.ImportEngineUtil$.throwIllegal(ImportEngineUtil.scala:23) smartbix.smartcube.import2.mppservice.MonetDBMppService.uploadCsvFile(MonetDBMppService.scala:43) smartbix.smartcube.import2.DataMoveService.csv2Db$$anonfun$1(DataMoveService.scala:417) scala.runtime.function.JProcedure1.apply(JProcedure1.java:15) scala.runtime.function.JProcedure1.apply(JProcedure1.java:10) scala.util.Using$.resource(Using.scala:261) smartbix.smartcube.import2.DataMoveService.csv2Db(DataMoveService.scala:418) smartbix.smartcube.import2.DataMoveService.$anonfun$4(DataMoveService.scala:350) smartbix.smartcube.import2.CsvLevelFuture$.apply$$anonfun$2(DataMoveService.scala:60) scala.concurrent.Future$.$anonfun$apply$1(Future.scala:678) scala.concurrent.impl.Promise$Transformation.run(Promise.scala:467) smartbi.executor.SmartbiExecutorService.lambda$execute$0(SmartbiExecutorService.java:53) smartbi.executor.extension.SmartbiExtensionChain.doExtend(SmartbiExtensionChain.java:47) smartbix.util.RequestCxtExtension.doExtend(RequestCxtExtension.java:106) smartbi.executor.extension.SmartbiExtensionChain.doExtend(SmartbiExtensionChain.java:45) smartbi.executor.extension.MonitorExtension.doExtend(MonitorExtension.java:48) smartbi.executor.extension.SmartbiExtensionChain.doExtend(SmartbiExtensionChain.java:45) smartbi.executor.SmartbiExecutorService.lambda$execute$1(SmartbiExecutorService.java:71) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)
Stack trace: smartbix.smartcube.import2.util.ImportEngineUtil$.throwIllegal(ImportEngineUtil.scala:23) smartbix.smartcube.import2.DataMoveService$.parallelMove(DataMoveService.scala:104) smartbix.smartcube.import2.DataMoveService$.move$$anonfun$1(DataMoveService.scala:75) scala.runtime.function.JProcedure1.apply(JProcedure1.java:15) scala.runtime.function.JProcedure1.apply(JProcedure1.java:10) scala.collection.immutable.List.foreach(List.scala:333) smartbix.smartcube.import2.DataMoveService$.move(DataMoveService.scala:79) smartbix.smartcube.import2.ImportService.executeDataMoveTask(ImportService.scala:452) smartbix.smartcube.import2.ImportService.buildAndExecuteTask(ImportService.scala:408) smartbix.smartcube.import2.ImportService.executeTask(ImportService.scala:283) smartbix.smartcube.import2.ImportService.executeImport(ImportService.scala:167) smartbix.smartcube.import2.ImportService$.importWhenComplete(ImportService.scala:43) smartbix.smartcube.import2.ImportService.importWhenComplete(ImportService.scala) smartbix.augmenteddataset.olap.impl.newolap.import2.ImportServiceImpl$1.call(ImportServiceImpl.java:121) smartbix.augmenteddataset.olap.impl.newolap.import2.ImportServiceImpl$1.call(ImportServiceImpl.java:108) smartbix.augmenteddataset.extract.ExtractTaskWrapper.call(ExtractTaskWrapper.java:44) smartbix.util.ThreadUtil$RequestTask.call(ThreadUtil.java:466) smartbi.executor.extension.SmartbiExtensionChain.doExtend(SmartbiExtensionChain.java:47) smartbix.util.RequestCxtExtension.doExtend(RequestCxtExtension.java:106) smartbi.executor.extension.SmartbiExtensionChain.doExtend(SmartbiExtensionChain.java:45) smartbi.executor.extension.MonitorExtension.doExtend(MonitorExtension.java:48) smartbi.executor.extension.SmartbiExtensionChain.doExtend(SmartbiExtensionChain.java:45) smartbi.executor.SmartbiExecutorService.lambda$submit$2(SmartbiExecutorService.java:88) java.util.concurrent.FutureTask.run(FutureTask.java:266) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748) |