This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new 48f1ee134 [Fix] replace a new judgement method (#3448)
48f1ee134 is described below
commit 48f1ee1347d36544bc5ced9295fc74464dd1b15a
Author: zhengke zhou <[email protected]>
AuthorDate: Tue Jan 2 22:03:33 2024 +0800
[Fix] replace a new judgement method (#3448)
---
.../streampark/flink/connector/hbase/source/HBaseJavaSource.java | 4 ++--
.../apache/streampark/flink/connector/jdbc/sink/JdbcJavaSink.java | 2 +-
.../streampark/flink/connector/jdbc/source/JdbcJavaSource.java | 4 ++--
.../streampark/flink/connector/mongo/source/MongoJavaSource.java | 6 +++---
4 files changed, 8 insertions(+), 8 deletions(-)
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 e0bf77d33..a9dd19f7e 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 @@ public class HBaseJavaSource<T> {
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 df39f3d61..f49763bae 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 class JdbcJavaSink<T> {
}
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 464f1b715..bcc6cb24a 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 @@ public class JdbcJavaSource<T> {
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 d7dc70bd9..5c451f0a1 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 @@ public class MongoJavaSource<T> {
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);
