diff --git a/streamingpro-mlsql/src/main/java/streaming/dsl/mmlib/algs/SQLDiscretizer.scala b/streamingpro-mlsql/src/main/java/streaming/dsl/mmlib/algs/SQLDiscretizer.scala index 6042e709a..b6211c8b8 100644 --- a/streamingpro-mlsql/src/main/java/streaming/dsl/mmlib/algs/SQLDiscretizer.scala +++ b/streamingpro-mlsql/src/main/java/streaming/dsl/mmlib/algs/SQLDiscretizer.scala @@ -96,7 +96,7 @@ class SQLDiscretizer(override val uid: String) extends SQLAlg with Functions wit } def trainWithoutGroup(df: DataFrame, params: Map[String, String], _method: String, metaPath: String): DataFrame = { - require(isGroupParams(params), "The Et of Discretizer is not valid for multi group params!") + require(isGroupParams(params), "The multi-group params are not available for the Discretizer Et!") val dfWithId = df.withColumn("id", monotonically_increasing_id) var transformedDF = dfWithId // we need save metadatas with index, because we need index