duler.JobScheduler$
> JobHandler.run(JobScheduler.scala:223)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(
> ThreadPoolExecutor.java:1145)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(
> ThreadPoolExecutor.java:615)
> at java.l
ed job streaming job 148007638 ms.0
from job set of time 148007638 ms
INFO 25-11 20:19:47,590 - Total delay: 7.586 s for time 148007638 ms
(execution: 7.547 s)
--
View this message in context:
http://apache-carbondata-mailing-list-archive.1130556.n5.nabble.com/Using-DataFrame-to-write
-carbondata-mailing-list-archive.1130556.n5.nabble.com/Using-DataFrame-to-write-carbondata-file-cause-no-table-found-error-tp3203p3207.html
Sent from the Apache CarbonData Mailing List archive mailing list archive at
Nabble.com.
[image: Inline image 1]
here the code:
```
val df = func(rdd)
val writer = df.write
if (_resource != "") {
writer.option("path", _resource)
}
writer.options(_cfg).mode(SaveMode.valueOf(_mode)).format(_format).save()
```
and the configurations:
ยทยทยท
{
"name": "stream.output",
"params": [
