Skip to content

Commit c081f28

Browse files
fix: add require check message (#3638)
1 parent 40eaf50 commit c081f28

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

java/openmldb-batch/src/main/scala/com/_4paradigm/openmldb/batch/utils/HybridseUtil.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -393,7 +393,7 @@ object HybridseUtil {
393393
// So we should fix it.
394394
private def autoFileLoad(openmldbSession: OpenmldbSession, file: String, format: String,
395395
options: Map[String, String], columns: util.List[Common.ColumnDesc], loadDataSql: String): DataFrame = {
396-
require(format.equals("csv") || format.equals("parquet"))
396+
require(format.equals("csv") || format.equals("parquet"), s"unsupported format $format")
397397
val reader = openmldbSession.getSparkSession.read.options(options)
398398

399399
val (oriSchema, readSchema, tsCols) = HybridseUtil.extractOriginAndReadSchema(columns)
@@ -451,7 +451,7 @@ object HybridseUtil {
451451
}
452452

453453
def hiveDest(path: String): String = {
454-
require(path.toLowerCase.startsWith("hive://"))
454+
require(path.toLowerCase.startsWith("hive://"), s"invalid hive path $path")
455455
// hive://<table_pattern>
456456
val tableStartPos = 7
457457
path.substring(tableStartPos)

0 commit comments

Comments
 (0)