[Fix] replace a new judgement method (#3448)
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/src/main/java/org/apache/streampark/flink/connector/hbase/source/HBaseJavaSource.java b/streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/src/main/java/org/apache/streampark/flink/connector/hbase/source/HBaseJavaSource.java
index e0bf77d..a9dd19f 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/src/main/java/org/apache/streampark/flink/connector/hbase/source/HBaseJavaSource.java
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-hbase/src/main/java/org/apache/streampark/flink/connector/hbase/source/HBaseJavaSource.java
@@ -42,8 +42,8 @@
HBaseResultFunction<T> resultFunction,
RunningFunction runningFunc) {
- Utils.notNull(queryFunction, "QueryFunction must not be null");
- Utils.notNull(resultFunction, "ResultFunction must not be null");
+ Utils.requireNotNull(queryFunction, "QueryFunction must not be null");
+ Utils.requireNotNull(resultFunction, "ResultFunction must not be null");
HBaseSourceFunction<T> sourceFunction =
new HBaseSourceFunction<>(property, queryFunction, resultFunction, runningFunc, null);
return context.getJavaEnv().addSource(sourceFunction);
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/java/org/apache/streampark/flink/connector/jdbc/sink/JdbcJavaSink.java b/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/java/org/apache/streampark/flink/connector/jdbc/sink/JdbcJavaSink.java
index df39f3d..f49763b 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/java/org/apache/streampark/flink/connector/jdbc/sink/JdbcJavaSink.java
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/java/org/apache/streampark/flink/connector/jdbc/sink/JdbcJavaSink.java
@@ -55,7 +55,7 @@
}
public DataStreamSink<T> sink(DataStream<T> dataStream) {
- Utils.notNull(sqlFunc, "TransformFunction can not be null");
+ Utils.requireNotNull(sqlFunc, "TransformFunction can not be null");
this.jdbc =
this.jdbc == null ? ConfigUtils.getJdbcConf(context.parameter().toMap(), alias) : this.jdbc;
JdbcSinkFunction<T> sinkFun = new JdbcSinkFunction<>(this.jdbc, this.sqlFunc);
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/java/org/apache/streampark/flink/connector/jdbc/source/JdbcJavaSource.java b/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/java/org/apache/streampark/flink/connector/jdbc/source/JdbcJavaSource.java
index 464f1b7..bcc6cb2 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/java/org/apache/streampark/flink/connector/jdbc/source/JdbcJavaSource.java
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-jdbc/src/main/java/org/apache/streampark/flink/connector/jdbc/source/JdbcJavaSource.java
@@ -54,8 +54,8 @@
SQLResultFunction<T> resultFunction,
RunningFunction runningFunc) {
- Utils.notNull(queryFunction, "'queryFunction' must not be null");
- Utils.notNull(resultFunction, "'resultFunction' must not be null");
+ Utils.requireNotNull(queryFunction, "'queryFunction' must not be null");
+ Utils.requireNotNull(resultFunction, "'resultFunction' must not be null");
this.jdbc =
this.jdbc == null ? ConfigUtils.getJdbcConf(context.parameter().toMap(), alias) : this.jdbc;
JdbcSourceFunction<T> sourceFunction =
diff --git a/streampark-flink/streampark-flink-connector/streampark-flink-connector-mongo/src/main/java/org/apache/streampark/flink/connector/mongo/source/MongoJavaSource.java b/streampark-flink/streampark-flink-connector/streampark-flink-connector-mongo/src/main/java/org/apache/streampark/flink/connector/mongo/source/MongoJavaSource.java
index d7dc70b..5c451f0 100644
--- a/streampark-flink/streampark-flink-connector/streampark-flink-connector-mongo/src/main/java/org/apache/streampark/flink/connector/mongo/source/MongoJavaSource.java
+++ b/streampark-flink/streampark-flink-connector/streampark-flink-connector-mongo/src/main/java/org/apache/streampark/flink/connector/mongo/source/MongoJavaSource.java
@@ -43,9 +43,9 @@
MongoResultFunction<T> resultFunction,
RunningFunction runningFunc) {
- Utils.notNull(collectionName, "'collectionName' must not be null");
- Utils.notNull(queryFunction, "'queryFunction' must not be null");
- Utils.notNull(resultFunction, "'resultFunction' must not be null");
+ Utils.requireNotNull(collectionName, "'collectionName' must not be null");
+ Utils.requireNotNull(queryFunction, "'queryFunction' must not be null");
+ Utils.requireNotNull(resultFunction, "'resultFunction' must not be null");
MongoSourceFunction<T> sourceFunction =
new MongoSourceFunction<>(
collectionName, property, queryFunction, resultFunction, runningFunc, null);
