SparkEngine - SQL / DataFrame

Completed Queries: 385

Completed Queries (385)

Page:

ID	Description	Submitted	Duration ▾	Job IDs
0	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/03 17:56:21	6 s	[1][2]
4	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/03 17:56:29	2 s	[9]
5	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/03 17:56:32	1 s	[10]
22	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/04 00:00:04	1 s	[34][35][40]
91	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/06 00:00:02	0.9 s	[161][162][163][165]
196	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/09 00:00:01	0.9 s	[362][363][364][366]
335	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/13 00:00:01	0.8 s	[630][631][632][634]
21	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/04 00:00:03	0.8 s	[33]
56	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/05 00:00:02	0.7 s	[97][98][100]
126	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/07 00:00:01	0.7 s	[228][229][230][231]
161	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/08 00:00:01	0.6 s	[295][296][297][298]
369	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/14 00:00:01	0.6 s	[695][696][699][700]
228	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/10 00:00:01	0.5 s	[425][426][428][432]
301	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/12 00:00:01	0.5 s	[563][564][565][567]
197	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/09 00:00:01	0.5 s	[365]
92	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/06 00:00:02	0.5 s	[164]
266	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/11 00:00:01	0.5 s	[496][497][498][499]
57	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/05 00:00:02	0.5 s	[99]
337	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/13 00:00:01	0.4 s	[633]
162	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/08 00:00:01	0.4 s	[299]
32	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:05:39	0.4 s	[59]
94	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 00:00:03	0.4 s	[166][167][169][172][174]
302	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/12 00:00:01	0.4 s	[566]
127	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/07 00:00:01	0.4 s	[232]
25	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:00:05	0.4 s	[41][42][43][44]
31	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:05:38	0.4 s	[58]
232	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/10 00:00:01	0.4 s	[436]
3	count at OutputSourceOperator.java:158 +details count at OutputSourceOperator.java:158 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:158) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/03 17:56:29	0.3 s	[7][8]
253	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 00:00:00	0.3 s	[478][479]
372	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/14 00:00:01	0.3 s	[703]
288	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 00:00:00	0.3 s	[545][546]
1	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/03 17:56:28	0.3 s	[3][4]
2	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/03 17:56:28	0.3 s	[5][6]
311	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 00:05:38	0.3 s	[591]
12	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:00:01	0.3 s	[23][26]
13	count at AbstractOperator.java:109 +details count at AbstractOperator.java:109 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:109) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:00:01	0.3 s	[24][25]
267	parquet at LocalFilePlatform.java:79 +details parquet at LocalFilePlatform.java:79 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.filesystem.fileplatform.LocalFilePlatform.storageCTDataset(LocalFilePlatform.java:79) com.sdata.filesystem.utils.StorageUtil.storageCTDataset(StorageUtil.java:52) com.sdata.asset.service.dataset.DatasetService.saveAssetParquetV2(DatasetService.java:96) com.sdata.asset.service.dataset.DatasetService$$FastClassBySpringCGLIB$$8b47ccc8.invoke(<generated>) org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:793) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89) com.sdata.starter.log.OpentelemetryLogAspect.preTrace(OpentelemetryLogAspect.java:95) sun.reflect.GeneratedMethodAccessor176.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) java.lang.reflect.Method.invoke(Method.java:498) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:624) org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:72) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)	2025/03/11 00:00:01	0.3 s	[500]
101	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 00:05:38	0.3 s	[189]
113	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 00:00:00	0.3 s	[210][211]
40	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 14:45:33	0.3 s	[74]
166	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 00:00:02	0.3 s	[309][310][311][312][313]
183	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 00:00:00	0.3 s	[344][345]
347	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 00:05:38	0.3 s	[659]
373	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/14 00:00:02	0.3 s	[701][702][704][705][706]
43	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 00:00:00	0.2 s	[79][80]
78	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 00:00:00	0.2 s	[143][144]
93	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 00:00:03	0.2 s	[168][170]
75	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 14:45:33	0.2 s	[138]
207	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 00:05:38	0.2 s	[391]
268	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 00:00:02	0.2 s	[501][502][504][505][507]
39	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 14:45:32	0.2 s	[73]
67	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 00:05:39	0.2 s	[123]
200	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 00:00:02	0.2 s	[370][371][373][374][375]
105	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 14:45:32	0.2 s	[196][197]
148	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 00:00:00	0.2 s	[277][278]
163	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 00:00:02	0.2 s	[301][302][304][306][307]
233	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 00:00:01	0.2 s	[433][434][435][437][438]
172	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 00:05:38	0.2 s	[324]
128	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 00:00:02	0.2 s	[233][234][236][238][240]
137	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 00:05:38	0.2 s	[257]
346	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 00:05:38	0.2 s	[658]
306	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 00:00:02	0.2 s	[577][578][579][580][581]
23	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:00:04	0.2 s	[36][37]
319	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 14:45:32	0.2 s	[606]
234	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 00:00:02	0.2 s	[439][440][441][442][444]
102	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 00:05:39	0.2 s	[190]
11	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:00:01	0.2 s	[21][22]
218	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 00:00:00	0.2 s	[411][412]
110	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 14:45:33	0.2 s	[205]
215	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 14:45:33	0.2 s	[406]
6	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/03 17:56:33	0.2 s	[11][12]
26	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/04 00:00:06	0.2 s	[45][46][47][48]
242	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 00:05:38	0.2 s	[458]
304	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 00:00:02	0.2 s	[570][571][573][575][576]
131	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 00:00:02	0.2 s	[242][243][244][245][246]
323	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 00:00:00	0.2 s	[612][613]
339	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 00:00:02	0.2 s	[635][636][639][640][642]
358	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/14 00:00:00	0.2 s	[679][680]
241	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 00:05:38	0.2 s	[457]
285	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 14:45:32	0.2 s	[540]
382	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/14 00:05:38	0.2 s	[726]
74	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 14:45:32	0.2 s	[137]
96	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/06 00:00:03	0.2 s	[175][176][177][178][179]
375	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/14 00:00:02	0.2 s	[708][709][711][713][714]
201	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 00:00:02	0.2 s	[376][377][378][379][380]
206	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 00:05:38	0.2 s	[390]
171	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/08 00:05:38	0.2 s	[323]
271	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 00:00:02	0.2 s	[509][510][512][513][514]
144	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 14:45:32	0.2 s	[271]
250	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/10 14:45:32	0.2 s	[473]
312	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/12 00:05:38	0.2 s	[592]
59	count at AbstractOperator.java:118 +details count at AbstractOperator.java:118 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:118) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 00:00:02	0.2 s	[103][104][106][108]
7	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/03 17:56:33	0.2 s	[13][14]
210	count at InputSourceOperator.java:260 +details count at InputSourceOperator.java:260 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.getAssetInputCount(InputSourceOperator.java:260) com.sdata.exchange.service.runtime.operators.extract.InputSourceOperator.handle(InputSourceOperator.java:126) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/09 14:45:32	0.2 s	[397][398]
341	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/13 00:00:02	0.2 s	[644][645][646][647][648]
66	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 00:05:38	0.2 s	[122]
136	parquet at OutputSourceOperator.java:161 +details parquet at OutputSourceOperator.java:161 org.apache.spark.sql.DataFrameWriter.parquet(DataFrameWriter.scala:789) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:161) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 00:05:38	0.2 s	[256]
145	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/07 14:45:32	0.2 s	[272]
277	jdbc at OutputSourceOperator.java:591 +details jdbc at OutputSourceOperator.java:591 org.apache.spark.sql.DataFrameWriter.jdbc(DataFrameWriter.scala:753) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.writeDSToJDBC(OutputSourceOperator.java:591) com.sdata.exchange.service.runtime.operators.load.OutputSourceOperator.handle(OutputSourceOperator.java:337) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:257) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/11 00:05:38	0.2 s	[525]
61	count at AbstractOperator.java:251 +details count at AbstractOperator.java:251 org.apache.spark.sql.Dataset.count(Dataset.scala:3499) com.sdata.exchange.service.runtime.operators.AbstractOperator.getNodeCountStatus(AbstractOperator.java:251) com.sdata.exchange.service.runtime.operators.AbstractOperator.afterNodeEnd(AbstractOperator.java:148) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.serialExecute(SparkRunnerThread.java:258) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.execute(SparkRunnerThread.java:195) com.sdata.exchange.service.runtime.runtime.SparkRunnerThread.run(SparkRunnerThread.java:142) com.sdata.starter.utils.log.TaskExecutorMBean.lambda$executeRunnable$0(TaskExecutorMBean.java:88) java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) java.lang.Thread.run(Thread.java:748)	2025/03/05 00:00:03	0.2 s	[109][110][111][112]

Page: