feat: select into null exception

KaidoWang · KaidoWang · commit 10417ac86f46 · 2022-04-13T15:05:57.000+08:00
diff --git a/java/openmldb-batch/src/main/scala/com/_4paradigm/openmldb/batch/nodes/SelectIntoPlan.scala b/java/openmldb-batch/src/main/scala/com/_4paradigm/openmldb/batch/nodes/SelectIntoPlan.scala
@@ -37,7 +37,7 @@ object SelectIntoPlan {
     logger.info("select into offline storage: format[{}], options[{}], write mode[{}], out path {}", format, options,
       mode, outPath)
     if (input.getDf().isEmpty) {
-      logger.info("select empty, skip save")
+      throw new Exception("select empty, skip save")
     } else {
       input.getDf().write.format(format).options(options).mode(mode).save(outPath)
     }

Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ object SelectIntoPlan {`
`37`	`37`	`logger.info("select into offline storage: format[{}], options[{}], write mode[{}], out path {}", format, options,`
`38`	`38`	`mode, outPath)`
`39`	`39`	`if (input.getDf().isEmpty) {`
`40`		`- logger.info("select empty, skip save")`
	`40`	`+ throw new Exception("select empty, skip save")`
`41`	`41`	`} else {`
`42`	`42`	`input.getDf().write.format(format).options(options).mode(mode).save(outPath)`
`43`	`43`	`}`